types

Documentation

Index

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

Types

type KafkaSourceClient

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

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
	CeOverrides      []string
	Labels           []string
	Annotations      []string
}

func (*KafkaSourceParams) NewSourcesClient

func (p *KafkaSourceParams) NewSourcesClient() (*clientv1beta1.SourcesV1beta1Client, error)

type KafkaSourceRunEFactory

type KafkaSourceRunEFactory interface {
	sourcetypes.RunEFactory

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