Documentation
¶
Overview ¶
Package mock_protocol is a generated GoMock package.
Index ¶
- type MockMessageRouter
- type MockMessageRouterMockRecorder
- type MockMessageTracer
- type MockMessageTracerMockRecorder
- type MockMessageWrapper
- func (m *MockMessageWrapper) EXPECT() *MockMessageWrapperMockRecorder
- func (m *MockMessageWrapper) GetDatabase() string
- func (m *MockMessageWrapper) GetMqMsgType() protocol.JobMsgType
- func (m *MockMessageWrapper) GetPartitionKeyFromPayload(arg0 []string) string
- func (m *MockMessageWrapper) GetPayloadKafkaEncoder() (sarama.Encoder, error)
- func (m *MockMessageWrapper) GetTable() string
- type MockMessageWrapperMockRecorder
- func (mr *MockMessageWrapperMockRecorder) GetDatabase() *gomock.Call
- func (mr *MockMessageWrapperMockRecorder) GetMqMsgType() *gomock.Call
- func (mr *MockMessageWrapperMockRecorder) GetPartitionKeyFromPayload(arg0 interface{}) *gomock.Call
- func (mr *MockMessageWrapperMockRecorder) GetPayloadKafkaEncoder() *gomock.Call
- func (mr *MockMessageWrapperMockRecorder) GetTable() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockMessageRouter ¶
type MockMessageRouter struct {
// contains filtered or unexported fields
}
MockMessageRouter is a mock of MessageRouter interface
func NewMockMessageRouter ¶
func NewMockMessageRouter(ctrl *gomock.Controller) *MockMessageRouter
NewMockMessageRouter creates a new mock instance
func (*MockMessageRouter) EXPECT ¶
func (m *MockMessageRouter) EXPECT() *MockMessageRouterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMessageRouter) GetPartitions ¶
func (m *MockMessageRouter) GetPartitions() []int32
GetPartitions mocks base method
func (*MockMessageRouter) GetTopic ¶
func (m *MockMessageRouter) GetTopic() string
GetTopic mocks base method
type MockMessageRouterMockRecorder ¶
type MockMessageRouterMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageRouterMockRecorder is the mock recorder for MockMessageRouter
func (*MockMessageRouterMockRecorder) GetPartitions ¶
func (mr *MockMessageRouterMockRecorder) GetPartitions() *gomock.Call
GetPartitions indicates an expected call of GetPartitions
func (*MockMessageRouterMockRecorder) GetTopic ¶
func (mr *MockMessageRouterMockRecorder) GetTopic() *gomock.Call
GetTopic indicates an expected call of GetTopic
type MockMessageTracer ¶
type MockMessageTracer struct {
// contains filtered or unexported fields
}
MockMessageTracer is a mock of MessageTracer interface
func NewMockMessageTracer ¶
func NewMockMessageTracer(ctrl *gomock.Controller) *MockMessageTracer
NewMockMessageTracer creates a new mock instance
func (*MockMessageTracer) AddMetrics ¶
func (m *MockMessageTracer) AddMetrics()
AddMetrics mocks base method
func (*MockMessageTracer) AddTimestamp ¶
func (m *MockMessageTracer) AddTimestamp(arg0 protocol.MsgTimestamp)
AddTimestamp mocks base method
func (*MockMessageTracer) EXPECT ¶
func (m *MockMessageTracer) EXPECT() *MockMessageTracerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMessageTracer) MetricsString ¶
func (m *MockMessageTracer) MetricsString() string
MetricsString mocks base method
type MockMessageTracerMockRecorder ¶
type MockMessageTracerMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageTracerMockRecorder is the mock recorder for MockMessageTracer
func (*MockMessageTracerMockRecorder) AddMetrics ¶
func (mr *MockMessageTracerMockRecorder) AddMetrics() *gomock.Call
AddMetrics indicates an expected call of AddMetrics
func (*MockMessageTracerMockRecorder) AddTimestamp ¶
func (mr *MockMessageTracerMockRecorder) AddTimestamp(arg0 interface{}) *gomock.Call
AddTimestamp indicates an expected call of AddTimestamp
func (*MockMessageTracerMockRecorder) MetricsString ¶
func (mr *MockMessageTracerMockRecorder) MetricsString() *gomock.Call
MetricsString indicates an expected call of MetricsString
type MockMessageWrapper ¶
type MockMessageWrapper struct {
// contains filtered or unexported fields
}
MockMessageWrapper is a mock of MessageWrapper interface
func NewMockMessageWrapper ¶
func NewMockMessageWrapper(ctrl *gomock.Controller) *MockMessageWrapper
NewMockMessageWrapper creates a new mock instance
func (*MockMessageWrapper) EXPECT ¶
func (m *MockMessageWrapper) EXPECT() *MockMessageWrapperMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMessageWrapper) GetDatabase ¶
func (m *MockMessageWrapper) GetDatabase() string
GetDatabase mocks base method
func (*MockMessageWrapper) GetMqMsgType ¶
func (m *MockMessageWrapper) GetMqMsgType() protocol.JobMsgType
GetMqMsgType mocks base method
func (*MockMessageWrapper) GetPartitionKeyFromPayload ¶
func (m *MockMessageWrapper) GetPartitionKeyFromPayload(arg0 []string) string
GetPartitionKeyFromPayload mocks base method
func (*MockMessageWrapper) GetPayloadKafkaEncoder ¶
func (m *MockMessageWrapper) GetPayloadKafkaEncoder() (sarama.Encoder, error)
GetPayloadKafkaEncoder mocks base method
func (*MockMessageWrapper) GetTable ¶
func (m *MockMessageWrapper) GetTable() string
GetTable mocks base method
type MockMessageWrapperMockRecorder ¶
type MockMessageWrapperMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageWrapperMockRecorder is the mock recorder for MockMessageWrapper
func (*MockMessageWrapperMockRecorder) GetDatabase ¶
func (mr *MockMessageWrapperMockRecorder) GetDatabase() *gomock.Call
GetDatabase indicates an expected call of GetDatabase
func (*MockMessageWrapperMockRecorder) GetMqMsgType ¶
func (mr *MockMessageWrapperMockRecorder) GetMqMsgType() *gomock.Call
GetMqMsgType indicates an expected call of GetMqMsgType
func (*MockMessageWrapperMockRecorder) GetPartitionKeyFromPayload ¶
func (mr *MockMessageWrapperMockRecorder) GetPartitionKeyFromPayload(arg0 interface{}) *gomock.Call
GetPartitionKeyFromPayload indicates an expected call of GetPartitionKeyFromPayload
func (*MockMessageWrapperMockRecorder) GetPayloadKafkaEncoder ¶
func (mr *MockMessageWrapperMockRecorder) GetPayloadKafkaEncoder() *gomock.Call
GetPayloadKafkaEncoder indicates an expected call of GetPayloadKafkaEncoder
func (*MockMessageWrapperMockRecorder) GetTable ¶
func (mr *MockMessageWrapperMockRecorder) GetTable() *gomock.Call
GetTable indicates an expected call of GetTable
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
pkg
|
|
|
kafka_client
Package mock_sarama is a generated GoMock package.
|
Package mock_sarama is a generated GoMock package. |
|
sliding_window
Package mock_sliding_window is a generated GoMock package.
|
Package mock_sliding_window is a generated GoMock package. |
|
worker_pool
Package mock_worker_pool is a generated GoMock package.
|
Package mock_worker_pool is a generated GoMock package. |
|
Package mock_position_store is a generated GoMock package.
|
Package mock_position_store is a generated GoMock package. |
|
Package mock_schema_store is a generated GoMock package.
|
Package mock_schema_store is a generated GoMock package. |
|
Package mock_sql_execution_engine is a generated GoMock package.
|
Package mock_sql_execution_engine is a generated GoMock package. |