types

Documentation

Index

• type KafkaSourceClient
• type KafkaSourceCommandFactory
• type KafkaSourceFactory
• type KafkaSourceFlagsFactory
• type KafkaSourceParams
  • func (p *KafkaSourceParams) NewSourcesClient() (*clientv1alpha1.SourcesV1alpha1Client, error)
• type KafkaSourceRunEFactory

Types

type KafkaSourceClient

type KafkaSourceClient interface {
	sourcetypes.KnSourceClient
	KafkaSourceParams() *KafkaSourceParams
	CreateKafkaSource(kafkaSource *v1alpha1.KafkaSource) error
	DeleteKafkaSource(name string) error
	GetKafkaSource(name string) (*v1alpha1.KafkaSource, error)
}

type KafkaSourceCommandFactory

type KafkaSourceCommandFactory interface {
	sourcetypes.CommandFactory

	KafkaSourceFactory() KafkaSourceFactory
}

type KafkaSourceFactory

type KafkaSourceFactory interface {
	sourcetypes.KnSourceFactory

	KafkaSourceParams() *KafkaSourceParams
	KafkaSourceClient() KafkaSourceClient

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

type KafkaSourceFlagsFactory

type KafkaSourceFlagsFactory interface {
	sourcetypes.FlagsFactory

	KafkaSourceFactory() KafkaSourceFactory
}

type KafkaSourceParams

type KafkaSourceParams struct {
	KnSourceParams   *sourcetypes.KnSourceParams
	BootstrapServers string
	Topics           string
	ConsumerGroup    string
}

func (*KafkaSourceParams) NewSourcesClient

func (p *KafkaSourceParams) NewSourcesClient() (*clientv1alpha1.SourcesV1alpha1Client, error)

type KafkaSourceRunEFactory

type KafkaSourceRunEFactory interface {
	sourcetypes.RunEFactory

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