repltracker

package
v0.11.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 17, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.8.0

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL