count

Documentation

Index

• Constants
• type CountRepo
  • func NewCountRepo() (result *CountRepo)
  • func (repo *CountRepo) BatchInsert(batch []*_types.Count) error
  • func (repo *CountRepo) Find(filter types.Filter, agg string) (types.Counts, error)
  • func (repo *CountRepo) RunBatcher() *CountRepo
  • func (repo *CountRepo) StatsByDashboard(dashId int) ([]*types.DashStatRow, error)
  • func (repo *CountRepo) StatsByDashboardCached(dashId int) ([]*types.DashStatRow, error)
  • func (repo *CountRepo) StatsByLogname(dashId int, logname string) ([]*types.DashStatRow, error)
  • func (repo *CountRepo) StatsByLognameCached(dashId int, logname string) ([]*types.DashStatRow, error)
  • func (repo *CountRepo) StopBatcher() error
  • func (repo *CountRepo) Store(count *_types.Count) error

Constants

const (
	AggMinute   = "m"
	Agg5Minutes = "5m"
	AggHour     = "h"
	AggDay      = "d"
)

Types

type CountRepo

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

func NewCountRepo

func NewCountRepo() (result *CountRepo)

func (*CountRepo) BatchInsert

func (repo *CountRepo) BatchInsert(batch []*_types.Count) error

func (*CountRepo) Find

func (repo *CountRepo) Find(filter types.Filter, agg string) (types.Counts, error)

func (*CountRepo) RunBatcher

func (repo *CountRepo) RunBatcher() *CountRepo

func (*CountRepo) StatsByDashboard

func (repo *CountRepo) StatsByDashboard(dashId int) ([]*types.DashStatRow, error)

func (*CountRepo) StatsByDashboardCached

func (repo *CountRepo) StatsByDashboardCached(dashId int) ([]*types.DashStatRow, error)

func (*CountRepo) StatsByLogname

func (repo *CountRepo) StatsByLogname(dashId int, logname string) ([]*types.DashStatRow, error)

func (*CountRepo) StatsByLognameCached

func (repo *CountRepo) StatsByLognameCached(dashId int, logname string) ([]*types.DashStatRow, error)

func (*CountRepo) StopBatcher

func (repo *CountRepo) StopBatcher() error

func (*CountRepo) Store

func (repo *CountRepo) Store(count *_types.Count) error