aggregate

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

type ApplyResult struct {
	Receipt               domain.ReportReceipt
	Traffic               []domain.AcceptedTraffic
	PathTransitions       []domain.PathTransition
	Changed               bool
	CanonicalStateChanged bool
	CheckpointRequired    bool
}

type Options struct {
	HeartbeatInterval time.Duration
	ControlNodeIDs    []string
	Now               func() time.Time
	NewNodeID         func() string
}