Documentation ¶
Index ¶
- type KafkaDataSourceMock
- func (kp KafkaDataSourceMock) ConsumeTopic(ctx context.Context, topicName string, flags api.ConsumeFlags, ...) error
- func (kp KafkaDataSourceMock) GetConsumerGroups() ([]api.ConsumerGroup, error)
- func (kp KafkaDataSourceMock) GetContext() string
- func (kp KafkaDataSourceMock) GetContexts() ([]string, error)
- func (kp KafkaDataSourceMock) GetTopics() (map[string]api.Topic, error)
- func (kp KafkaDataSourceMock) Init()
- func (kp KafkaDataSourceMock) SetContext(contextName string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaDataSourceMock ¶
type KafkaDataSourceMock struct { }
func (KafkaDataSourceMock) ConsumeTopic ¶
func (kp KafkaDataSourceMock) ConsumeTopic(ctx context.Context, topicName string, flags api.ConsumeFlags, handleMessage api.MessageHandlerFunc) error
func (KafkaDataSourceMock) GetConsumerGroups ¶
func (kp KafkaDataSourceMock) GetConsumerGroups() ([]api.ConsumerGroup, error)
func (KafkaDataSourceMock) GetContext ¶
func (kp KafkaDataSourceMock) GetContext() string
func (KafkaDataSourceMock) GetContexts ¶
func (kp KafkaDataSourceMock) GetContexts() ([]string, error)
GetContexts retrieves a list of Kafka contexts
func (KafkaDataSourceMock) GetTopics ¶
func (kp KafkaDataSourceMock) GetTopics() (map[string]api.Topic, error)
GetTopics retrieves a list of Kafka topics
func (KafkaDataSourceMock) Init ¶
func (kp KafkaDataSourceMock) Init()
func (KafkaDataSourceMock) SetContext ¶
func (kp KafkaDataSourceMock) SetContext(contextName string) error
SetContext implements api.KafkaDataSource.
Click to show internal directories.
Click to hide internal directories.