Versions in this module Expand all Collapse all v1 v1.7.0 Feb 17, 2026 v1.6.0 Feb 10, 2026 Changes in this version + type MockConsumerGroup struct + func NewMockConsumerGroup(ctrl *gomock.Controller) *MockConsumerGroup + func (m *MockConsumerGroup) Close() error + func (m *MockConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error + func (m *MockConsumerGroup) EXPECT() *MockConsumerGroupMockRecorder + func (m *MockConsumerGroup) Errors() <-chan error + func (m *MockConsumerGroup) Pause(partitions map[string][]int32) + func (m *MockConsumerGroup) PauseAll() + func (m *MockConsumerGroup) Resume(partitions map[string][]int32) + func (m *MockConsumerGroup) ResumeAll() + type MockConsumerGroupMockRecorder struct + func (mr *MockConsumerGroupMockRecorder) Close() *gomock.Call + func (mr *MockConsumerGroupMockRecorder) Consume(ctx, topics, handler any) *gomock.Call + func (mr *MockConsumerGroupMockRecorder) Errors() *gomock.Call + func (mr *MockConsumerGroupMockRecorder) Pause(partitions any) *gomock.Call + func (mr *MockConsumerGroupMockRecorder) PauseAll() *gomock.Call + func (mr *MockConsumerGroupMockRecorder) Resume(partitions any) *gomock.Call + func (mr *MockConsumerGroupMockRecorder) ResumeAll() *gomock.Call + type MockKinesisClient struct + func NewMockKinesisClient(ctrl *gomock.Controller) *MockKinesisClient + func (m *MockKinesisClient) CreateStream(ctx context.Context, params *kinesis.CreateStreamInput, ...) (*kinesis.CreateStreamOutput, error) + func (m *MockKinesisClient) DescribeStream(ctx context.Context, params *kinesis.DescribeStreamInput, ...) (*kinesis.DescribeStreamOutput, error) + func (m *MockKinesisClient) EXPECT() *MockKinesisClientMockRecorder + func (m *MockKinesisClient) GetRecords(ctx context.Context, params *kinesis.GetRecordsInput, ...) (*kinesis.GetRecordsOutput, error) + func (m *MockKinesisClient) GetShardIterator(ctx context.Context, params *kinesis.GetShardIteratorInput, ...) (*kinesis.GetShardIteratorOutput, error) + func (m *MockKinesisClient) PutRecord(ctx context.Context, params *kinesis.PutRecordInput, ...) (*kinesis.PutRecordOutput, error) + type MockKinesisClientMockRecorder struct + func (mr *MockKinesisClientMockRecorder) CreateStream(ctx, params any, optFns ...any) *gomock.Call + func (mr *MockKinesisClientMockRecorder) DescribeStream(ctx, params any, optFns ...any) *gomock.Call + func (mr *MockKinesisClientMockRecorder) GetRecords(ctx, params any, optFns ...any) *gomock.Call + func (mr *MockKinesisClientMockRecorder) GetShardIterator(ctx, params any, optFns ...any) *gomock.Call + func (mr *MockKinesisClientMockRecorder) PutRecord(ctx, params any, optFns ...any) *gomock.Call + type MockSyncProducer struct + func NewMockSyncProducer(ctrl *gomock.Controller) *MockSyncProducer + func (m *MockSyncProducer) AbortTxn() error + func (m *MockSyncProducer) AddMessageToTxn(msg *sarama.ConsumerMessage, groupId string, metadata *string) error + func (m *MockSyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error + func (m *MockSyncProducer) BeginTxn() error + func (m *MockSyncProducer) Close() error + func (m *MockSyncProducer) CommitTxn() error + func (m *MockSyncProducer) EXPECT() *MockSyncProducerMockRecorder + func (m *MockSyncProducer) IsTransactional() bool + func (m *MockSyncProducer) SendMessage(msg *sarama.ProducerMessage) (int32, int64, error) + func (m *MockSyncProducer) SendMessages(msgs []*sarama.ProducerMessage) error + func (m *MockSyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag + type MockSyncProducerMockRecorder struct + func (mr *MockSyncProducerMockRecorder) AbortTxn() *gomock.Call + func (mr *MockSyncProducerMockRecorder) AddMessageToTxn(msg, groupId, metadata any) *gomock.Call + func (mr *MockSyncProducerMockRecorder) AddOffsetsToTxn(offsets, groupId any) *gomock.Call + func (mr *MockSyncProducerMockRecorder) BeginTxn() *gomock.Call + func (mr *MockSyncProducerMockRecorder) Close() *gomock.Call + func (mr *MockSyncProducerMockRecorder) CommitTxn() *gomock.Call + func (mr *MockSyncProducerMockRecorder) IsTransactional() *gomock.Call + func (mr *MockSyncProducerMockRecorder) SendMessage(msg any) *gomock.Call + func (mr *MockSyncProducerMockRecorder) SendMessages(msgs any) *gomock.Call + func (mr *MockSyncProducerMockRecorder) TxnStatus() *gomock.Call Other modules containing this package github.com/CrisisTextLine/modular/modules/eventbus/v2
Go to main page