Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockICluster ¶
type MockICluster struct {
// contains filtered or unexported fields
}
MockICluster is a mock of ICluster interface.
func NewMockICluster ¶
func NewMockICluster(ctrl *gomock.Controller) *MockICluster
NewMockICluster creates a new mock instance.
func (*MockICluster) EXPECT ¶
func (m *MockICluster) EXPECT() *MockIClusterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockICluster) Run ¶
func (m *MockICluster) Run(ctx context.Context, stopNotifyCh chan<- struct{})
Run mocks base method.
type MockIClusterMockRecorder ¶
type MockIClusterMockRecorder struct {
// contains filtered or unexported fields
}
MockIClusterMockRecorder is the mock recorder for MockICluster.
func (*MockIClusterMockRecorder) Run ¶
func (mr *MockIClusterMockRecorder) Run(ctx, stopNotifyCh interface{}) *gomock.Call
Run indicates an expected call of Run.
type MockIHub ¶
type MockIHub struct {
// contains filtered or unexported fields
}
MockIHub is a mock of IHub interface.
func NewMockIHub ¶
func NewMockIHub(ctrl *gomock.Controller) *MockIHub
NewMockIHub creates a new mock instance.
func (*MockIHub) EXPECT ¶
func (m *MockIHub) EXPECT() *MockIHubMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockIHubMockRecorder ¶
type MockIHubMockRecorder struct {
// contains filtered or unexported fields
}
MockIHubMockRecorder is the mock recorder for MockIHub.
func (*MockIHubMockRecorder) Kickoff ¶
func (mr *MockIHubMockRecorder) Kickoff(arg0 interface{}) *gomock.Call
Kickoff indicates an expected call of Kickoff.
func (*MockIHubMockRecorder) Offline ¶
func (mr *MockIHubMockRecorder) Offline() *gomock.Call
Offline indicates an expected call of Offline.
func (*MockIHubMockRecorder) Online ¶
func (mr *MockIHubMockRecorder) Online() *gomock.Call
Online indicates an expected call of Online.
func (*MockIHubMockRecorder) Run ¶
func (mr *MockIHubMockRecorder) Run(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
Run indicates an expected call of Run.
type MockIKafkaReader ¶
type MockIKafkaReader struct {
// contains filtered or unexported fields
}
MockIKafkaReader is a mock of IKafkaReader interface.
func NewMockIKafkaReader ¶
func NewMockIKafkaReader(ctrl *gomock.Controller) *MockIKafkaReader
NewMockIKafkaReader creates a new mock instance.
func (*MockIKafkaReader) CommitMessages ¶
CommitMessages mocks base method.
func (*MockIKafkaReader) EXPECT ¶
func (m *MockIKafkaReader) EXPECT() *MockIKafkaReaderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIKafkaReader) FetchMessage ¶
FetchMessage mocks base method.
type MockIKafkaReaderMockRecorder ¶
type MockIKafkaReaderMockRecorder struct {
// contains filtered or unexported fields
}
MockIKafkaReaderMockRecorder is the mock recorder for MockIKafkaReader.
func (*MockIKafkaReaderMockRecorder) Close ¶
func (mr *MockIKafkaReaderMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockIKafkaReaderMockRecorder) CommitMessages ¶
func (mr *MockIKafkaReaderMockRecorder) CommitMessages(arg0 interface{}, arg1 ...interface{}) *gomock.Call
CommitMessages indicates an expected call of CommitMessages.
func (*MockIKafkaReaderMockRecorder) FetchMessage ¶
func (mr *MockIKafkaReaderMockRecorder) FetchMessage(arg0 interface{}) *gomock.Call
FetchMessage indicates an expected call of FetchMessage.
type MockIKafkaWriter ¶
type MockIKafkaWriter struct {
// contains filtered or unexported fields
}
MockIKafkaWriter is a mock of IKafkaWriter interface.
func NewMockIKafkaWriter ¶
func NewMockIKafkaWriter(ctrl *gomock.Controller) *MockIKafkaWriter
NewMockIKafkaWriter creates a new mock instance.
func (*MockIKafkaWriter) EXPECT ¶
func (m *MockIKafkaWriter) EXPECT() *MockIKafkaWriterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIKafkaWriter) WriteMessages ¶
WriteMessages mocks base method.
type MockIKafkaWriterMockRecorder ¶
type MockIKafkaWriterMockRecorder struct {
// contains filtered or unexported fields
}
MockIKafkaWriterMockRecorder is the mock recorder for MockIKafkaWriter.
func (*MockIKafkaWriterMockRecorder) Close ¶
func (mr *MockIKafkaWriterMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockIKafkaWriterMockRecorder) WriteMessages ¶
func (mr *MockIKafkaWriterMockRecorder) WriteMessages(arg0 interface{}, arg1 ...interface{}) *gomock.Call
WriteMessages indicates an expected call of WriteMessages.
Source Files