Documentation
¶
Index ¶
- func NewFakeKafkaSourceFactory(ns string) types.KafkaSourceFactory
- func NewFakeKafkaSourceRunEFactory(ns string) types.KafkaSourceRunEFactory
- func NewKafkaSourceCommandFactory(kafkaFactory types.KafkaSourceFactory) types.KafkaSourceCommandFactory
- func NewKafkaSourceFactory() types.KafkaSourceFactory
- func NewKafkaSourceFlagsFactory(kafkaFactory types.KafkaSourceFactory) types.KafkaSourceFlagsFactory
- func NewKafkaSourceRunEFactory(kafkaFactory types.KafkaSourceFactory) types.KafkaSourceRunEFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFakeKafkaSourceFactory ¶
func NewFakeKafkaSourceFactory(ns string) types.KafkaSourceFactory
func NewFakeKafkaSourceRunEFactory ¶
func NewFakeKafkaSourceRunEFactory(ns string) types.KafkaSourceRunEFactory
func NewKafkaSourceCommandFactory ¶
func NewKafkaSourceCommandFactory(kafkaFactory types.KafkaSourceFactory) types.KafkaSourceCommandFactory
func NewKafkaSourceFactory ¶
func NewKafkaSourceFactory() types.KafkaSourceFactory
func NewKafkaSourceFlagsFactory ¶
func NewKafkaSourceFlagsFactory(kafkaFactory types.KafkaSourceFactory) types.KafkaSourceFlagsFactory
func NewKafkaSourceRunEFactory ¶
func NewKafkaSourceRunEFactory(kafkaFactory types.KafkaSourceFactory) types.KafkaSourceRunEFactory
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.