Moving Placeable type and new Scheduler to eventing core

pkg/apis/sources/v1beta1/kafka_scheduling.go

@@ -18,7 +18,7 @@ package v1beta1
 
 import (
 	"k8s.io/apimachinery/pkg/types"
-	"knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
+	"knative.dev/eventing/pkg/apis/duck/v1alpha1"
 )
 
 func (k *KafkaSource) GetKey() types.NamespacedName {

pkg/apis/sources/v1beta1/kafka_scheduling_test.go

@@ -23,7 +23,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/utils/pointer"
-	"knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
+	"knative.dev/eventing/pkg/apis/duck/v1alpha1"
 )
 
 func TestScheduling(t *testing.T) {

pkg/apis/sources/v1beta1/kafka_types.go

@@ -19,7 +19,7 @@ package v1beta1
 import (
 	"fmt"
 
-	"knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
+	"knative.dev/eventing/pkg/apis/duck/v1alpha1"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"

pkg/common/constants/constants.go

@@ -73,8 +73,4 @@ const (
 
 	// KafkaTopicConfigRetentionMs is the key in the Sarama TopicDetail ConfigEntries map for retention time (in ms)
 	KafkaTopicConfigRetentionMs = "retention.ms"
-
-	// PodAnnotationKey is an annotation used by the scheduler to be informed of pods
-	// being evicted and not use it for placing vreplicas
-	PodAnnotationKey = "eventing.knative.dev/unschedulable"
 )