type Event struct {Initbool `json:"-"`TemplateUsageStatsbool `json:"template_usage_stats"`}

type Option func(*Rolluper)

funcWithEventChannel¶

func WithEventChannel(ch chan<-Event)Option

WithEventChannel sets the event channel to use for rollup events.

This is only used for testing.

funcWithInterval¶

func WithInterval(intervaltime.Duration)Option

WithInterval sets the interval between rollups.

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

funcNew¶

func New(loggerslog.Logger, dbdatabase.Store, opts ...Option) *Rolluper

New creates a new DB rollup service that periodically runs rollup queries.It is the caller's responsibility to call Close on the returned instance.

This is for e.g. generating insights data (template_usage_stats) fromraw data (workspace_agent_stats, workspace_app_stats).

func (*Rolluper)Close¶

func (r *Rolluper) Close()error