mock

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2020 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

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
}

MockConsumer is a mock of Consumer interface

func NewMockConsumer 

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance

func (*MockConsumer) AddGroupPartition 

func (m *MockConsumer) AddGroupPartition(arg0 int32)

AddGroupPartition mocks base method

func (*MockConsumer) AddPartition 

func (m *MockConsumer) AddPartition(arg0 string, arg1 int32, arg2 int64) error

AddPartition mocks base method

func (*MockConsumer) Close 

func (m *MockConsumer) Close() error

Close mocks base method

func (*MockConsumer) Commit 

func (m *MockConsumer) Commit(arg0 string, arg1 int32, arg2 int64) error

Commit mocks base method

func (*MockConsumer) EXPECT 

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

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

func (*MockConsumer) Events 

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

Events mocks base method

func (*MockConsumer) RemovePartition 

func (m *MockConsumer) RemovePartition(arg0 string, arg1 int32) error

RemovePartition mocks base method

func (*MockConsumer) Subscribe 

func (m *MockConsumer) Subscribe(arg0 map[string]int64) error

Subscribe mocks base method

type MockConsumerMockRecorder added in v0.1.1 

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

MockConsumerMockRecorder is the mock recorder for MockConsumer

func (*MockConsumerMockRecorder) AddGroupPartition added in v0.1.1 

func (mr *MockConsumerMockRecorder) AddGroupPartition(arg0 interface{}) *gomock.Call

AddGroupPartition indicates an expected call of AddGroupPartition

func (*MockConsumerMockRecorder) AddPartition added in v0.1.1 

func (mr *MockConsumerMockRecorder) AddPartition(arg0, arg1, arg2 interface{}) *gomock.Call

AddPartition indicates an expected call of AddPartition

func (*MockConsumerMockRecorder) Close added in v0.1.1 

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

Close indicates an expected call of Close

func (*MockConsumerMockRecorder) Commit added in v0.1.1 

func (mr *MockConsumerMockRecorder) Commit(arg0, arg1, arg2 interface{}) *gomock.Call

Commit indicates an expected call of Commit

func (*MockConsumerMockRecorder) Events added in v0.1.1 

func (mr *MockConsumerMockRecorder) Events() *gomock.Call

Events indicates an expected call of Events

func (*MockConsumerMockRecorder) RemovePartition added in v0.1.1 

func (mr *MockConsumerMockRecorder) RemovePartition(arg0, arg1 interface{}) *gomock.Call

RemovePartition indicates an expected call of RemovePartition

func (*MockConsumerMockRecorder) Subscribe added in v0.1.1 

func (mr *MockConsumerMockRecorder) Subscribe(arg0 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe

type MockProducer 

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

MockProducer is a mock of Producer interface

func NewMockProducer 

func NewMockProducer(ctrl *gomock.Controller) *MockProducer

NewMockProducer creates a new mock instance

func (*MockProducer) Close 

func (m *MockProducer) Close() error

Close mocks base method

func (*MockProducer) EXPECT 

func (m *MockProducer) EXPECT() *MockProducerMockRecorder

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

func (*MockProducer) Emit 

func (m *MockProducer) Emit(arg0, arg1 string, arg2 []byte) *kafka.Promise

Emit mocks base method

type MockProducerMockRecorder added in v0.1.1 

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

MockProducerMockRecorder is the mock recorder for MockProducer

func (*MockProducerMockRecorder) Close added in v0.1.1 

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

Close indicates an expected call of Close

func (*MockProducerMockRecorder) Emit added in v0.1.1 

func (mr *MockProducerMockRecorder) Emit(arg0, arg1, arg2 interface{}) *gomock.Call

Emit indicates an expected call of Emit

type MockStorage 

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

MockStorage is a mock of Storage interface

func NewMockStorage 

func NewMockStorage(ctrl *gomock.Controller) *MockStorage

NewMockStorage creates a new mock instance

func (*MockStorage) Close 

func (m *MockStorage) Close() error

Close mocks base method

func (*MockStorage) Delete 

func (m *MockStorage) Delete(arg0 string) error

Delete mocks base method

func (*MockStorage) EXPECT 

func (m *MockStorage) EXPECT() *MockStorageMockRecorder

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

func (*MockStorage) Get 

func (m *MockStorage) Get(arg0 string) ([]byte, error)

Get mocks base method

func (*MockStorage) GetOffset 

func (m *MockStorage) GetOffset(arg0 int64) (int64, error)

GetOffset mocks base method

func (*MockStorage) Has 

func (m *MockStorage) Has(arg0 string) (bool, error)

Has mocks base method

func (*MockStorage) Iterator 

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

Iterator mocks base method

func (*MockStorage) IteratorWithRange 

func (m *MockStorage) IteratorWithRange(arg0, arg1 []byte) (storage.Iterator, error)

IteratorWithRange mocks base method

func (*MockStorage) MarkRecovered 

func (m *MockStorage) MarkRecovered() error

MarkRecovered mocks base method

func (*MockStorage) Open 

func (m *MockStorage) Open() error

Open mocks base method

func (*MockStorage) Recovered 

func (m *MockStorage) Recovered() bool

Recovered mocks base method

func (*MockStorage) Set 

func (m *MockStorage) Set(arg0 string, arg1 []byte) error

Set mocks base method

func (*MockStorage) SetOffset 

func (m *MockStorage) SetOffset(arg0 int64) error

SetOffset mocks base method

type MockStorageMockRecorder added in v0.1.1 

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

MockStorageMockRecorder is the mock recorder for MockStorage

func (*MockStorageMockRecorder) Close added in v0.1.1 

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

Close indicates an expected call of Close

func (*MockStorageMockRecorder) Delete added in v0.1.1 

func (mr *MockStorageMockRecorder) Delete(arg0 interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockStorageMockRecorder) Get added in v0.1.1 

func (mr *MockStorageMockRecorder) Get(arg0 interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockStorageMockRecorder) GetOffset added in v0.1.1 

func (mr *MockStorageMockRecorder) GetOffset(arg0 interface{}) *gomock.Call

GetOffset indicates an expected call of GetOffset

func (*MockStorageMockRecorder) Has added in v0.1.1 

func (mr *MockStorageMockRecorder) Has(arg0 interface{}) *gomock.Call

Has indicates an expected call of Has

func (*MockStorageMockRecorder) Iterator added in v0.1.1 

func (mr *MockStorageMockRecorder) Iterator() *gomock.Call

Iterator indicates an expected call of Iterator

func (*MockStorageMockRecorder) IteratorWithRange added in v0.1.1 

func (mr *MockStorageMockRecorder) IteratorWithRange(arg0, arg1 interface{}) *gomock.Call

IteratorWithRange indicates an expected call of IteratorWithRange

func (*MockStorageMockRecorder) MarkRecovered added in v0.1.1 

func (mr *MockStorageMockRecorder) MarkRecovered() *gomock.Call

MarkRecovered indicates an expected call of MarkRecovered

func (*MockStorageMockRecorder) Open added in v0.1.1 

func (mr *MockStorageMockRecorder) Open() *gomock.Call

Open indicates an expected call of Open

func (*MockStorageMockRecorder) Recovered added in v0.1.1 

func (mr *MockStorageMockRecorder) Recovered() *gomock.Call

Recovered indicates an expected call of Recovered

func (*MockStorageMockRecorder) Set added in v0.1.1 

func (mr *MockStorageMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call

Set indicates an expected call of Set

func (*MockStorageMockRecorder) SetOffset added in v0.1.1 

func (mr *MockStorageMockRecorder) SetOffset(arg0 interface{}) *gomock.Call

SetOffset indicates an expected call of SetOffset

type MockTopicManager 

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

MockTopicManager is a mock of TopicManager interface

func NewMockTopicManager 

func NewMockTopicManager(ctrl *gomock.Controller) *MockTopicManager

NewMockTopicManager creates a new mock instance

func (*MockTopicManager) Close 

func (m *MockTopicManager) Close() error

Close mocks base method

func (*MockTopicManager) EXPECT 

func (m *MockTopicManager) EXPECT() *MockTopicManagerMockRecorder

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

func (*MockTopicManager) EnsureStreamExists 

func (m *MockTopicManager) EnsureStreamExists(arg0 string, arg1 int) error

EnsureStreamExists mocks base method

func (*MockTopicManager) EnsureTableExists 

func (m *MockTopicManager) EnsureTableExists(arg0 string, arg1 int) error

EnsureTableExists mocks base method

func (*MockTopicManager) EnsureTopicExists added in v0.1.1 

func (m *MockTopicManager) EnsureTopicExists(arg0 string, arg1, arg2 int, arg3 map[string]string) error

EnsureTopicExists mocks base method

func (*MockTopicManager) Partitions 

func (m *MockTopicManager) Partitions(arg0 string) ([]int32, error)

Partitions mocks base method

type MockTopicManagerMockRecorder added in v0.1.1 

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

MockTopicManagerMockRecorder is the mock recorder for MockTopicManager

func (*MockTopicManagerMockRecorder) Close added in v0.1.1 

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

Close indicates an expected call of Close

func (*MockTopicManagerMockRecorder) EnsureStreamExists added in v0.1.1 

func (mr *MockTopicManagerMockRecorder) EnsureStreamExists(arg0, arg1 interface{}) *gomock.Call

EnsureStreamExists indicates an expected call of EnsureStreamExists

func (*MockTopicManagerMockRecorder) EnsureTableExists added in v0.1.1 

func (mr *MockTopicManagerMockRecorder) EnsureTableExists(arg0, arg1 interface{}) *gomock.Call

EnsureTableExists indicates an expected call of EnsureTableExists

func (*MockTopicManagerMockRecorder) EnsureTopicExists added in v0.1.1 

func (mr *MockTopicManagerMockRecorder) EnsureTopicExists(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

EnsureTopicExists indicates an expected call of EnsureTopicExists

func (*MockTopicManagerMockRecorder) Partitions added in v0.1.1 

func (mr *MockTopicManagerMockRecorder) Partitions(arg0 interface{}) *gomock.Call

Partitions indicates an expected call of Partitions

type MockkafkaProxy 

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

MockkafkaProxy is a mock of kafkaProxy interface

func NewMockkafkaProxy 

func NewMockkafkaProxy(ctrl *gomock.Controller) *MockkafkaProxy

NewMockkafkaProxy creates a new mock instance

func (*MockkafkaProxy) Add 

func (m *MockkafkaProxy) Add(arg0 string, arg1 int64) error

Add mocks base method

func (*MockkafkaProxy) AddGroup 

func (m *MockkafkaProxy) AddGroup()

AddGroup mocks base method

func (*MockkafkaProxy) EXPECT 

func (m *MockkafkaProxy) EXPECT() *MockkafkaProxyMockRecorder

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

func (*MockkafkaProxy) Remove 

func (m *MockkafkaProxy) Remove(arg0 string) error

Remove mocks base method

func (*MockkafkaProxy) Stop 

func (m *MockkafkaProxy) Stop()

Stop mocks base method

type MockkafkaProxyMockRecorder added in v0.1.1 

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

MockkafkaProxyMockRecorder is the mock recorder for MockkafkaProxy

func (*MockkafkaProxyMockRecorder) Add added in v0.1.1 

func (mr *MockkafkaProxyMockRecorder) Add(arg0, arg1 interface{}) *gomock.Call

Add indicates an expected call of Add

func (*MockkafkaProxyMockRecorder) AddGroup added in v0.1.1 

func (mr *MockkafkaProxyMockRecorder) AddGroup() *gomock.Call

AddGroup indicates an expected call of AddGroup

func (*MockkafkaProxyMockRecorder) Remove added in v0.1.1 

func (mr *MockkafkaProxyMockRecorder) Remove(arg0 interface{}) *gomock.Call

Remove indicates an expected call of Remove

func (*MockkafkaProxyMockRecorder) Stop added in v0.1.1 

func (mr *MockkafkaProxyMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

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.