Function New

coderd/database/dbrollup/dbrollup.go:62–82

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) from raw data (workspace_agent_stats, workspace_app_stats).

(logger slog.Logger, db database.Store, opts ...Option)

// This is for e.g. generating insights data (template_usage_stats) from
// raw data (workspace_agent_stats, workspace_app_stats).
func New(logger slog.Logger, db database.Store, opts ...Option) *Rolluper {
	ctx, cancel := context.WithCancel(context.Background())

	r := &Rolluper{
		cancel:   cancel,
		closed:   make(chan struct{}),
		db:       db,
		logger:   logger,
		interval: DefaultInterval,
	}

	for _, opt := range opts {
		opt(r)
	}

	//nolint:gocritic // The system rolls up database tables without user input.
	ctx = dbauthz.AsSystemRestricted(ctx)
	go r.start(ctx)

	return r
}

func (r *Rolluper) start(ctx context.Context) {
	defer close(r.closed)