flow

Documentation

Index

• Variables
• func SetClock(c clock.Clock)
• type Meter
  • func NewMeter() *Meter
  • func (m *Meter) Mark(count uint64)
  • func (m *Meter) Reset()
  • func (m *Meter) Snapshot() Snapshot
  • func (m *Meter) String() string
• type MeterRegistry
  • func (r *MeterRegistry) Clear()
  • func (r *MeterRegistry) FindIdle(since time.Time) []string
  • func (r *MeterRegistry) ForEach(iterFunc func(string, *Meter))
  • func (r *MeterRegistry) Get(name string) *Meter
  • func (r *MeterRegistry) Remove(name string)
  • func (r *MeterRegistry) TrimIdle(since time.Time) (trimmed int)
• type Snapshot
  • func (s Snapshot) String() string

Variables

var IdleRate = 1e-13

IdleRate the rate at which we declare a meter idle (and stop tracking it until it's re-registered).

The default ensures that 1 event every ~30s will keep the meter from going idle.

Functions

func SetClock

func SetClock(c clock.Clock)

SetClock sets a clock to use in the sweeper. This will probably only ever be useful for testing purposes.

Types

type Meter

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

Meter is a meter for monitoring a flow.

func NewMeter

func NewMeter() *Meter

NewMeter returns a new Meter with the correct idle time.

While zero-value Meters can be used, their "last update" time will start at the program start instead of when the meter was created.

func (*Meter) Mark

func (m *Meter) Mark(count uint64)

Mark updates the total.

func (*Meter) Reset

func (m *Meter) Reset()

Reset sets accumulator, total and rate to zero.

func (*Meter) Snapshot

func (m *Meter) Snapshot() Snapshot

Snapshot gets a snapshot of the total and rate.

func (*Meter) String

func (m *Meter) String() string

type MeterRegistry

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

MeterRegistry is a registry for named meters.

func (*MeterRegistry) Clear

func (r *MeterRegistry) Clear()

Clear removes all meters from the registry.

func (*MeterRegistry) FindIdle

func (r *MeterRegistry) FindIdle(since time.Time) []string

FindIdle finds all meters that haven't been used since the given time.

func (*MeterRegistry) ForEach

func (r *MeterRegistry) ForEach(iterFunc func(string, *Meter))

ForEach calls the passed function for each registered meter.

func (*MeterRegistry) Get

func (r *MeterRegistry) Get(name string) *Meter

Get gets (or creates) a meter by name.

func (*MeterRegistry) Remove

func (r *MeterRegistry) Remove(name string)

Remove removes the named meter from the registry.

Note: The only reason to do this is to save a bit of memory. Unused meters don't consume any CPU (after they go idle).

func (*MeterRegistry) TrimIdle

func (r *MeterRegistry) TrimIdle(since time.Time) (trimmed int)

TrimIdle trims that haven't been updated since the given time. Returns the number of timers trimmed.

type Snapshot

type Snapshot struct {
	Rate       float64
	Total      uint64
	LastUpdate time.Time
}

Snapshot is a rate/total snapshot.

func (Snapshot) String

func (s Snapshot) String() string