failover

Documentation

Overview

Package failover is a generated GoMock package.

Package failover is a generated GoMock package.

Index

• type Coordinator
  • func NewCoordinator(metadataMgr persistence.MetadataManager, historyClient history.Client, ...) Coordinator
• type MarkerNotifier
  • func NewMarkerNotifier(shard shard.Context, config *config.Config, failoverCoordinator Coordinator) MarkerNotifier
• type MockCoordinator
  • func NewMockCoordinator(ctrl *gomock.Controller) *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
  • func NewMockMarkerNotifier(ctrl *gomock.Controller) *MockMarkerNotifier
  • func (m *MockMarkerNotifier) EXPECT() *MockMarkerNotifierMockRecorder
  • func (m *MockMarkerNotifier) Start()
  • func (m *MockMarkerNotifier) Stop()
• type MockMarkerNotifierMockRecorder
  • func (mr *MockMarkerNotifierMockRecorder) Start() *gomock.Call
  • func (mr *MockMarkerNotifierMockRecorder) Stop() *gomock.Call

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

type MarkerNotifier interface {
	common.Daemon
}

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

func (*MockCoordinator) Start

func (m *MockCoordinator) Start()

Start mocks base method

func (*MockCoordinator) Stop

func (m *MockCoordinator) Stop()

Stop 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

func (*MockMarkerNotifier) Start

func (m *MockMarkerNotifier) Start()

Start mocks base method

func (*MockMarkerNotifier) Stop

func (m *MockMarkerNotifier) Stop()

Stop mocks base method

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