replicate

Documentation

Index

• type ModeManager
  • func NewReplicateModeManager(config config.ReplicateModeConfig, storage *core.Storage, idAlloc id.Allocator, ...) (*ModeManager, error)
  • func (m *ModeManager) GetReplicateStatus() *pb.ReplicateStatus
  • func (m *ModeManager) Run(quit chan struct{})

Types

type ModeManager

type ModeManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ModeManager is used to control how raft logs are synchronized between different tikv nodes.

func NewReplicateModeManager

func NewReplicateModeManager(config config.ReplicateModeConfig, storage *core.Storage, idAlloc id.Allocator, stores core.StoreSetInformer) (*ModeManager, error)

NewReplicateModeManager creates the replicate mode manager.

func (*ModeManager) GetReplicateStatus

func (m *ModeManager) GetReplicateStatus() *pb.ReplicateStatus

GetReplicateStatus returns the status to sync with tikv servers.

func (*ModeManager) Run

func (m *ModeManager) Run(quit chan struct{})

Run starts the background job.