stats

Documentation

Index

• type Aggregator
  • func NewAggregator(store Store) *Aggregator
  • func (a *Aggregator) Run() error
  • func (a *Aggregator) Stop() error
• type Store

Types

type Aggregator

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

func NewAggregator

func NewAggregator(store Store) *Aggregator

func (*Aggregator) Run

func (a *Aggregator) Run() error

func (*Aggregator) Stop

func (a *Aggregator) Stop() error

type Store

type Store interface {
	LatestDailyStats() (model.Stats, error)
	AggregateStats(time.Time) error
}