repltracker

Documentation

Index

• type ReplTracker
  • func NewReplTracker(env tabletenv.Env, alias *topodatapb.TabletAlias) *ReplTracker
  • func (rt *ReplTracker) Close()
  • func (rt *ReplTracker) EnableHeartbeat(enable bool)
  • func (rt *ReplTracker) InitDBConfig(target *querypb.Target, mysqld mysqlctl.MysqlDaemon)
  • func (rt *ReplTracker) MakeMaster()
  • func (rt *ReplTracker) MakeNonMaster()
  • func (rt *ReplTracker) Status() (time.Duration, error)

Types

type ReplTracker

type ReplTracker struct {
	// contains filtered or unexported fields
}

ReplTracker tracks replication lag.

func NewReplTracker

func NewReplTracker(env tabletenv.Env, alias *topodatapb.TabletAlias) *ReplTracker

NewReplTracker creates a new ReplTracker.

func (*ReplTracker) Close

func (rt *ReplTracker) Close()

Close closes ReplTracker.

func (*ReplTracker) EnableHeartbeat

func (rt *ReplTracker) EnableHeartbeat(enable bool)

EnableHeartbeat enables or disables writes of heartbeat. This functionality is only used by tests.

func (*ReplTracker) InitDBConfig

func (rt *ReplTracker) InitDBConfig(target *querypb.Target, mysqld mysqlctl.MysqlDaemon)

InitDBConfig initializes the target name.

func (*ReplTracker) MakeMaster

func (rt *ReplTracker) MakeMaster()

MakeMaster must be called if the tablet type becomes MASTER.

func (*ReplTracker) MakeNonMaster

func (rt *ReplTracker) MakeNonMaster()

MakeNonMaster must be called if the tablet type becomes non-MASTER.

func (*ReplTracker) Status

func (rt *ReplTracker) Status() (time.Duration, error)

Status reports the replication status.