replication

Nov 22, 2022

Changes in this version

+ type Config struct

+ ReconcileInterval time.Duration

+ Workers WorkerConfig

+ type Manager struct

+ func NewManager(tm *tables.Manager, nh *dragonboat.NodeHost, conn *grpc.ClientConn, cfg Config) *Manager

+ func (m *Manager) Close()

+ func (m *Manager) Collect(metrics chan<- prometheus.Metric)

+ func (m *Manager) Describe(descs chan<- *prometheus.Desc)

+ func (m *Manager) Start()

+ type WorkerConfig struct

+ LeaseInterval time.Duration

+ LogRPCTimeout time.Duration

+ MaxRecoveryInFlight int64

+ MaxSnapshotRecv uint64

+ PollInterval time.Duration

+ SnapshotRPCTimeout time.Duration