app

package

v0.4.0 Latest Latest Go to latest Published: Aug 29, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type App struct {
	Aggregator *aggregate.Aggregator
	Store      *store.SQLite
	// contains filtered or unexported fields
}

func New(database *store.SQLite, options aggregate.Options, logger *slog.Logger) (*App, error)

func (a *App) EdgeHistory(ctx context.Context, edgeID string) (domain.EdgeHistory, error)

func (a *App) EdgeHistoryWindow(ctx context.Context, edgeID string, window domain.HistoryWindow) (domain.EdgeHistory, bool, error)

func (a *App) HistoryEdges(ctx context.Context, query domain.HistoryEdgeQuery) (domain.HistoryEdgePage, error)

func (a *App) HistoryNodes(ctx context.Context, window domain.HistoryWindow) (domain.HistoryNodes, error)

func (a *App) Maintain(ctx context.Context, now time.Time) error

func (a *App) RunMaintenance(ctx context.Context)

func (a *App) StoreRetention() time.Duration

func (a *App) Submit(ctx context.Context, report domain.ReportEnvelope) (domain.ReportReceipt, error)

func (a *App) SubmitAt(ctx context.Context, report domain.ReportEnvelope, receivedAt time.Time) (domain.ReportReceipt, error)