app

Documentation

Index

• type App
  • 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)

Types

type App

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

func New

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

func (*App) EdgeHistory

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

func (*App) EdgeHistoryWindow

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

func (*App) HistoryEdges

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

func (*App) HistoryNodes

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

func (*App) Maintain

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

func (*App) RunMaintenance

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

func (*App) StoreRetention

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

func (*App) Submit

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

func (*App) SubmitAt

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