mocks

Documentation

Index

• type KafkaStreamConfig
  • func (_m *KafkaStreamConfig) ChannelProduce(topic *string, value []byte)
  • func (_m *KafkaStreamConfig) Close() error
  • func (_m *KafkaStreamConfig) Flush(ms int) int
  • func (_m *KafkaStreamConfig) FullTopic(t string) string
  • func (_m *KafkaStreamConfig) GetBrokers() string
  • func (_m *KafkaStreamConfig) GetConsumer() *kafka.Consumer
  • func (_m *KafkaStreamConfig) GetPrefix() string
  • func (_m *KafkaStreamConfig) GetProducer() *kafka.Producer
  • func (_m *KafkaStreamConfig) NewConsumer(km *kafka.ConfigMap) (*kafka.Consumer, error)
  • func (_m *KafkaStreamConfig) NewProducer(km *kafka.ConfigMap) (*kafka.Producer, error)
  • func (_m *KafkaStreamConfig) Produce(topic *string, value []byte) error
  • func (_m *KafkaStreamConfig) ProducerDefaults() *kafka.ConfigMap
  • func (_m *KafkaStreamConfig) SetBrokers(brokers string)
  • func (_m *KafkaStreamConfig) SetDeliveryError(f func(*kafka.Message))
  • func (_m *KafkaStreamConfig) SetFlags()
  • func (_m *KafkaStreamConfig) SetPrefix(prefix string)
  • func (_m *KafkaStreamConfig) SetTopic(topic string)

Types

type KafkaStreamConfig

type KafkaStreamConfig struct {
	mock.Mock
}

KafkaStreamConfig is an autogenerated mock type for the KafkaStreamConfig type

func (*KafkaStreamConfig) ChannelProduce

func (_m *KafkaStreamConfig) ChannelProduce(topic *string, value []byte)

ChannelProduce provides a mock function with given fields: topic, value

func (*KafkaStreamConfig) Close

func (_m *KafkaStreamConfig) Close() error

Close provides a mock function with given fields:

func (*KafkaStreamConfig) Flush

func (_m *KafkaStreamConfig) Flush(ms int) int

Flush provides a mock function with given fields: ms

func (*KafkaStreamConfig) FullTopic

func (_m *KafkaStreamConfig) FullTopic(t string) string

FullTopic provides a mock function with given fields: t

func (*KafkaStreamConfig) GetBrokers

func (_m *KafkaStreamConfig) GetBrokers() string

GetBrokers provides a mock function with given fields:

func (*KafkaStreamConfig) GetConsumer

func (_m *KafkaStreamConfig) GetConsumer() *kafka.Consumer

GetConsumer provides a mock function with given fields:

func (*KafkaStreamConfig) GetPrefix

func (_m *KafkaStreamConfig) GetPrefix() string

GetPrefix provides a mock function with given fields:

func (*KafkaStreamConfig) GetProducer

func (_m *KafkaStreamConfig) GetProducer() *kafka.Producer

GetProducer provides a mock function with given fields:

func (*KafkaStreamConfig) NewConsumer

func (_m *KafkaStreamConfig) NewConsumer(km *kafka.ConfigMap) (*kafka.Consumer, error)

NewConsumer provides a mock function with given fields: km

func (*KafkaStreamConfig) NewProducer

func (_m *KafkaStreamConfig) NewProducer(km *kafka.ConfigMap) (*kafka.Producer, error)

NewProducer provides a mock function with given fields: km

func (*KafkaStreamConfig) Produce

func (_m *KafkaStreamConfig) Produce(topic *string, value []byte) error

Produce provides a mock function with given fields: topic, value

func (*KafkaStreamConfig) ProducerDefaults

func (_m *KafkaStreamConfig) ProducerDefaults() *kafka.ConfigMap

ProducerDefaults provides a mock function with given fields:

func (*KafkaStreamConfig) SetBrokers

func (_m *KafkaStreamConfig) SetBrokers(brokers string)

SetBrokers provides a mock function with given fields: brokers

func (*KafkaStreamConfig) SetDeliveryError

func (_m *KafkaStreamConfig) SetDeliveryError(f func(*kafka.Message))

SetDeliveryError provides a mock function with given fields: f

func (*KafkaStreamConfig) SetFlags

func (_m *KafkaStreamConfig) SetFlags()

SetFlags provides a mock function with given fields:

func (*KafkaStreamConfig) SetPrefix

func (_m *KafkaStreamConfig) SetPrefix(prefix string)

SetPrefix provides a mock function with given fields: prefix

func (*KafkaStreamConfig) SetTopic

func (_m *KafkaStreamConfig) SetTopic(topic string)

SetTopic provides a mock function with given fields: topic