repllag

Documentation

Index

• Constants
• type Lag
  • func NewLag(db *sql.DB) *Lag
  • func (c *Lag) Collect(ctx context.Context, levelName string) ([]blip.MetricValue, error)
  • func (c *Lag) Domain() string
  • func (c *Lag) Help() blip.CollectorHelp
  • func (c *Lag) Prepare(ctx context.Context, plan blip.Plan) (func(), error)

Constants

const (
	DOMAIN = "repl.lag"

	OPT_SOURCE_ID            = "source-id"
	OPT_SOURCE_ROLE          = "source-role"
	OPT_TABLE                = "table"
	OPT_WRITER               = "writer"
	OPT_REPL_CHECK           = "repl-check"
	OPT_REPORT_NO_HEARTBEAT  = "report-no-heartbeat"
	OPT_REPORT_NOT_A_REPLICA = "report-not-a-replica"
	OPT_NETWORK_LATENCY      = "network-latency"
)

Types

type Lag

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

func NewLag

func NewLag(db *sql.DB) *Lag

func (*Lag) Collect

func (c *Lag) Collect(ctx context.Context, levelName string) ([]blip.MetricValue, error)

func (*Lag) Domain

func (c *Lag) Domain() string

func (*Lag) Help

func (c *Lag) Help() blip.CollectorHelp

func (*Lag) Prepare

func (c *Lag) Prepare(ctx context.Context, plan blip.Plan) (func(), error)