Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetaInfo ¶
type MetaInfo struct { sync.RWMutex //binlog filename Name string //binlog position Pos uint32 //server group, check server.group == meta.group Group string //save time LastSaveTime time.Time //server self role MyRole ha.NodeStatus }
func NewMetaInfo ¶
type SyncClient ¶
type SyncClient struct { MysqlDumpPath string sync.RWMutex // contains filtered or unexported fields }
func NewSyncClient ¶
func NewSyncClient(cfg *config.ServerConfig) (*SyncClient, error)
func (*SyncClient) Close ¶
func (r *SyncClient) Close()
func (*SyncClient) Ctx ¶
func (c *SyncClient) Ctx() context.Context
func (*SyncClient) IsRunaway ¶
func (c *SyncClient) IsRunaway() (bool, string)
func (*SyncClient) RoleSwitch ¶
func (c *SyncClient) RoleSwitch() chan<- ha.NodeStatus
func (*SyncClient) Start ¶
func (c *SyncClient) Start() error
Click to show internal directories.
Click to hide internal directories.