Versions in this module Expand all Collapse all v0 v0.1.1 Oct 4, 2026 Changes in this version type Option + func WithClaudeReconciliation() Option v0.1.0 Oct 3, 2026 Changes in this version + func Run(ctx context.Context, interval time.Duration, reg *adapter.Registry, st Store, ...) error + type CycleStats struct + ActivityInserted int + ActivitySeen int + Adapters int + Canceled bool + CodeChangesUpdated int + Errors []string + EventsInserted int + EventsSeen int + PricesSynced int + RollupRebuilt bool + Snapshots int + Sources int + SourcesFailed int + TurnContextsInserted int + TurnContextsSeen int + func RunOnce(ctx context.Context, reg *adapter.Registry, st Store, ...) (CycleStats, error) + func (s CycleStats) AllFailed() bool + type Option func(*cycleOptions) + func WithCycleCallback(fn func(CycleStats, error)) Option + func WithPricer(p Pricer) Option + func WithoutRaw() Option + type Pricer interface + PriceEvent func(e model.UsageEvent) (microUSD int64, source string, ok bool) + type Refresher interface + Refresh func(ctx context.Context) error + type Store interface + ApplyBatch func(ctx context.Context, b store.ObservationBatch) (store.Applied, error) + ApplyEvents func(ctx context.Context, events []model.UsageEvent, cp *model.SourceCheckpoint) (int, error) + ApplySnapshot func(ctx context.Context, events []model.UsageEvent, state model.AggregateSnapshot, ...) (int, error) + Checkpoint func(ctx context.Context, tool, sourcePath string) (*model.SourceCheckpoint, error) + EnsureRollup func(ctx context.Context) (bool, error) + LastState func(ctx context.Context, tool, key string) (*model.AggregateSnapshot, error)
Go to main page