The highest tagged major version is
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 MockProducer
- type MockProducer_Expecter
- type MockProducer_Produce_Call
- func (_c *MockProducer_Produce_Call) Return(_a0 error) *MockProducer_Produce_Call
- func (_c *MockProducer_Produce_Call) Run(run func(msg *sarama.ProducerMessage)) *MockProducer_Produce_Call
- func (_c *MockProducer_Produce_Call) RunAndReturn(run func(*sarama.ProducerMessage) error) *MockProducer_Produce_Call
- 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 ¶
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 ¶
func (_m *ConsumerGroup) Pause(partitions map[string][]int32)
Pause provides a mock function with given fields: partitions
func (*ConsumerGroup) PauseAll ¶
func (_m *ConsumerGroup) PauseAll()
PauseAll provides a mock function with given fields:
func (*ConsumerGroup) Resume ¶
func (_m *ConsumerGroup) Resume(partitions map[string][]int32)
Resume provides a mock function with given fields: partitions
func (*ConsumerGroup) ResumeAll ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 MockProducer ¶
MockProducer is an autogenerated mock type for the Producer type
func NewMockProducer ¶
func NewMockProducer(t mockConstructorTestingTNewMockProducer) *MockProducer
NewMockProducer creates a new instance of MockProducer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*MockProducer) EXPECT ¶
func (_m *MockProducer) EXPECT() *MockProducer_Expecter
func (*MockProducer) Produce ¶
func (_m *MockProducer) Produce(msg *sarama.ProducerMessage) error
Produce provides a mock function with given fields: msg
type MockProducer_Expecter ¶
type MockProducer_Expecter struct {
// contains filtered or unexported fields
}
func (*MockProducer_Expecter) Produce ¶
func (_e *MockProducer_Expecter) Produce(msg interface{}) *MockProducer_Produce_Call
Produce is a helper method to define mock.On call
- msg *sarama.ProducerMessage
type MockProducer_Produce_Call ¶
MockProducer_Produce_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Produce'
func (*MockProducer_Produce_Call) Return ¶
func (_c *MockProducer_Produce_Call) Return(_a0 error) *MockProducer_Produce_Call
func (*MockProducer_Produce_Call) Run ¶
func (_c *MockProducer_Produce_Call) Run(run func(msg *sarama.ProducerMessage)) *MockProducer_Produce_Call
func (*MockProducer_Produce_Call) RunAndReturn ¶
func (_c *MockProducer_Produce_Call) RunAndReturn(run func(*sarama.ProducerMessage) error) *MockProducer_Produce_Call
type StdLogger ¶
StdLogger is an autogenerated mock type for the StdLogger type
func NewStdLogger ¶
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 ¶
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 ¶
func (_m *SyncProducer) AbortTxn() error
AbortTxn provides a mock function with given fields:
func (*SyncProducer) AddMessageToTxn ¶
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 ¶
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 ¶
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 ¶
func (_m *SyncProducer) CommitTxn() error
CommitTxn provides a mock function with given fields:
func (*SyncProducer) IsTransactional ¶
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 ¶
func (_m *SyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag
TxnStatus provides a mock function with given fields:
Source Files