mock

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(cfgOption string)
  • func (kp KafkaDataSourceMock) SetContext(contextName string) error

Types

type KafkaDataSourceMock

type KafkaDataSourceMock struct {
}

func (KafkaDataSourceMock) ConsumeTopic

func (kp KafkaDataSourceMock) ConsumeTopic(ctx context.Context, topicName string, flags api.ConsumeFlags, handleMessage api.MessageHandlerFunc, onError func(err any)) 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(cfgOption string)

func (KafkaDataSourceMock) SetContext

func (kp KafkaDataSourceMock) SetContext(contextName string) error

SetContext implements api.KafkaDataSource.