mocks

Sep 27, 2022

Changes in this version

type AsyncProducer

+ func (mp *AsyncProducer) AbortTxn() error

+ func (mp *AsyncProducer) AddMessageToTxn(msg *sarama.ConsumerMessage, groupId string, metadata *string) error

+ func (mp *AsyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error

+ func (mp *AsyncProducer) BeginTxn() error

+ func (mp *AsyncProducer) CommitTxn() error

+ func (mp *AsyncProducer) IsTransactional() bool

+ func (mp *AsyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag

type SyncProducer

+ func (sp *SyncProducer) AbortTxn() error

+ func (sp *SyncProducer) AddMessageToTxn(msg *sarama.ConsumerMessage, groupId string, metadata *string) error

+ func (sp *SyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error

+ func (sp *SyncProducer) BeginTxn() error

+ func (sp *SyncProducer) CommitTxn() error

+ func (sp *SyncProducer) IsTransactional() bool

+ func (sp *SyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag

Feb 1, 2022

retracted

Changes in this version

type Consumer

+ func (c *Consumer) Pause(topicPartitions map[string][]int32)

+ func (c *Consumer) PauseAll()

+ func (c *Consumer) Resume(topicPartitions map[string][]int32)

+ func (c *Consumer) ResumeAll()

type PartitionConsumer

+ func (pc *PartitionConsumer) IsPaused() bool

+ func (pc *PartitionConsumer) Pause()

+ func (pc *PartitionConsumer) Resume()

Jun 22, 2021

Changes in this version

type AsyncProducer

+ func (mp *AsyncProducer) ExpectInputWithMessageCheckerFunctionAndFail(cf MessageChecker, err error)

+ func (mp *AsyncProducer) ExpectInputWithMessageCheckerFunctionAndSucceed(cf MessageChecker)

+ type MessageChecker func(*sarama.ProducerMessage) error

type SyncProducer

+ func (sp *SyncProducer) ExpectSendMessageWithMessageCheckerFunctionAndFail(cf MessageChecker, err error)

+ func (sp *SyncProducer) ExpectSendMessageWithMessageCheckerFunctionAndSucceed(cf MessageChecker)

+ type TopicConfig struct

+ func NewTopicConfig() *TopicConfig

+ func (pc *TopicConfig) SetDefaultPartitions(n int32)

+ func (pc *TopicConfig) SetPartitions(partitions map[string]int32)

Oct 7, 2020

Changes in this version

+ func NewTestConfig() *sarama.Config

Dec 20, 2016

Changes in this version

type Consumer

+ func (c *Consumer) HighWaterMarks() map[string]map[int32]int64

Aug 2, 2016

Changes in this version

type AsyncProducer

+ func (mp *AsyncProducer) ExpectInputWithCheckerFunctionAndFail(cf ValueChecker, err error)

+ func (mp *AsyncProducer) ExpectInputWithCheckerFunctionAndSucceed(cf ValueChecker)

type SyncProducer

+ func (sp *SyncProducer) ExpectSendMessageWithCheckerFunctionAndFail(cf ValueChecker, err error)

+ func (sp *SyncProducer) ExpectSendMessageWithCheckerFunctionAndSucceed(cf ValueChecker)

+ func (sp *SyncProducer) SendMessages(msgs []*sarama.ProducerMessage) error

+ type ValueChecker func(val []byte) error

May 1, 2015

Changes in this version

type Consumer

+ func (c *Consumer) Partitions(topic string) ([]int32, error)

+ func (c *Consumer) SetTopicMetadata(metadata map[string][]int32)

+ func (c *Consumer) Topics() ([]string, error)

type PartitionConsumer

+ func (pc *PartitionConsumer) HighWaterMarkOffset() int64

Mar 17, 2015

Changes in this version

+ const AnyOffset

+ type AsyncProducer struct

+ func NewAsyncProducer(t ErrorReporter, config *sarama.Config) *AsyncProducer

+ func (mp *AsyncProducer) AsyncClose()

+ func (mp *AsyncProducer) Close() error

+ func (mp *AsyncProducer) Errors() <-chan *sarama.ProducerError

+ func (mp *AsyncProducer) ExpectInputAndFail(err error)

+ func (mp *AsyncProducer) ExpectInputAndSucceed()

+ func (mp *AsyncProducer) Input() chan<- *sarama.ProducerMessage

+ func (mp *AsyncProducer) Successes() <-chan *sarama.ProducerMessage

+ type Consumer struct

+ func NewConsumer(t ErrorReporter, config *sarama.Config) *Consumer

+ func (c *Consumer) Close() error

+ func (c *Consumer) ConsumePartition(topic string, partition int32, offset int64) (sarama.PartitionConsumer, error)

+ func (c *Consumer) ExpectConsumePartition(topic string, partition int32, offset int64) *PartitionConsumer

+ type ErrorReporter interface

+ Errorf func(string, ...interface{})

+ type PartitionConsumer struct

+ func (pc *PartitionConsumer) AsyncClose()

+ func (pc *PartitionConsumer) Close() error

+ func (pc *PartitionConsumer) Errors() <-chan *sarama.ConsumerError

+ func (pc *PartitionConsumer) ExpectErrorsDrainedOnClose()

+ func (pc *PartitionConsumer) ExpectMessagesDrainedOnClose()

+ func (pc *PartitionConsumer) Messages() <-chan *sarama.ConsumerMessage

+ func (pc *PartitionConsumer) YieldError(err error)

+ func (pc *PartitionConsumer) YieldMessage(msg *sarama.ConsumerMessage)

+ type SyncProducer struct

+ func NewSyncProducer(t ErrorReporter, config *sarama.Config) *SyncProducer

+ func (sp *SyncProducer) Close() error

+ func (sp *SyncProducer) ExpectSendMessageAndFail(err error)

+ func (sp *SyncProducer) ExpectSendMessageAndSucceed()

+ func (sp *SyncProducer) SendMessage(msg *sarama.ProducerMessage) (partition int32, offset int64, err error)