server

type DataHandlerOptions ¶ added in v0.1.5

type DataHandlerOptions struct {
	Host, InstanceID, Hostname string
	AllowIngestion             bool
	Policy                     serverfeatures.Policy
	Accounts                   *accounts.Service
	PublicURL                  string
	Progress                   *collectorprogress.Registry
	ProcessUsage               ProcessUsage
}

type DataSource ¶ added in v0.1.5

type DataSource interface {
	Kind() string
	Receiver(datasetID string) evidence.Receiver
	Queries(datasetID string) analytics.Repository
}

DataSource binds storage ports to an authenticated dataset. Composition selects the adapter once; HTTP never opens databases or selects a backend from a request. Receiver and Queries must use the same database/dataset identity. Scoping never creates a dataset or falls back to another dataset when it is absent.

type DirectQuery ¶ added in v0.1.5

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

DirectQuery adapts the same query validation, analytics and presentation used by REST without constructing HTTP requests or opening a listener.

func NewDirectQuery(source analytics.Repository, instance, hostname string) *DirectQuery

func (d *DirectQuery) AllUsage(ctx context.Context, params api.GetUsageParams, maxRows int) (api.UsageResponseV2, error)

func (d *DirectQuery) Facets(ctx context.Context, params api.GetUsageFacetsParams) (api.UsageFacetsResponseV2, error)

func (d *DirectQuery) Instance(ctx context.Context) (api.InstanceResponseV2, error)

func (d *DirectQuery) Status(ctx context.Context) (api.StatusResponseV2, error)

func (d *DirectQuery) Usage(ctx context.Context, params api.GetUsageParams) (api.UsageResponseV2, error)

type Options ¶

type Options struct {
	Defaults   viewer.Selection
	InstanceID string
	Hostname   string
}

type ProcessUsage ¶ added in v0.1.5

type ProcessUsage interface {
	Snapshot(context.Context) processusage.Sample
}

ProcessUsage samples the command-owned process; missing measurements remain unknown.

type Row ¶

type Row = analytics.Row