count

Documentation

Index

• Constants
• type CountRepo
  • func NewCountRepo() *CountRepo
  • func (repo *CountRepo) BatchInsert(batch []*_types.Count) error
  • func (repo *CountRepo) Find(filter types.Filter, agg string) (types.Counts, error)
  • func (repo *CountRepo) Insert(count *_types.Count) error
  • func (repo *CountRepo) StartBatcher()
  • 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()
  • func (repo *CountRepo) Store(count *_types.Count) error

Constants

const (
	AGG_MINUTE   = "m"
	AGG_5MINUTES = "5m"
	AGG_HOUR     = "h"
	AGG_DAY      = "d"
)

Types

type CountRepo

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

func NewCountRepo

func NewCountRepo() *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) Insert

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

func (*CountRepo) StartBatcher

func (repo *CountRepo) StartBatcher()

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()

func (*CountRepo) Store

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