Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterManager ¶
Types ¶
type DBManager ¶
type DBManager interface {
Initialize()
IsRunning() bool
IsCurrentMemberInCluster(*dcs.Cluster) bool
IsCurrentMemberHealthy() bool
IsMemberHealthy(*dcs.Cluster, *dcs.Member) bool
IsClusterHealthy(context.Context, *dcs.Cluster) bool
IsClusterInitialized(context.Context, *dcs.Cluster) (bool, error)
IsLeader(context.Context, *dcs.Cluster) (bool, error)
IsLeaderMember(context.Context, *dcs.Cluster, *dcs.Member) (bool, error)
IsDBStartupReady() bool
Recover()
AddCurrentMemberToCluster(*dcs.Cluster) error
DeleteMemberFromCluster(*dcs.Cluster, string) error
Premote() error
Demote() error
Follow(*dcs.Cluster) error
GetHealthiestMember(*dcs.Cluster, string) *dcs.Member
// IsHealthiestMember(*dcs.Cluster) bool
HasOtherHealthyLeader(*dcs.Cluster) *dcs.Member
HasOtherHealthyMembers(*dcs.Cluster, string) []*dcs.Member
GetCurrentMemberName() string
GetMemberAddrs(*dcs.Cluster) []string
GetLogger() logger.Logger
}
func GetManager ¶
type DBManagerBase ¶
type DBManagerBase struct {
CurrentMemberName string
ClusterCompName string
Namespace string
DataDir string
Logger logger.Logger
DBStartupReady bool
}
func (*DBManagerBase) GetCurrentMemberName ¶
func (mgr *DBManagerBase) GetCurrentMemberName() string
func (*DBManagerBase) GetLogger ¶
func (mgr *DBManagerBase) GetLogger() logger.Logger
func (*DBManagerBase) IsDBStartupReady ¶
func (mgr *DBManagerBase) IsDBStartupReady() bool
Click to show internal directories.
Click to hide internal directories.