component

Documentation

Index

• func RegisterManager(characterType string, manager DBManager)
• type DBManager
  • func GetManager(characterType string) DBManager
• type DBManagerBase
  • func (mgr *DBManagerBase) GetCurrentMemberName() string
  • func (mgr *DBManagerBase) GetLogger() logger.Logger
  • func (mgr *DBManagerBase) IsDBStartupReady() bool

Functions

func RegisterManager

func RegisterManager(characterType string, manager DBManager)

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

func GetManager(characterType string) DBManager

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