Documentation ¶
Overview ¶
Package failover is a generated GoMock package.
Package failover is a generated GoMock package.
Index ¶
- type Coordinator
- type MarkerNotifier
- type MockCoordinator
- func (m *MockCoordinator) EXPECT() *MockCoordinatorMockRecorder
- func (m *MockCoordinator) NotifyFailoverMarkers(shardID int32, markers []*replicator.FailoverMarkerAttributes)
- func (m *MockCoordinator) ReceiveFailoverMarkers(shardIDs []int32, marker *replicator.FailoverMarkerAttributes)
- func (m *MockCoordinator) Start()
- func (m *MockCoordinator) Stop()
- type MockCoordinatorMockRecorder
- func (mr *MockCoordinatorMockRecorder) NotifyFailoverMarkers(shardID, markers interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) ReceiveFailoverMarkers(shardIDs, marker interface{}) *gomock.Call
- func (mr *MockCoordinatorMockRecorder) Start() *gomock.Call
- func (mr *MockCoordinatorMockRecorder) Stop() *gomock.Call
- type MockMarkerNotifier
- type MockMarkerNotifierMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Coordinator ¶
type Coordinator interface { common.Daemon NotifyFailoverMarkers(shardID int32, markers []*replicator.FailoverMarkerAttributes) ReceiveFailoverMarkers(shardIDs []int32, marker *replicator.FailoverMarkerAttributes) }
Coordinator manages the failover markers on sending and receiving
func NewCoordinator ¶
func NewCoordinator( metadataMgr persistence.MetadataManager, historyClient history.Client, timeSource clock.TimeSource, config *config.Config, metrics metrics.Client, logger log.Logger, ) Coordinator
NewCoordinator initialize a failover coordinator
type MarkerNotifier ¶
MarkerNotifier notifies failover markers to the remote failover coordinator
func NewMarkerNotifier ¶
func NewMarkerNotifier( shard shard.Context, config *config.Config, failoverCoordinator Coordinator, ) MarkerNotifier
NewMarkerNotifier creates a new instance of failover marker notifier
type MockCoordinator ¶
type MockCoordinator struct {
// contains filtered or unexported fields
}
MockCoordinator is a mock of Coordinator interface
func NewMockCoordinator ¶
func NewMockCoordinator(ctrl *gomock.Controller) *MockCoordinator
NewMockCoordinator creates a new mock instance
func (*MockCoordinator) EXPECT ¶
func (m *MockCoordinator) EXPECT() *MockCoordinatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockCoordinator) NotifyFailoverMarkers ¶
func (m *MockCoordinator) NotifyFailoverMarkers(shardID int32, markers []*replicator.FailoverMarkerAttributes)
NotifyFailoverMarkers mocks base method
func (*MockCoordinator) ReceiveFailoverMarkers ¶
func (m *MockCoordinator) ReceiveFailoverMarkers(shardIDs []int32, marker *replicator.FailoverMarkerAttributes)
ReceiveFailoverMarkers mocks base method
type MockCoordinatorMockRecorder ¶
type MockCoordinatorMockRecorder struct {
// contains filtered or unexported fields
}
MockCoordinatorMockRecorder is the mock recorder for MockCoordinator
func (*MockCoordinatorMockRecorder) NotifyFailoverMarkers ¶
func (mr *MockCoordinatorMockRecorder) NotifyFailoverMarkers(shardID, markers interface{}) *gomock.Call
NotifyFailoverMarkers indicates an expected call of NotifyFailoverMarkers
func (*MockCoordinatorMockRecorder) ReceiveFailoverMarkers ¶
func (mr *MockCoordinatorMockRecorder) ReceiveFailoverMarkers(shardIDs, marker interface{}) *gomock.Call
ReceiveFailoverMarkers indicates an expected call of ReceiveFailoverMarkers
func (*MockCoordinatorMockRecorder) Start ¶
func (mr *MockCoordinatorMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start
func (*MockCoordinatorMockRecorder) Stop ¶
func (mr *MockCoordinatorMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop
type MockMarkerNotifier ¶
type MockMarkerNotifier struct {
// contains filtered or unexported fields
}
MockMarkerNotifier is a mock of MarkerNotifier interface
func NewMockMarkerNotifier ¶
func NewMockMarkerNotifier(ctrl *gomock.Controller) *MockMarkerNotifier
NewMockMarkerNotifier creates a new mock instance
func (*MockMarkerNotifier) EXPECT ¶
func (m *MockMarkerNotifier) EXPECT() *MockMarkerNotifierMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockMarkerNotifierMockRecorder ¶
type MockMarkerNotifierMockRecorder struct {
// contains filtered or unexported fields
}
MockMarkerNotifierMockRecorder is the mock recorder for MockMarkerNotifier
func (*MockMarkerNotifierMockRecorder) Start ¶
func (mr *MockMarkerNotifierMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start
func (*MockMarkerNotifierMockRecorder) Stop ¶
func (mr *MockMarkerNotifierMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop