stats

Documentation

Index

• type Counters
  • func (c *Counters) DecrJob()
  • func (c *Counters) DecrSpoke()
  • func (c *Counters) IncrJob()
  • func (c *Counters) IncrSpoke()
  • func (c *Counters) Read() Snapshot
• type Snapshot

Types

type Counters

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

Counters are used to keep quick stats counters so that we can do stats reporting without locking the hub and reading over the spokes internal state should not be accessed directly

func (*Counters) DecrJob

func (c *Counters) DecrJob()

DecrJob updates counter - job has been removed

func (*Counters) DecrSpoke

func (c *Counters) DecrSpoke()

DecrSpoke updates counter - spoke has been removed

func (*Counters) IncrJob

func (c *Counters) IncrJob()

IncrJob updates counters - job has been added

func (*Counters) IncrSpoke

func (c *Counters) IncrSpoke()

IncrSpoke updates counters - spoke has been added

func (*Counters) Read

func (c *Counters) Read() Snapshot

Read returns a "copy" of the current stats snapshot at that instant

type Snapshot

type Snapshot struct {
	CurrentJobs   int64 // current set of jobs
	RemovedJobs   int64 // jobs removed so far
	CurrentSpokes int64 // number of current spokes
}

Snapshot is a readonly view of the stats counters