Help us shape the future of Go! Take the 2026 Go Developer Survey

app

package
v0.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 6, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) ApplyDirectorySnapshot added in v0.5.0

func (a *App) ApplyDirectorySnapshot(
	ctx context.Context,
	snapshot domain.DirectorySnapshot,
	syncState domain.DirectorySyncState,
) (aggregate.DirectoryApplyResult, error)

func (*App) ApplyDirectorySnapshotAt added in v0.5.0

func (a *App) ApplyDirectorySnapshotAt(
	ctx context.Context,
	snapshot domain.DirectorySnapshot,
	syncState domain.DirectorySyncState,
	updatedAt time.Time,
) (aggregate.DirectoryApplyResult, error)

func (*App) ClearDirectory added in v0.5.0

func (a *App) ClearDirectory(ctx context.Context) (bool, error)

func (*App) ClearDirectoryAt added in v0.5.0

func (a *App) ClearDirectoryAt(ctx context.Context, updatedAt time.Time) (bool, error)

func (*App) DeviceDirectory added in v0.5.0

func (a *App) DeviceDirectory() domain.DeviceDirectory

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, includeSystemTelemetry bool) (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, includeSystemTelemetry bool) (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)

func (*App) UpdateDirectorySyncState added in v0.5.0

func (a *App) UpdateDirectorySyncState(ctx context.Context, syncState domain.DirectorySyncState) error

func (*App) UpdateDirectorySyncStateAt added in v0.5.0

func (a *App) UpdateDirectorySyncStateAt(
	ctx context.Context,
	syncState domain.DirectorySyncState,
	updatedAt time.Time,
) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL