aggregate

Documentation

Index

• type Aggregator
  • 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) ApplyDirectorySnapshot(snapshot domain.DirectorySnapshot, syncState domain.DirectorySyncState) (DirectoryApplyResult, error)
  • func (a *Aggregator) ClearDirectory() bool
  • func (a *Aggregator) Clone() (*Aggregator, error)
  • func (a *Aggregator) DeviceDirectory() domain.DeviceDirectory
  • 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())
  • func (a *Aggregator) UpdateDirectorySyncState(syncState domain.DirectorySyncState) error
• type ApplyResult
• type DirectoryApplyResult
• type Options

Types

type Aggregator

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

func New

func New(options Options) *Aggregator

func (*Aggregator) Apply

func (a *Aggregator) Apply(report domain.ReportEnvelope) (domain.ReportReceipt, error)

func (*Aggregator) ApplyAt

func (a *Aggregator) ApplyAt(report domain.ReportEnvelope, receivedAt time.Time) (ApplyResult, error)

func (*Aggregator) ApplyDirectorySnapshot

func (a *Aggregator) ApplyDirectorySnapshot(snapshot domain.DirectorySnapshot, syncState domain.DirectorySyncState) (DirectoryApplyResult, error)

func (*Aggregator) ClearDirectory

func (a *Aggregator) ClearDirectory() bool

func (*Aggregator) Clone

func (a *Aggregator) Clone() (*Aggregator, error)

func (*Aggregator) DeviceDirectory

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

func (*Aggregator) HistoryMetadata

func (a *Aggregator) HistoryMetadata() domain.HistoryMetadata

func (*Aggregator) MarshalState

func (a *Aggregator) MarshalState() ([]byte, error)

func (*Aggregator) ReplaceWith

func (a *Aggregator) ReplaceWith(candidate *Aggregator) error

func (*Aggregator) RestoreState

func (a *Aggregator) RestoreState(payload []byte) error

func (*Aggregator) Snapshot

func (a *Aggregator) Snapshot() domain.Topology

func (*Aggregator) Subscribe

func (a *Aggregator) Subscribe() (<-chan struct{}, func())

func (*Aggregator) UpdateDirectorySyncState

func (a *Aggregator) UpdateDirectorySyncState(syncState domain.DirectorySyncState) error

type ApplyResult

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

type DirectoryApplyResult

type DirectoryApplyResult struct {
	Changed               bool
	CanonicalStateChanged bool
	Normalization         domain.DirectoryNormalization
}

type Options

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