Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockConsumer
- type MockConsumerIterator
- type MockConsumerIteratorMockRecorder
- type MockConsumerMockRecorder
- type MockCursorStorage
- type MockCursorStorageMockRecorder
- type MockEventStorage
- type MockEventStorageMockRecorder
- type MockEventsIterator
- type MockEventsIteratorMockRecorder
- type MockGoethe_ConsumeServer
- func (m *MockGoethe_ConsumeServer) Context() context.Context
- func (m *MockGoethe_ConsumeServer) EXPECT() *MockGoethe_ConsumeServerMockRecorder
- func (m *MockGoethe_ConsumeServer) Recv() (*spec.Cursor, error)
- func (m *MockGoethe_ConsumeServer) RecvMsg(arg0 interface{}) error
- func (m *MockGoethe_ConsumeServer) Send(arg0 *spec.Cursor) error
- func (m *MockGoethe_ConsumeServer) SendHeader(arg0 metadata.MD) error
- func (m *MockGoethe_ConsumeServer) SendMsg(arg0 interface{}) error
- func (m *MockGoethe_ConsumeServer) SetHeader(arg0 metadata.MD) error
- func (m *MockGoethe_ConsumeServer) SetTrailer(arg0 metadata.MD)
- type MockGoethe_ConsumeServerMockRecorder
- func (mr *MockGoethe_ConsumeServerMockRecorder) Context() *gomock.Call
- func (mr *MockGoethe_ConsumeServerMockRecorder) Recv() *gomock.Call
- func (mr *MockGoethe_ConsumeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ConsumeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ConsumeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ConsumeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ConsumeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ConsumeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockGoethe_ProduceServer
- func (m *MockGoethe_ProduceServer) Context() context.Context
- func (m *MockGoethe_ProduceServer) EXPECT() *MockGoethe_ProduceServerMockRecorder
- func (m *MockGoethe_ProduceServer) Recv() (*spec.Event, error)
- func (m *MockGoethe_ProduceServer) RecvMsg(arg0 interface{}) error
- func (m *MockGoethe_ProduceServer) Send(arg0 *spec.Event) error
- func (m *MockGoethe_ProduceServer) SendHeader(arg0 metadata.MD) error
- func (m *MockGoethe_ProduceServer) SendMsg(arg0 interface{}) error
- func (m *MockGoethe_ProduceServer) SetHeader(arg0 metadata.MD) error
- func (m *MockGoethe_ProduceServer) SetTrailer(arg0 metadata.MD)
- type MockGoethe_ProduceServerMockRecorder
- func (mr *MockGoethe_ProduceServerMockRecorder) Context() *gomock.Call
- func (mr *MockGoethe_ProduceServerMockRecorder) Recv() *gomock.Call
- func (mr *MockGoethe_ProduceServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ProduceServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ProduceServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ProduceServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ProduceServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGoethe_ProduceServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockIDGenerator
- type MockIDGeneratorMockRecorder
- type MockIterator
- func (m *MockIterator) EXPECT() *MockIteratorMockRecorder
- func (m *MockIterator) Error() error
- func (m *MockIterator) First() bool
- func (m *MockIterator) Key() []byte
- func (m *MockIterator) Last() bool
- func (m *MockIterator) Next() bool
- func (m *MockIterator) Prev() bool
- func (m *MockIterator) Release()
- func (m *MockIterator) Seek(arg0 []byte) bool
- func (m *MockIterator) SetReleaser(arg0 util.Releaser)
- func (m *MockIterator) Valid() bool
- func (m *MockIterator) Value() []byte
- type MockIteratorMockRecorder
- func (mr *MockIteratorMockRecorder) Error() *gomock.Call
- func (mr *MockIteratorMockRecorder) First() *gomock.Call
- func (mr *MockIteratorMockRecorder) Key() *gomock.Call
- func (mr *MockIteratorMockRecorder) Last() *gomock.Call
- func (mr *MockIteratorMockRecorder) Next() *gomock.Call
- func (mr *MockIteratorMockRecorder) Prev() *gomock.Call
- func (mr *MockIteratorMockRecorder) Release() *gomock.Call
- func (mr *MockIteratorMockRecorder) Seek(arg0 interface{}) *gomock.Call
- func (mr *MockIteratorMockRecorder) SetReleaser(arg0 interface{}) *gomock.Call
- func (mr *MockIteratorMockRecorder) Valid() *gomock.Call
- func (mr *MockIteratorMockRecorder) Value() *gomock.Call
- type MockLevelDB
- func (m *MockLevelDB) Close() error
- func (m *MockLevelDB) EXPECT() *MockLevelDBMockRecorder
- func (m *MockLevelDB) Get(arg0 []byte, arg1 *opt.ReadOptions) ([]byte, error)
- func (m *MockLevelDB) NewIterator(arg0 *util.Range, arg1 *opt.ReadOptions) iterator.Iterator
- func (m *MockLevelDB) Write(arg0 *leveldb.Batch, arg1 *opt.WriteOptions) error
- type MockLevelDBMockRecorder
- type MockProducer
- type MockProducerMockRecorder
- type MockStorageMetrics
- type MockStorageMetricsMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) Commit ¶
func (m *MockConsumer) Commit(arg0 *spec.Cursor) 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) GetIterator ¶
func (m *MockConsumer) GetIterator(arg0 *spec.Cursor) (api.ConsumerIterator, error)
GetIterator mocks base method
type MockConsumerIterator ¶
type MockConsumerIterator struct {
// contains filtered or unexported fields
}
MockConsumerIterator is a mock of ConsumerIterator interface
func NewMockConsumerIterator ¶
func NewMockConsumerIterator(ctrl *gomock.Controller) *MockConsumerIterator
NewMockConsumerIterator creates a new mock instance
func (*MockConsumerIterator) Close ¶
func (m *MockConsumerIterator) Close() error
Close mocks base method
func (*MockConsumerIterator) EXPECT ¶
func (m *MockConsumerIterator) EXPECT() *MockConsumerIteratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockConsumerIterator) Next ¶
func (m *MockConsumerIterator) Next() bool
Next mocks base method
type MockConsumerIteratorMockRecorder ¶
type MockConsumerIteratorMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerIteratorMockRecorder is the mock recorder for MockConsumerIterator
func (*MockConsumerIteratorMockRecorder) Close ¶
func (mr *MockConsumerIteratorMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockConsumerIteratorMockRecorder) Next ¶
func (mr *MockConsumerIteratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockConsumerIteratorMockRecorder) Value ¶
func (mr *MockConsumerIteratorMockRecorder) Value() *gomock.Call
Value indicates an expected call of Value
type MockConsumerMockRecorder ¶
type MockConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerMockRecorder is the mock recorder for MockConsumer
func (*MockConsumerMockRecorder) Commit ¶
func (mr *MockConsumerMockRecorder) Commit(arg0 interface{}) *gomock.Call
Commit indicates an expected call of Commit
func (*MockConsumerMockRecorder) GetIterator ¶
func (mr *MockConsumerMockRecorder) GetIterator(arg0 interface{}) *gomock.Call
GetIterator indicates an expected call of GetIterator
type MockCursorStorage ¶
type MockCursorStorage struct {
// contains filtered or unexported fields
}
MockCursorStorage is a mock of CursorStorage interface
func NewMockCursorStorage ¶
func NewMockCursorStorage(ctrl *gomock.Controller) *MockCursorStorage
NewMockCursorStorage creates a new mock instance
func (*MockCursorStorage) EXPECT ¶
func (m *MockCursorStorage) EXPECT() *MockCursorStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockCursorStorage) GetCursorFor ¶
GetCursorFor mocks base method
func (*MockCursorStorage) SaveCursor ¶
func (m *MockCursorStorage) SaveCursor(arg0 *spec.Cursor) error
SaveCursor mocks base method
type MockCursorStorageMockRecorder ¶
type MockCursorStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockCursorStorageMockRecorder is the mock recorder for MockCursorStorage
func (*MockCursorStorageMockRecorder) GetCursorFor ¶
func (mr *MockCursorStorageMockRecorder) GetCursorFor(arg0 interface{}) *gomock.Call
GetCursorFor indicates an expected call of GetCursorFor
func (*MockCursorStorageMockRecorder) SaveCursor ¶
func (mr *MockCursorStorageMockRecorder) SaveCursor(arg0 interface{}) *gomock.Call
SaveCursor indicates an expected call of SaveCursor
type MockEventStorage ¶
type MockEventStorage struct {
// contains filtered or unexported fields
}
MockEventStorage is a mock of EventStorage interface
func NewMockEventStorage ¶
func NewMockEventStorage(ctrl *gomock.Controller) *MockEventStorage
NewMockEventStorage creates a new mock instance
func (*MockEventStorage) EXPECT ¶
func (m *MockEventStorage) EXPECT() *MockEventStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockEventStorage) GetIterator ¶
func (m *MockEventStorage) GetIterator(arg0 *spec.Event) (storage.EventsIterator, error)
GetIterator mocks base method
type MockEventStorageMockRecorder ¶
type MockEventStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockEventStorageMockRecorder is the mock recorder for MockEventStorage
func (*MockEventStorageMockRecorder) Append ¶
func (mr *MockEventStorageMockRecorder) Append(arg0 interface{}) *gomock.Call
Append indicates an expected call of Append
func (*MockEventStorageMockRecorder) GetIterator ¶
func (mr *MockEventStorageMockRecorder) GetIterator(arg0 interface{}) *gomock.Call
GetIterator indicates an expected call of GetIterator
type MockEventsIterator ¶
type MockEventsIterator struct {
// contains filtered or unexported fields
}
MockEventsIterator is a mock of EventsIterator interface
func NewMockEventsIterator ¶
func NewMockEventsIterator(ctrl *gomock.Controller) *MockEventsIterator
NewMockEventsIterator creates a new mock instance
func (*MockEventsIterator) Close ¶
func (m *MockEventsIterator) Close() error
Close mocks base method
func (*MockEventsIterator) EXPECT ¶
func (m *MockEventsIterator) EXPECT() *MockEventsIteratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockEventsIteratorMockRecorder ¶
type MockEventsIteratorMockRecorder struct {
// contains filtered or unexported fields
}
MockEventsIteratorMockRecorder is the mock recorder for MockEventsIterator
func (*MockEventsIteratorMockRecorder) Close ¶
func (mr *MockEventsIteratorMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockEventsIteratorMockRecorder) Next ¶
func (mr *MockEventsIteratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockEventsIteratorMockRecorder) Value ¶
func (mr *MockEventsIteratorMockRecorder) Value() *gomock.Call
Value indicates an expected call of Value
type MockGoethe_ConsumeServer ¶
type MockGoethe_ConsumeServer struct {
// contains filtered or unexported fields
}
MockGoethe_ConsumeServer is a mock of Goethe_ConsumeServer interface
func NewMockGoethe_ConsumeServer ¶
func NewMockGoethe_ConsumeServer(ctrl *gomock.Controller) *MockGoethe_ConsumeServer
NewMockGoethe_ConsumeServer creates a new mock instance
func (*MockGoethe_ConsumeServer) Context ¶
func (m *MockGoethe_ConsumeServer) Context() context.Context
Context mocks base method
func (*MockGoethe_ConsumeServer) EXPECT ¶
func (m *MockGoethe_ConsumeServer) EXPECT() *MockGoethe_ConsumeServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockGoethe_ConsumeServer) Recv ¶
func (m *MockGoethe_ConsumeServer) Recv() (*spec.Cursor, error)
Recv mocks base method
func (*MockGoethe_ConsumeServer) RecvMsg ¶
func (m *MockGoethe_ConsumeServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockGoethe_ConsumeServer) Send ¶
func (m *MockGoethe_ConsumeServer) Send(arg0 *spec.Cursor) error
Send mocks base method
func (*MockGoethe_ConsumeServer) SendHeader ¶
func (m *MockGoethe_ConsumeServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method
func (*MockGoethe_ConsumeServer) SendMsg ¶
func (m *MockGoethe_ConsumeServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockGoethe_ConsumeServer) SetHeader ¶
func (m *MockGoethe_ConsumeServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method
func (*MockGoethe_ConsumeServer) SetTrailer ¶
func (m *MockGoethe_ConsumeServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method
type MockGoethe_ConsumeServerMockRecorder ¶
type MockGoethe_ConsumeServerMockRecorder struct {
// contains filtered or unexported fields
}
MockGoethe_ConsumeServerMockRecorder is the mock recorder for MockGoethe_ConsumeServer
func (*MockGoethe_ConsumeServerMockRecorder) Context ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockGoethe_ConsumeServerMockRecorder) Recv ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockGoethe_ConsumeServerMockRecorder) RecvMsg ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockGoethe_ConsumeServerMockRecorder) Send ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockGoethe_ConsumeServerMockRecorder) SendHeader ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader
func (*MockGoethe_ConsumeServerMockRecorder) SendMsg ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockGoethe_ConsumeServerMockRecorder) SetHeader ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader
func (*MockGoethe_ConsumeServerMockRecorder) SetTrailer ¶
func (mr *MockGoethe_ConsumeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer
type MockGoethe_ProduceServer ¶
type MockGoethe_ProduceServer struct {
// contains filtered or unexported fields
}
MockGoethe_ProduceServer is a mock of Goethe_ProduceServer interface
func NewMockGoethe_ProduceServer ¶
func NewMockGoethe_ProduceServer(ctrl *gomock.Controller) *MockGoethe_ProduceServer
NewMockGoethe_ProduceServer creates a new mock instance
func (*MockGoethe_ProduceServer) Context ¶
func (m *MockGoethe_ProduceServer) Context() context.Context
Context mocks base method
func (*MockGoethe_ProduceServer) EXPECT ¶
func (m *MockGoethe_ProduceServer) EXPECT() *MockGoethe_ProduceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockGoethe_ProduceServer) Recv ¶
func (m *MockGoethe_ProduceServer) Recv() (*spec.Event, error)
Recv mocks base method
func (*MockGoethe_ProduceServer) RecvMsg ¶
func (m *MockGoethe_ProduceServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockGoethe_ProduceServer) Send ¶
func (m *MockGoethe_ProduceServer) Send(arg0 *spec.Event) error
Send mocks base method
func (*MockGoethe_ProduceServer) SendHeader ¶
func (m *MockGoethe_ProduceServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method
func (*MockGoethe_ProduceServer) SendMsg ¶
func (m *MockGoethe_ProduceServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockGoethe_ProduceServer) SetHeader ¶
func (m *MockGoethe_ProduceServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method
func (*MockGoethe_ProduceServer) SetTrailer ¶
func (m *MockGoethe_ProduceServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method
type MockGoethe_ProduceServerMockRecorder ¶
type MockGoethe_ProduceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockGoethe_ProduceServerMockRecorder is the mock recorder for MockGoethe_ProduceServer
func (*MockGoethe_ProduceServerMockRecorder) Context ¶
func (mr *MockGoethe_ProduceServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockGoethe_ProduceServerMockRecorder) Recv ¶
func (mr *MockGoethe_ProduceServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockGoethe_ProduceServerMockRecorder) RecvMsg ¶
func (mr *MockGoethe_ProduceServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockGoethe_ProduceServerMockRecorder) Send ¶
func (mr *MockGoethe_ProduceServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockGoethe_ProduceServerMockRecorder) SendHeader ¶
func (mr *MockGoethe_ProduceServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader
func (*MockGoethe_ProduceServerMockRecorder) SendMsg ¶
func (mr *MockGoethe_ProduceServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockGoethe_ProduceServerMockRecorder) SetHeader ¶
func (mr *MockGoethe_ProduceServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader
func (*MockGoethe_ProduceServerMockRecorder) SetTrailer ¶
func (mr *MockGoethe_ProduceServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer
type MockIDGenerator ¶
type MockIDGenerator struct {
// contains filtered or unexported fields
}
MockIDGenerator is a mock of IDGenerator interface
func NewMockIDGenerator ¶
func NewMockIDGenerator(ctrl *gomock.Controller) *MockIDGenerator
NewMockIDGenerator creates a new mock instance
func (*MockIDGenerator) EXPECT ¶
func (m *MockIDGenerator) EXPECT() *MockIDGeneratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockIDGeneratorMockRecorder ¶
type MockIDGeneratorMockRecorder struct {
// contains filtered or unexported fields
}
MockIDGeneratorMockRecorder is the mock recorder for MockIDGenerator
func (*MockIDGeneratorMockRecorder) Next ¶
func (mr *MockIDGeneratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
type MockIterator ¶
type MockIterator struct {
// contains filtered or unexported fields
}
MockIterator is a mock of Iterator interface
func NewMockIterator ¶
func NewMockIterator(ctrl *gomock.Controller) *MockIterator
NewMockIterator creates a new mock instance
func (*MockIterator) EXPECT ¶
func (m *MockIterator) EXPECT() *MockIteratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockIterator) SetReleaser ¶
func (m *MockIterator) SetReleaser(arg0 util.Releaser)
SetReleaser mocks base method
type MockIteratorMockRecorder ¶
type MockIteratorMockRecorder struct {
// contains filtered or unexported fields
}
MockIteratorMockRecorder is the mock recorder for MockIterator
func (*MockIteratorMockRecorder) Error ¶
func (mr *MockIteratorMockRecorder) Error() *gomock.Call
Error indicates an expected call of Error
func (*MockIteratorMockRecorder) First ¶
func (mr *MockIteratorMockRecorder) First() *gomock.Call
First indicates an expected call of First
func (*MockIteratorMockRecorder) Key ¶
func (mr *MockIteratorMockRecorder) Key() *gomock.Call
Key indicates an expected call of Key
func (*MockIteratorMockRecorder) Last ¶
func (mr *MockIteratorMockRecorder) Last() *gomock.Call
Last indicates an expected call of Last
func (*MockIteratorMockRecorder) Next ¶
func (mr *MockIteratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockIteratorMockRecorder) Prev ¶
func (mr *MockIteratorMockRecorder) Prev() *gomock.Call
Prev indicates an expected call of Prev
func (*MockIteratorMockRecorder) Release ¶
func (mr *MockIteratorMockRecorder) Release() *gomock.Call
Release indicates an expected call of Release
func (*MockIteratorMockRecorder) Seek ¶
func (mr *MockIteratorMockRecorder) Seek(arg0 interface{}) *gomock.Call
Seek indicates an expected call of Seek
func (*MockIteratorMockRecorder) SetReleaser ¶
func (mr *MockIteratorMockRecorder) SetReleaser(arg0 interface{}) *gomock.Call
SetReleaser indicates an expected call of SetReleaser
func (*MockIteratorMockRecorder) Valid ¶
func (mr *MockIteratorMockRecorder) Valid() *gomock.Call
Valid indicates an expected call of Valid
func (*MockIteratorMockRecorder) Value ¶
func (mr *MockIteratorMockRecorder) Value() *gomock.Call
Value indicates an expected call of Value
type MockLevelDB ¶
type MockLevelDB struct {
// contains filtered or unexported fields
}
MockLevelDB is a mock of LevelDB interface
func NewMockLevelDB ¶
func NewMockLevelDB(ctrl *gomock.Controller) *MockLevelDB
NewMockLevelDB creates a new mock instance
func (*MockLevelDB) EXPECT ¶
func (m *MockLevelDB) EXPECT() *MockLevelDBMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockLevelDB) Get ¶
func (m *MockLevelDB) Get(arg0 []byte, arg1 *opt.ReadOptions) ([]byte, error)
Get mocks base method
func (*MockLevelDB) NewIterator ¶
func (m *MockLevelDB) NewIterator(arg0 *util.Range, arg1 *opt.ReadOptions) iterator.Iterator
NewIterator mocks base method
func (*MockLevelDB) Write ¶
func (m *MockLevelDB) Write(arg0 *leveldb.Batch, arg1 *opt.WriteOptions) error
Write mocks base method
type MockLevelDBMockRecorder ¶
type MockLevelDBMockRecorder struct {
// contains filtered or unexported fields
}
MockLevelDBMockRecorder is the mock recorder for MockLevelDB
func (*MockLevelDBMockRecorder) Close ¶
func (mr *MockLevelDBMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockLevelDBMockRecorder) Get ¶
func (mr *MockLevelDBMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockLevelDBMockRecorder) NewIterator ¶
func (mr *MockLevelDBMockRecorder) NewIterator(arg0, arg1 interface{}) *gomock.Call
NewIterator indicates an expected call of NewIterator
func (*MockLevelDBMockRecorder) Write ¶
func (mr *MockLevelDBMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call
Write indicates an expected call of Write
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) EXPECT ¶
func (m *MockProducer) EXPECT() *MockProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockProducerMockRecorder ¶
type MockProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockProducerMockRecorder is the mock recorder for MockProducer
func (*MockProducerMockRecorder) Produce ¶
func (mr *MockProducerMockRecorder) Produce(arg0 interface{}) *gomock.Call
Produce indicates an expected call of Produce
type MockStorageMetrics ¶
type MockStorageMetrics struct {
// contains filtered or unexported fields
}
MockStorageMetrics is a mock of Metrics interface
func NewMockStorageMetrics ¶
func NewMockStorageMetrics(ctrl *gomock.Controller) *MockStorageMetrics
NewMockStorageMetrics creates a new mock instance
func (*MockStorageMetrics) EXPECT ¶
func (m *MockStorageMetrics) EXPECT() *MockStorageMetricsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockStorageMetrics) MeasureGetIterator ¶
func (m *MockStorageMetrics) MeasureGetIterator(arg0 func() (storage.EventsIterator, error)) (storage.EventsIterator, error)
MeasureGetIterator mocks base method
func (*MockStorageMetrics) MeasurePersistEvent ¶
func (m *MockStorageMetrics) MeasurePersistEvent(arg0 func() (*spec.Event, error)) (*spec.Event, error)
MeasurePersistEvent mocks base method
type MockStorageMetricsMockRecorder ¶
type MockStorageMetricsMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageMetricsMockRecorder is the mock recorder for MockStorageMetrics
func (*MockStorageMetricsMockRecorder) MeasureGetIterator ¶
func (mr *MockStorageMetricsMockRecorder) MeasureGetIterator(arg0 interface{}) *gomock.Call
MeasureGetIterator indicates an expected call of MeasureGetIterator
func (*MockStorageMetricsMockRecorder) MeasurePersistEvent ¶
func (mr *MockStorageMetricsMockRecorder) MeasurePersistEvent(arg0 interface{}) *gomock.Call
MeasurePersistEvent indicates an expected call of MeasurePersistEvent