repltracker

package
v0.19.8 Latest Latest
Warning

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

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 21 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) HeartbeatWriter added in v0.14.0

func (rt *ReplTracker) HeartbeatWriter() heartbeat.HeartbeatWriter

HeartbeatWriter returns the heartbeat writer used by this tracker

func (*ReplTracker) InitDBConfig

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

InitDBConfig initializes the target name.

func (*ReplTracker) MakeNonPrimary added in v0.12.0

func (rt *ReplTracker) MakeNonPrimary()

MakeNonPrimary must be called if the tablet type becomes non-PRIMARY.

func (*ReplTracker) MakePrimary added in v0.12.0

func (rt *ReplTracker) MakePrimary()

MakePrimary must be called if the tablet type becomes PRIMARY.

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