Documentation
¶
Index ¶
- type ConsumerGroup
- func (_m *ConsumerGroup) Close() error
- func (_m *ConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error
- func (_m *ConsumerGroup) Errors() <-chan error
- func (_m *ConsumerGroup) Pause(partitions map[string][]int32)
- func (_m *ConsumerGroup) PauseAll()
- func (_m *ConsumerGroup) Resume(partitions map[string][]int32)
- func (_m *ConsumerGroup) ResumeAll()
- type ConsumerGroupClaim
- type ConsumerGroupHandler
- type ConsumerGroupSession
- func (_m *ConsumerGroupSession) Claims() map[string][]int32
- func (_m *ConsumerGroupSession) Commit()
- func (_m *ConsumerGroupSession) Context() context.Context
- func (_m *ConsumerGroupSession) GenerationID() int32
- func (_m *ConsumerGroupSession) MarkMessage(msg *sarama.ConsumerMessage, metadata string)
- func (_m *ConsumerGroupSession) MarkOffset(topic string, partition int32, offset int64, metadata string)
- func (_m *ConsumerGroupSession) MemberID() string
- func (_m *ConsumerGroupSession) ResetOffset(topic string, partition int32, offset int64, metadata string)
- type StdLogger
- type SyncProducer
- func (_m *SyncProducer) AbortTxn() error
- func (_m *SyncProducer) AddMessageToTxn(msg *sarama.ConsumerMessage, groupId string, metadata *string) error
- func (_m *SyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error
- func (_m *SyncProducer) BeginTxn() error
- func (_m *SyncProducer) Close() error
- func (_m *SyncProducer) CommitTxn() error
- func (_m *SyncProducer) IsTransactional() bool
- func (_m *SyncProducer) SendMessage(msg *sarama.ProducerMessage) (int32, int64, error)
- func (_m *SyncProducer) SendMessages(msgs []*sarama.ProducerMessage) error
- func (_m *SyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerGroup ¶
ConsumerGroup is an autogenerated mock type for the ConsumerGroup type
func NewConsumerGroup ¶ added in v0.13.0
func NewConsumerGroup(t mockConstructorTestingTNewConsumerGroup) *ConsumerGroup
NewConsumerGroup creates a new instance of ConsumerGroup. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ConsumerGroup) Close ¶
func (_m *ConsumerGroup) Close() error
Close provides a mock function with given fields:
func (*ConsumerGroup) Consume ¶
func (_m *ConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error
Consume provides a mock function with given fields: ctx, topics, handler
func (*ConsumerGroup) Errors ¶
func (_m *ConsumerGroup) Errors() <-chan error
Errors provides a mock function with given fields:
func (*ConsumerGroup) Pause ¶ added in v0.13.0
func (_m *ConsumerGroup) Pause(partitions map[string][]int32)
Pause provides a mock function with given fields: partitions
func (*ConsumerGroup) PauseAll ¶ added in v0.13.0
func (_m *ConsumerGroup) PauseAll()
PauseAll provides a mock function with given fields:
func (*ConsumerGroup) Resume ¶ added in v0.13.0
func (_m *ConsumerGroup) Resume(partitions map[string][]int32)
Resume provides a mock function with given fields: partitions
func (*ConsumerGroup) ResumeAll ¶ added in v0.13.0
func (_m *ConsumerGroup) ResumeAll()
ResumeAll provides a mock function with given fields:
type ConsumerGroupClaim ¶
ConsumerGroupClaim is an autogenerated mock type for the ConsumerGroupClaim type
func NewConsumerGroupClaim ¶ added in v0.13.0
func NewConsumerGroupClaim(t mockConstructorTestingTNewConsumerGroupClaim) *ConsumerGroupClaim
NewConsumerGroupClaim creates a new instance of ConsumerGroupClaim. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ConsumerGroupClaim) HighWaterMarkOffset ¶
func (_m *ConsumerGroupClaim) HighWaterMarkOffset() int64
HighWaterMarkOffset provides a mock function with given fields:
func (*ConsumerGroupClaim) InitialOffset ¶
func (_m *ConsumerGroupClaim) InitialOffset() int64
InitialOffset provides a mock function with given fields:
func (*ConsumerGroupClaim) Messages ¶
func (_m *ConsumerGroupClaim) Messages() <-chan *sarama.ConsumerMessage
Messages provides a mock function with given fields:
func (*ConsumerGroupClaim) Partition ¶
func (_m *ConsumerGroupClaim) Partition() int32
Partition provides a mock function with given fields:
func (*ConsumerGroupClaim) Topic ¶
func (_m *ConsumerGroupClaim) Topic() string
Topic provides a mock function with given fields:
type ConsumerGroupHandler ¶
ConsumerGroupHandler is an autogenerated mock type for the ConsumerGroupHandler type
func NewConsumerGroupHandler ¶ added in v0.13.0
func NewConsumerGroupHandler(t mockConstructorTestingTNewConsumerGroupHandler) *ConsumerGroupHandler
NewConsumerGroupHandler creates a new instance of ConsumerGroupHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ConsumerGroupHandler) Cleanup ¶
func (_m *ConsumerGroupHandler) Cleanup(_a0 sarama.ConsumerGroupSession) error
Cleanup provides a mock function with given fields: _a0
func (*ConsumerGroupHandler) ConsumeClaim ¶
func (_m *ConsumerGroupHandler) ConsumeClaim(_a0 sarama.ConsumerGroupSession, _a1 sarama.ConsumerGroupClaim) error
ConsumeClaim provides a mock function with given fields: _a0, _a1
func (*ConsumerGroupHandler) Setup ¶
func (_m *ConsumerGroupHandler) Setup(_a0 sarama.ConsumerGroupSession) error
Setup provides a mock function with given fields: _a0
type ConsumerGroupSession ¶
ConsumerGroupSession is an autogenerated mock type for the ConsumerGroupSession type
func NewConsumerGroupSession ¶ added in v0.13.0
func NewConsumerGroupSession(t mockConstructorTestingTNewConsumerGroupSession) *ConsumerGroupSession
NewConsumerGroupSession creates a new instance of ConsumerGroupSession. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ConsumerGroupSession) Claims ¶
func (_m *ConsumerGroupSession) Claims() map[string][]int32
Claims provides a mock function with given fields:
func (*ConsumerGroupSession) Commit ¶ added in v0.13.0
func (_m *ConsumerGroupSession) Commit()
Commit provides a mock function with given fields:
func (*ConsumerGroupSession) Context ¶
func (_m *ConsumerGroupSession) Context() context.Context
Context provides a mock function with given fields:
func (*ConsumerGroupSession) GenerationID ¶
func (_m *ConsumerGroupSession) GenerationID() int32
GenerationID provides a mock function with given fields:
func (*ConsumerGroupSession) MarkMessage ¶
func (_m *ConsumerGroupSession) MarkMessage(msg *sarama.ConsumerMessage, metadata string)
MarkMessage provides a mock function with given fields: msg, metadata
func (*ConsumerGroupSession) MarkOffset ¶
func (_m *ConsumerGroupSession) MarkOffset(topic string, partition int32, offset int64, metadata string)
MarkOffset provides a mock function with given fields: topic, partition, offset, metadata
func (*ConsumerGroupSession) MemberID ¶
func (_m *ConsumerGroupSession) MemberID() string
MemberID provides a mock function with given fields:
func (*ConsumerGroupSession) ResetOffset ¶
func (_m *ConsumerGroupSession) ResetOffset(topic string, partition int32, offset int64, metadata string)
ResetOffset provides a mock function with given fields: topic, partition, offset, metadata
type StdLogger ¶
StdLogger is an autogenerated mock type for the StdLogger type
func NewStdLogger ¶ added in v0.13.0
func NewStdLogger(t mockConstructorTestingTNewStdLogger) *StdLogger
NewStdLogger creates a new instance of StdLogger. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*StdLogger) Print ¶
func (_m *StdLogger) Print(v ...interface{})
Print provides a mock function with given fields: v
type SyncProducer ¶
SyncProducer is an autogenerated mock type for the SyncProducer type
func NewSyncProducer ¶ added in v0.13.0
func NewSyncProducer(t mockConstructorTestingTNewSyncProducer) *SyncProducer
NewSyncProducer creates a new instance of SyncProducer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*SyncProducer) AbortTxn ¶ added in v0.13.0
func (_m *SyncProducer) AbortTxn() error
AbortTxn provides a mock function with given fields:
func (*SyncProducer) AddMessageToTxn ¶ added in v0.13.0
func (_m *SyncProducer) AddMessageToTxn(msg *sarama.ConsumerMessage, groupId string, metadata *string) error
AddMessageToTxn provides a mock function with given fields: msg, groupId, metadata
func (*SyncProducer) AddOffsetsToTxn ¶ added in v0.13.0
func (_m *SyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error
AddOffsetsToTxn provides a mock function with given fields: offsets, groupId
func (*SyncProducer) BeginTxn ¶ added in v0.13.0
func (_m *SyncProducer) BeginTxn() error
BeginTxn provides a mock function with given fields:
func (*SyncProducer) Close ¶
func (_m *SyncProducer) Close() error
Close provides a mock function with given fields:
func (*SyncProducer) CommitTxn ¶ added in v0.13.0
func (_m *SyncProducer) CommitTxn() error
CommitTxn provides a mock function with given fields:
func (*SyncProducer) IsTransactional ¶ added in v0.13.0
func (_m *SyncProducer) IsTransactional() bool
IsTransactional provides a mock function with given fields:
func (*SyncProducer) SendMessage ¶
func (_m *SyncProducer) SendMessage(msg *sarama.ProducerMessage) (int32, int64, error)
SendMessage provides a mock function with given fields: msg
func (*SyncProducer) SendMessages ¶
func (_m *SyncProducer) SendMessages(msgs []*sarama.ProducerMessage) error
SendMessages provides a mock function with given fields: msgs
func (*SyncProducer) TxnStatus ¶ added in v0.13.0
func (_m *SyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag
TxnStatus provides a mock function with given fields: