health

Documentation

Index

• Constants
• func History() []interface{}
• func Register(name string, rep Reporter)
• func Run(typ topo.TabletType) (map[string]string, error)
• type Aggregator
  • func NewAggregator() *Aggregator
  • func (ag *Aggregator) Register(name string, rep Reporter)
  • func (ag *Aggregator) Run(typ topo.TabletType) (map[string]string, error)
• type FunctionReporter
  • func (fc FunctionReporter) Report(typ topo.TabletType) (status map[string]string, err error)
• type Record
  • func (r Record) Class() string
  • func (r Record) IsDuplicate(other interface{}) bool
• type Reporter

Constants

const (
	// ReplicationLag should be the key for any reporters
	// reporting MySQL repliaction lag.
	ReplicationLag = "replication_lag"

	// ReplicationLagHigh should be the value for any reporters
	// indicating that the replication lag is too high.
	ReplicationLagHigh = "high"
)

const (
	Healthy   = "healthy"
	Unhappy   = "unhappy"
	Unhealthy = "unhealthy"
	Unknown   = "unknown"
)

Functions

func History

func History() []interface{}

History returns the health records from the default health aggregator.

func Register

func Register(name string, rep Reporter)

Register registers rep under name with the default health aggregator. Only keys specified in keys will be aggregated from this particular Reporter.

func Run

func Run(typ topo.TabletType) (map[string]string, error)

Run collects all the health statuses from the default health aggregator.

Types

type Aggregator

type Aggregator struct {
	History *history.History
	// contains filtered or unexported fields
}

Aggregator aggregates the results of many Reporters.

func NewAggregator

func NewAggregator() *Aggregator

func (*Aggregator) Register

func (ag *Aggregator) Register(name string, rep Reporter)

Register registers rep with ag. Only keys specified in keys will be aggregated from this particular Reporter.

func (*Aggregator) Run

func (ag *Aggregator) Run(typ topo.TabletType) (map[string]string, error)

Run runs aggregates health statuses from all the reporters. If any errors occur during the reporting, they will be logged, but only the first error will be returned. It may return an empty map if no health condition is detected. Note it will not return nil, but an empty map.

type FunctionReporter

type FunctionReporter func(typ topo.TabletType) (map[string]string, error)

FunctionReporter is a function that may act as a Reporter.

func (FunctionReporter) Report

func (fc FunctionReporter) Report(typ topo.TabletType) (status map[string]string, err error)

type Record

type Record struct {
	Error  error
	Result map[string]string
	Time   time.Time
}

Record records one run of an aggregator.

func (Record) Class

func (r Record) Class() string

func (Record) IsDuplicate

func (r Record) IsDuplicate(other interface{}) bool

type Reporter

type Reporter interface {
	// Report returns a map of health states for the tablet
	// assuming that its tablet type is typ. If Report returns an
	// error it implies that the tablet is in a bad shape and not
	// able to handle queries.
	Report(typ topo.TabletType) (status map[string]string, err error)
}

Reporter reports the health status of a tablet.