stats

Documentation

Index

• type DimensionKeeper
• type Keeper
  • func Combine(keepers ...Keeper) Keeper
  • func NewGolangKeeper() Keeper
  • func ToKeeper(k DimensionKeeper, dims map[string]string) Keeper
  • func ToKeeperMany(dims map[string]string, keeps ...DimensionKeeper) Keeper
• type StatDrainingThread
  • func NewDrainingThread(delay time.Duration, sendTo []dpsink.Sink, listenFrom []Keeper, ...) *StatDrainingThread
  • func (thread *StatDrainingThread) Stats() []*datapoint.Datapoint

Types

type DimensionKeeper

type DimensionKeeper interface {
	Stats(dimensions map[string]string) []*datapoint.Datapoint
}

A DimensionKeeper contains datapoints that describe its state and can be reported upstream

type Keeper

type Keeper interface {
	Stats() []*datapoint.Datapoint
}

A Keeper contains datapoints that describe its state and can be reported upstream

func Combine

func Combine(keepers ...Keeper) Keeper

Combine multiple keepers into a single keeper

func NewGolangKeeper

func NewGolangKeeper() Keeper

NewGolangKeeper returns a new stats keeper that can return internal golang stats

func ToKeeper

func ToKeeper(k DimensionKeeper, dims map[string]string) Keeper

ToKeeper creates a keeper that pulls stats from k with dims

func ToKeeperMany

func ToKeeperMany(dims map[string]string, keeps ...DimensionKeeper) Keeper

ToKeeperMany creates a single keeper that pulls stats from each of keeps with dims

type StatDrainingThread

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

StatDrainingThread will sleep delay between draining stats from each keeper and sending the full stats to each sendTo sink

func NewDrainingThread

func NewDrainingThread(delay time.Duration, sendTo []dpsink.Sink, listenFrom []Keeper, ctx context.Context, logger log.Logger) *StatDrainingThread

NewDrainingThread returns a new DrainingThread to collect stats and send them to sinks

func (*StatDrainingThread) Stats

func (thread *StatDrainingThread) Stats() []*datapoint.Datapoint

Stats returns all the stast this draining thread will report