repo

Documentation

Index

• func GetLastNRawStats(name string, last int) ([]stat.Stat, error)
• func GetRawStats(name string, start, end time.Time) ([]stat.Stat, error)
• type StatRepo
  • func NewStatRepo(rawStats <-chan *stat.Stat, shutdown <-chan bool) *StatRepo
  • func (s *StatRepo) Run()

Functions

func GetLastNRawStats

func GetLastNRawStats(name string, last int) ([]stat.Stat, error)

func GetRawStats

func GetRawStats(name string, start, end time.Time) ([]stat.Stat, error)

Types

type StatRepo

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

func NewStatRepo

func NewStatRepo(rawStats <-chan *stat.Stat, shutdown <-chan bool) *StatRepo

NewStatRepo constructs a StatRepo

func (*StatRepo) Run

func (s *StatRepo) Run()

Run is a goroutine that writes stats from the input channel, placing them into the appropriate bucket. Buckets are published on the output channel at the specified interval