mocks

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockConsumerGroup 

type MockConsumerGroup struct {
	// contains filtered or unexported fields
}

MockConsumerGroup is a mock of ConsumerGroup interface.

func NewMockConsumerGroup 

func NewMockConsumerGroup(ctrl *gomock.Controller) *MockConsumerGroup

NewMockConsumerGroup creates a new mock instance.

func (*MockConsumerGroup) Close 

func (m *MockConsumerGroup) Close() error

Close mocks base method.

func (*MockConsumerGroup) Consume 

func (m *MockConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error

Consume mocks base method.

func (*MockConsumerGroup) EXPECT 

func (m *MockConsumerGroup) EXPECT() *MockConsumerGroupMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConsumerGroup) Errors 

func (m *MockConsumerGroup) Errors() <-chan error

Errors mocks base method.

func (*MockConsumerGroup) Pause 

func (m *MockConsumerGroup) Pause(partitions map[string][]int32)

Pause mocks base method.

func (*MockConsumerGroup) PauseAll 

func (m *MockConsumerGroup) PauseAll()

PauseAll mocks base method.

func (*MockConsumerGroup) Resume 

func (m *MockConsumerGroup) Resume(partitions map[string][]int32)

Resume mocks base method.

func (*MockConsumerGroup) ResumeAll 

func (m *MockConsumerGroup) ResumeAll()

ResumeAll mocks base method.

type MockConsumerGroupMockRecorder 

type MockConsumerGroupMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerGroupMockRecorder is the mock recorder for MockConsumerGroup.

func (*MockConsumerGroupMockRecorder) Close 

func (mr *MockConsumerGroupMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockConsumerGroupMockRecorder) Consume 

func (mr *MockConsumerGroupMockRecorder) Consume(ctx, topics, handler any) *gomock.Call

Consume indicates an expected call of Consume.

func (*MockConsumerGroupMockRecorder) Errors 

func (mr *MockConsumerGroupMockRecorder) Errors() *gomock.Call

Errors indicates an expected call of Errors.

func (*MockConsumerGroupMockRecorder) Pause 

func (mr *MockConsumerGroupMockRecorder) Pause(partitions any) *gomock.Call

Pause indicates an expected call of Pause.

func (*MockConsumerGroupMockRecorder) PauseAll 

func (mr *MockConsumerGroupMockRecorder) PauseAll() *gomock.Call

PauseAll indicates an expected call of PauseAll.

func (*MockConsumerGroupMockRecorder) Resume 

func (mr *MockConsumerGroupMockRecorder) Resume(partitions any) *gomock.Call

Resume indicates an expected call of Resume.

func (*MockConsumerGroupMockRecorder) ResumeAll 

func (mr *MockConsumerGroupMockRecorder) ResumeAll() *gomock.Call

ResumeAll indicates an expected call of ResumeAll.

type MockKinesisClient 

type MockKinesisClient struct {
	// contains filtered or unexported fields
}

MockKinesisClient is a mock of KinesisClient interface.

func NewMockKinesisClient 

func NewMockKinesisClient(ctrl *gomock.Controller) *MockKinesisClient

NewMockKinesisClient creates a new mock instance.

func (*MockKinesisClient) CreateStream 

func (m *MockKinesisClient) CreateStream(ctx context.Context, params *kinesis.CreateStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.CreateStreamOutput, error)

CreateStream mocks base method.

func (*MockKinesisClient) DescribeStream 

func (m *MockKinesisClient) DescribeStream(ctx context.Context, params *kinesis.DescribeStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamOutput, error)

DescribeStream mocks base method.

func (*MockKinesisClient) EXPECT 

func (m *MockKinesisClient) EXPECT() *MockKinesisClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKinesisClient) GetRecords 

func (m *MockKinesisClient) GetRecords(ctx context.Context, params *kinesis.GetRecordsInput, optFns ...func(*kinesis.Options)) (*kinesis.GetRecordsOutput, error)

GetRecords mocks base method.

func (*MockKinesisClient) GetShardIterator 

func (m *MockKinesisClient) GetShardIterator(ctx context.Context, params *kinesis.GetShardIteratorInput, optFns ...func(*kinesis.Options)) (*kinesis.GetShardIteratorOutput, error)

GetShardIterator mocks base method.

func (*MockKinesisClient) PutRecord 

func (m *MockKinesisClient) PutRecord(ctx context.Context, params *kinesis.PutRecordInput, optFns ...func(*kinesis.Options)) (*kinesis.PutRecordOutput, error)

PutRecord mocks base method.

type MockKinesisClientMockRecorder 

type MockKinesisClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockKinesisClientMockRecorder is the mock recorder for MockKinesisClient.

func (*MockKinesisClientMockRecorder) CreateStream 

func (mr *MockKinesisClientMockRecorder) CreateStream(ctx, params any, optFns ...any) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockKinesisClientMockRecorder) DescribeStream 

func (mr *MockKinesisClientMockRecorder) DescribeStream(ctx, params any, optFns ...any) *gomock.Call

DescribeStream indicates an expected call of DescribeStream.

func (*MockKinesisClientMockRecorder) GetRecords 

func (mr *MockKinesisClientMockRecorder) GetRecords(ctx, params any, optFns ...any) *gomock.Call

GetRecords indicates an expected call of GetRecords.

func (*MockKinesisClientMockRecorder) GetShardIterator 

func (mr *MockKinesisClientMockRecorder) GetShardIterator(ctx, params any, optFns ...any) *gomock.Call

GetShardIterator indicates an expected call of GetShardIterator.

func (*MockKinesisClientMockRecorder) PutRecord 

func (mr *MockKinesisClientMockRecorder) PutRecord(ctx, params any, optFns ...any) *gomock.Call

PutRecord indicates an expected call of PutRecord.

type MockSyncProducer 

type MockSyncProducer struct {
	// contains filtered or unexported fields
}

MockSyncProducer is a mock of SyncProducer interface.

func NewMockSyncProducer 

func NewMockSyncProducer(ctrl *gomock.Controller) *MockSyncProducer

NewMockSyncProducer creates a new mock instance.

func (*MockSyncProducer) AbortTxn 

func (m *MockSyncProducer) AbortTxn() error

AbortTxn mocks base method.

func (*MockSyncProducer) AddMessageToTxn 

func (m *MockSyncProducer) AddMessageToTxn(msg *sarama.ConsumerMessage, groupId string, metadata *string) error

AddMessageToTxn mocks base method.

func (*MockSyncProducer) AddOffsetsToTxn 

func (m *MockSyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error

AddOffsetsToTxn mocks base method.

func (*MockSyncProducer) BeginTxn 

func (m *MockSyncProducer) BeginTxn() error

BeginTxn mocks base method.

func (*MockSyncProducer) Close 

func (m *MockSyncProducer) Close() error

Close mocks base method.

func (*MockSyncProducer) CommitTxn 

func (m *MockSyncProducer) CommitTxn() error

CommitTxn mocks base method.

func (*MockSyncProducer) EXPECT 

func (m *MockSyncProducer) EXPECT() *MockSyncProducerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSyncProducer) IsTransactional 

func (m *MockSyncProducer) IsTransactional() bool

IsTransactional mocks base method.

func (*MockSyncProducer) SendMessage 

func (m *MockSyncProducer) SendMessage(msg *sarama.ProducerMessage) (int32, int64, error)

SendMessage mocks base method.

func (*MockSyncProducer) SendMessages 

func (m *MockSyncProducer) SendMessages(msgs []*sarama.ProducerMessage) error

SendMessages mocks base method.

func (*MockSyncProducer) TxnStatus 

func (m *MockSyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag

TxnStatus mocks base method.

type MockSyncProducerMockRecorder 

type MockSyncProducerMockRecorder struct {
	// contains filtered or unexported fields
}

MockSyncProducerMockRecorder is the mock recorder for MockSyncProducer.

func (*MockSyncProducerMockRecorder) AbortTxn 

func (mr *MockSyncProducerMockRecorder) AbortTxn() *gomock.Call

AbortTxn indicates an expected call of AbortTxn.

func (*MockSyncProducerMockRecorder) AddMessageToTxn 

func (mr *MockSyncProducerMockRecorder) AddMessageToTxn(msg, groupId, metadata any) *gomock.Call

AddMessageToTxn indicates an expected call of AddMessageToTxn.

func (*MockSyncProducerMockRecorder) AddOffsetsToTxn 

func (mr *MockSyncProducerMockRecorder) AddOffsetsToTxn(offsets, groupId any) *gomock.Call

AddOffsetsToTxn indicates an expected call of AddOffsetsToTxn.

func (*MockSyncProducerMockRecorder) BeginTxn 

func (mr *MockSyncProducerMockRecorder) BeginTxn() *gomock.Call

BeginTxn indicates an expected call of BeginTxn.

func (*MockSyncProducerMockRecorder) Close 

func (mr *MockSyncProducerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockSyncProducerMockRecorder) CommitTxn 

func (mr *MockSyncProducerMockRecorder) CommitTxn() *gomock.Call

CommitTxn indicates an expected call of CommitTxn.

func (*MockSyncProducerMockRecorder) IsTransactional 

func (mr *MockSyncProducerMockRecorder) IsTransactional() *gomock.Call

IsTransactional indicates an expected call of IsTransactional.

func (*MockSyncProducerMockRecorder) SendMessage 

func (mr *MockSyncProducerMockRecorder) SendMessage(msg any) *gomock.Call

SendMessage indicates an expected call of SendMessage.

func (*MockSyncProducerMockRecorder) SendMessages 

func (mr *MockSyncProducerMockRecorder) SendMessages(msgs any) *gomock.Call

SendMessages indicates an expected call of SendMessages.

func (*MockSyncProducerMockRecorder) TxnStatus 

func (mr *MockSyncProducerMockRecorder) TxnStatus() *gomock.Call

TxnStatus indicates an expected call of TxnStatus.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.