types

type KafkaSourceClient interface {
	sourcetypes.KnSourceClient
	KafkaSourceParams() *KafkaSourceParams
	CreateKafkaSource(ctx context.Context, kafkaSource *v1beta1.KafkaSource) error
	DeleteKafkaSource(ctx context.Context, name string) error
	GetKafkaSource(ctx context.Context, name string) (*v1beta1.KafkaSource, error)
	ListKafkaSources(ctx context.Context) (*v1beta1.KafkaSourceList, error)
}

type KafkaSourceCommandFactory interface {
	sourcetypes.CommandFactory

	KafkaSourceFactory() KafkaSourceFactory
}

type KafkaSourceFactory interface {
	sourcetypes.KnSourceFactory

	KafkaSourceParams() *KafkaSourceParams
	KafkaSourceClient() KafkaSourceClient

	CreateKafkaSourceClient(restConfig *rest.Config, namespace string) (KafkaSourceClient, error)
	CreateKafkaSourceParams() *KafkaSourceParams
}

type KafkaSourceFlagsFactory interface {
	sourcetypes.FlagsFactory

	KafkaSourceFactory() KafkaSourceFactory
}

type KafkaSourceParams struct {
	KnSourceParams   *sourcetypes.KnSourceParams
	BootstrapServers []string
	Topics           []string
	ConsumerGroup    string
	CeOverrides      []string
	Labels           []string
	Annotations      []string
}

type KafkaSourceRunEFactory interface {
	sourcetypes.RunEFactory

	KafkaSourceFactory() KafkaSourceFactory
	KafkaSourceClient(restConfig *rest.Config, namespace string) (KafkaSourceClient, error)
}