mock

Documentation

Index

• func NewMockController(t gomock.TestReporter) *gomock.Controller
• type MockConsumer
  • func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
  • func (_m *MockConsumer) AddGroupPartition(_param0 int32)
  • func (_m *MockConsumer) AddPartition(_param0 string, _param1 int32, _param2 int64) error
  • func (_m *MockConsumer) Close() error
  • func (_m *MockConsumer) Commit(_param0 string, _param1 int32, _param2 int64) error
  • func (_m *MockConsumer) EXPECT() *_MockConsumerRecorder
  • func (_m *MockConsumer) Events() <-chan kafka.Event
  • func (_m *MockConsumer) RemovePartition(_param0 string, _param1 int32) error
  • func (_m *MockConsumer) Subscribe(_param0 map[string]int64) error
• type MockProducer
  • func NewMockProducer(ctrl *gomock.Controller) *MockProducer
  • func (_m *MockProducer) Close() error
  • func (_m *MockProducer) EXPECT() *_MockProducerRecorder
  • func (_m *MockProducer) Emit(_param0 string, _param1 string, _param2 []byte) *kafka.Promise
• type MockStorage
  • func NewMockStorage(ctrl *gomock.Controller) *MockStorage
  • func (_m *MockStorage) Close() error
  • func (_m *MockStorage) Delete(_param0 string) error
  • func (_m *MockStorage) EXPECT() *_MockStorageRecorder
  • func (_m *MockStorage) Get(_param0 string) ([]byte, error)
  • func (_m *MockStorage) GetOffset(_param0 int64) (int64, error)
  • func (_m *MockStorage) Has(_param0 string) (bool, error)
  • func (_m *MockStorage) Iterator() (storage.Iterator, error)
  • func (_m *MockStorage) IteratorWithRange(_param0 []byte, _param1 []byte) (storage.Iterator, error)
  • func (_m *MockStorage) MarkRecovered() error
  • func (_m *MockStorage) Open() error
  • func (_m *MockStorage) Recovered() bool
  • func (_m *MockStorage) Set(_param0 string, _param1 []byte) error
  • func (_m *MockStorage) SetOffset(_param0 int64) error
• type MockTopicManager
  • func NewMockTopicManager(ctrl *gomock.Controller) *MockTopicManager
  • func (_m *MockTopicManager) Close() error
  • func (_m *MockTopicManager) EXPECT() *_MockTopicManagerRecorder
  • func (_m *MockTopicManager) EnsureStreamExists(_param0 string, _param1 int) error
  • func (_m *MockTopicManager) EnsureTableExists(_param0 string, _param1 int) error
  • func (_m *MockTopicManager) Partitions(_param0 string) ([]int32, error)
• type MockkafkaProxy
  • func NewMockkafkaProxy(ctrl *gomock.Controller) *MockkafkaProxy
  • func (_m *MockkafkaProxy) Add(_param0 string, _param1 int64) error
  • func (_m *MockkafkaProxy) AddGroup()
  • func (_m *MockkafkaProxy) EXPECT() *_MockkafkaProxyRecorder
  • func (_m *MockkafkaProxy) Remove(_param0 string) error
  • func (_m *MockkafkaProxy) Stop()

Functions

func NewMockController

func NewMockController(t gomock.TestReporter) *gomock.Controller

NewMockController returns a *gomock.Controller using a wrapped testing.T (or whatever) which panics on a Fatalf. This is necessary when using a mock in kafkamock. Otherwise it will freeze on an unexpected call.

Types

type MockConsumer

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

Mock of Consumer interface

func NewMockConsumer

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

func (*MockConsumer) AddGroupPartition

func (_m *MockConsumer) AddGroupPartition(_param0 int32)

func (*MockConsumer) AddPartition

func (_m *MockConsumer) AddPartition(_param0 string, _param1 int32, _param2 int64) error

func (*MockConsumer) Close

func (_m *MockConsumer) Close() error

func (*MockConsumer) Commit

func (_m *MockConsumer) Commit(_param0 string, _param1 int32, _param2 int64) error

func (*MockConsumer) EXPECT

func (_m *MockConsumer) EXPECT() *_MockConsumerRecorder

func (*MockConsumer) Events

func (_m *MockConsumer) Events() <-chan kafka.Event

func (*MockConsumer) RemovePartition

func (_m *MockConsumer) RemovePartition(_param0 string, _param1 int32) error

func (*MockConsumer) Subscribe

func (_m *MockConsumer) Subscribe(_param0 map[string]int64) error

type MockProducer

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

Mock of Producer interface

func NewMockProducer

func NewMockProducer(ctrl *gomock.Controller) *MockProducer

func (*MockProducer) Close

func (_m *MockProducer) Close() error

func (*MockProducer) EXPECT

func (_m *MockProducer) EXPECT() *_MockProducerRecorder

func (*MockProducer) Emit

func (_m *MockProducer) Emit(_param0 string, _param1 string, _param2 []byte) *kafka.Promise

type MockStorage

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

Mock of Storage interface

func NewMockStorage

func NewMockStorage(ctrl *gomock.Controller) *MockStorage

func (*MockStorage) Close

func (_m *MockStorage) Close() error

func (*MockStorage) Delete

func (_m *MockStorage) Delete(_param0 string) error

func (*MockStorage) EXPECT

func (_m *MockStorage) EXPECT() *_MockStorageRecorder

func (*MockStorage) Get

func (_m *MockStorage) Get(_param0 string) ([]byte, error)

func (*MockStorage) GetOffset

func (_m *MockStorage) GetOffset(_param0 int64) (int64, error)

func (*MockStorage) Has

func (_m *MockStorage) Has(_param0 string) (bool, error)

func (*MockStorage) Iterator

func (_m *MockStorage) Iterator() (storage.Iterator, error)

func (*MockStorage) IteratorWithRange

func (_m *MockStorage) IteratorWithRange(_param0 []byte, _param1 []byte) (storage.Iterator, error)

func (*MockStorage) MarkRecovered

func (_m *MockStorage) MarkRecovered() error

func (*MockStorage) Open

func (_m *MockStorage) Open() error

func (*MockStorage) Recovered

func (_m *MockStorage) Recovered() bool

func (*MockStorage) Set

func (_m *MockStorage) Set(_param0 string, _param1 []byte) error

func (*MockStorage) SetOffset

func (_m *MockStorage) SetOffset(_param0 int64) error

type MockTopicManager

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

Mock of TopicManager interface

func NewMockTopicManager

func NewMockTopicManager(ctrl *gomock.Controller) *MockTopicManager

func (*MockTopicManager) Close

func (_m *MockTopicManager) Close() error

func (*MockTopicManager) EXPECT

func (_m *MockTopicManager) EXPECT() *_MockTopicManagerRecorder

func (*MockTopicManager) EnsureStreamExists

func (_m *MockTopicManager) EnsureStreamExists(_param0 string, _param1 int) error

func (*MockTopicManager) EnsureTableExists

func (_m *MockTopicManager) EnsureTableExists(_param0 string, _param1 int) error

func (*MockTopicManager) Partitions

func (_m *MockTopicManager) Partitions(_param0 string) ([]int32, error)

type MockkafkaProxy

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

Mock of kafkaProxy interface

func NewMockkafkaProxy

func NewMockkafkaProxy(ctrl *gomock.Controller) *MockkafkaProxy

func (*MockkafkaProxy) Add

func (_m *MockkafkaProxy) Add(_param0 string, _param1 int64) error

func (*MockkafkaProxy) AddGroup

func (_m *MockkafkaProxy) AddGroup()

func (*MockkafkaProxy) EXPECT

func (_m *MockkafkaProxy) EXPECT() *_MockkafkaProxyRecorder

func (*MockkafkaProxy) Remove

func (_m *MockkafkaProxy) Remove(_param0 string) error

func (*MockkafkaProxy) Stop

func (_m *MockkafkaProxy) Stop()