coordinator

type MasterCfg struct {
	// basic
	Ctx  context.Context
	TTL  int64 // masterController elect keepalive ttl
	Node models.Node
	Repo state.Repository

	// factory
	DiscoveryFactory discovery.Factory
	RepoFactory      state.RepositoryFactory
}

type MasterController interface {
	// Start starts master do election master, if success build master context,
	// starts state machine do cluster coordinate such metadata, cluster state etc.
	Start() error
	// IsMaster returns current node if is master
	IsMaster() bool
	// GetMaster returns the current master info
	GetMaster() *models.Master
	// Stop stops master if current node is master, cleanup master context and stops state machine
	Stop()
	// FlushDatabase submits the coordinator task for flushing memory database by cluster and database name
	FlushDatabase(cluster string, databaseName string) error
	// GetStateManager returns master's state manager.
	GetStateManager() masterpkg.StateManager
	// WatchMasterElected adds callback after master finished election.
	WatchMasterElected(fn func(master *models.Master))
}