ingest

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

type PeerUsage struct {
	Upload    uint
	Download  uint
	PublicKey string
}

type RestartMarkFileReadRemover interface {
	Read(filename string) ([1]byte, error)
	Remove(filename string) error
}

type Store interface {
	LoadBeforeRestartUsage(ctx context.Context) (map[string]PeerUsage, error)
	IngestUsage(ctx context.Context, peersUsage []PeerUsage, gatheredAt time.Time) error
}

type WgPeers interface {
	Usage(ctx context.Context) (peersUsage []PeerUsage, gatheredAt time.Time, err error)
}