mock_confluent

Documentation

Overview

Package mock_confluent is a generated GoMock package.

Package mock_confluent is a generated GoMock package.

Index

• type MockKafkaConsumer
  • func NewMockKafkaConsumer(ctrl *gomock.Controller) *MockKafkaConsumer
  • func (m *MockKafkaConsumer) Assignment() ([]kafka.TopicPartition, error)
  • func (m *MockKafkaConsumer) AssignmentLost() bool
  • func (m *MockKafkaConsumer) Close() error
  • func (m *MockKafkaConsumer) Commit() ([]kafka.TopicPartition, error)
  • func (m *MockKafkaConsumer) EXPECT() *MockKafkaConsumerMockRecorder
  • func (m *MockKafkaConsumer) ReadMessage(timeout time.Duration) (*kafka.Message, error)
  • func (m *MockKafkaConsumer) StoreOffsets(offsets []kafka.TopicPartition) ([]kafka.TopicPartition, error)
  • func (m *MockKafkaConsumer) SubscribeTopics(topics []string, rebalanceCb kafka.RebalanceCb) error
• type MockKafkaConsumerMockRecorder
  • func (mr *MockKafkaConsumerMockRecorder) Assignment() *gomock.Call
  • func (mr *MockKafkaConsumerMockRecorder) AssignmentLost() *gomock.Call
  • func (mr *MockKafkaConsumerMockRecorder) Close() *gomock.Call
  • func (mr *MockKafkaConsumerMockRecorder) Commit() *gomock.Call
  • func (mr *MockKafkaConsumerMockRecorder) ReadMessage(timeout any) *gomock.Call
  • func (mr *MockKafkaConsumerMockRecorder) StoreOffsets(offsets any) *gomock.Call
  • func (mr *MockKafkaConsumerMockRecorder) SubscribeTopics(topics, rebalanceCb any) *gomock.Call
• type MockKafkaProducer
  • func NewMockKafkaProducer(ctrl *gomock.Controller) *MockKafkaProducer
  • func (m *MockKafkaProducer) Close()
  • func (m *MockKafkaProducer) EXPECT() *MockKafkaProducerMockRecorder
  • func (m *MockKafkaProducer) Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error
• type MockKafkaProducerMockRecorder
  • func (mr *MockKafkaProducerMockRecorder) Close() *gomock.Call
  • func (mr *MockKafkaProducerMockRecorder) Produce(msg, deliveryChan any) *gomock.Call

Types

type MockKafkaConsumer

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

MockKafkaConsumer is a mock of KafkaConsumer interface.

func NewMockKafkaConsumer

func NewMockKafkaConsumer(ctrl *gomock.Controller) *MockKafkaConsumer

NewMockKafkaConsumer creates a new mock instance.

func (*MockKafkaConsumer) Assignment

func (m *MockKafkaConsumer) Assignment() ([]kafka.TopicPartition, error)

Assignment mocks base method.

func (*MockKafkaConsumer) AssignmentLost

func (m *MockKafkaConsumer) AssignmentLost() bool

AssignmentLost mocks base method.

func (*MockKafkaConsumer) Close

func (m *MockKafkaConsumer) Close() error

Close mocks base method.

func (*MockKafkaConsumer) Commit

func (m *MockKafkaConsumer) Commit() ([]kafka.TopicPartition, error)

Commit mocks base method.

func (*MockKafkaConsumer) EXPECT

func (m *MockKafkaConsumer) EXPECT() *MockKafkaConsumerMockRecorder

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

func (*MockKafkaConsumer) ReadMessage

func (m *MockKafkaConsumer) ReadMessage(timeout time.Duration) (*kafka.Message, error)

ReadMessage mocks base method.

func (*MockKafkaConsumer) StoreOffsets

func (m *MockKafkaConsumer) StoreOffsets(offsets []kafka.TopicPartition) ([]kafka.TopicPartition, error)

StoreOffsets mocks base method.

func (*MockKafkaConsumer) SubscribeTopics

func (m *MockKafkaConsumer) SubscribeTopics(topics []string, rebalanceCb kafka.RebalanceCb) error

SubscribeTopics mocks base method.

type MockKafkaConsumerMockRecorder

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

MockKafkaConsumerMockRecorder is the mock recorder for MockKafkaConsumer.

func (*MockKafkaConsumerMockRecorder) Assignment

func (mr *MockKafkaConsumerMockRecorder) Assignment() *gomock.Call

Assignment indicates an expected call of Assignment.

func (*MockKafkaConsumerMockRecorder) AssignmentLost

func (mr *MockKafkaConsumerMockRecorder) AssignmentLost() *gomock.Call

AssignmentLost indicates an expected call of AssignmentLost.

func (*MockKafkaConsumerMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockKafkaConsumerMockRecorder) Commit

func (mr *MockKafkaConsumerMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit.

func (*MockKafkaConsumerMockRecorder) ReadMessage

func (mr *MockKafkaConsumerMockRecorder) ReadMessage(timeout any) *gomock.Call

ReadMessage indicates an expected call of ReadMessage.

func (*MockKafkaConsumerMockRecorder) StoreOffsets

func (mr *MockKafkaConsumerMockRecorder) StoreOffsets(offsets any) *gomock.Call

StoreOffsets indicates an expected call of StoreOffsets.

func (*MockKafkaConsumerMockRecorder) SubscribeTopics

func (mr *MockKafkaConsumerMockRecorder) SubscribeTopics(topics, rebalanceCb any) *gomock.Call

SubscribeTopics indicates an expected call of SubscribeTopics.

type MockKafkaProducer

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

MockKafkaProducer is a mock of KafkaProducer interface.

func NewMockKafkaProducer

func NewMockKafkaProducer(ctrl *gomock.Controller) *MockKafkaProducer

NewMockKafkaProducer creates a new mock instance.

func (*MockKafkaProducer) Close

func (m *MockKafkaProducer) Close()

Close mocks base method.

func (*MockKafkaProducer) EXPECT

func (m *MockKafkaProducer) EXPECT() *MockKafkaProducerMockRecorder

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

func (*MockKafkaProducer) Produce

func (m *MockKafkaProducer) Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error

Produce mocks base method.

type MockKafkaProducerMockRecorder

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

MockKafkaProducerMockRecorder is the mock recorder for MockKafkaProducer.

func (*MockKafkaProducerMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockKafkaProducerMockRecorder) Produce

func (mr *MockKafkaProducerMockRecorder) Produce(msg, deliveryChan any) *gomock.Call

Produce indicates an expected call of Produce.