Versions in this module Expand all Collapse all v0 v0.4.0 Aug 29, 2026 Changes in this version type ApplyResult + CheckpointRequired bool v0.2.0 Aug 25, 2026 Changes in this version + type Aggregator struct + func New(options Options) *Aggregator + func (a *Aggregator) Apply(report domain.ReportEnvelope) (domain.ReportReceipt, error) + func (a *Aggregator) ApplyAt(report domain.ReportEnvelope, receivedAt time.Time) (ApplyResult, error) + func (a *Aggregator) Clone() (*Aggregator, error) + func (a *Aggregator) HistoryMetadata() domain.HistoryMetadata + func (a *Aggregator) MarshalState() ([]byte, error) + func (a *Aggregator) ReplaceWith(candidate *Aggregator) error + func (a *Aggregator) RestoreState(payload []byte) error + func (a *Aggregator) Snapshot() domain.Topology + func (a *Aggregator) Subscribe() (<-chan struct{}, func()) + type ApplyResult struct + CanonicalStateChanged bool + Changed bool + PathTransitions []domain.PathTransition + Receipt domain.ReportReceipt + Traffic []domain.AcceptedTraffic + type Options struct + ControlNodeIDs []string + HeartbeatInterval time.Duration + NewNodeID func() string + Now func() time.Time v0.2.0-alpha.1 Aug 24, 2026
Go to main page