advisor

Jun 13, 2022

Changes in this version

+ type Advisor struct

+ func New(ctx context.Context, wg *sync.WaitGroup, cfg *config.Advisory, nc *nats.Conn, ...) (*Advisor, error)

+ func (a *Advisor) Pause()

+ func (a *Advisor) Resume()

+ type AgeAdvisoryV2 struct

+ Age float64

+ Event EventType

+ EventID string

+ InspectField string

+ Protocol string

+ Replicator string

+ Seen int64

+ Timestamp int64

+ Value string

+ type EventType string

+ var AdvisoryProtocol = "io.choria.sr.v2.age_advisory"

+ var ExpireEvent EventType = "expire"

+ var FirstSeenEvent EventType = "new"

+ var RecoverEvent EventType = "recover"

+ var TimeoutEvent EventType = "timeout"

+ type Tracker interface

+ NotifyAgeWarning func(cb func(map[string]idtrack.Item)) error

+ NotifyExpired func(cb func(map[string]idtrack.Item)) error

+ NotifyFirstSeen func(cb func(string, idtrack.Item)) error

+ NotifyRecover func(cb func(string, idtrack.Item)) error

+ RecordAdvised func(v string)