advisor

package

v0.8.2 Latest Latest Go to latest Published: Apr 19, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/choria-io/stream-replicator

Links

Open Source Insights

Documentation ¶

Index ¶

type Advisor
- 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
type EventType
type Tracker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Advisor ¶

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

func New ¶

func New(ctx context.Context, wg *sync.WaitGroup, cfg *config.Advisory, nc *nats.Conn, tracker Tracker, inspectField string, stream string, replicator string, log *logrus.Entry) (*Advisor, error)

func (*Advisor) Pause ¶

func (a *Advisor) Pause()

func (*Advisor) Resume ¶

func (a *Advisor) Resume()

type AgeAdvisoryV2 ¶

type AgeAdvisoryV2 struct {
	Protocol     string    `json:"protocol"`
	EventID      string    `json:"event_id"`
	InspectField string    `json:"inspect_field"`
	Age          float64   `json:"age"`
	Seen         int64     `json:"seen"`
	Replicator   string    `json:"replicator"`
	Timestamp    int64     `json:"timestamp"`
	Event        EventType `json:"event"`
	Value        string    `json:"value"`
}

AgeAdvisoryV2 defines a message published when a node has not been seen within configured deadlines and when it recovers

type EventType ¶

type EventType string

EventType is the kind of event that triggered the advisory

var (
	TimeoutEvent     EventType = "timeout"
	RecoverEvent     EventType = "recover"
	ExpireEvent      EventType = "expire"
	FirstSeenEvent   EventType = "new"
	AdvisoryProtocol           = "io.choria.sr.v2.age_advisory"
)

type Tracker ¶

type Tracker interface {
	NotifyFirstSeen(cb func(string, idtrack.Item)) error
	NotifyRecover(cb func(string, idtrack.Item)) error
	NotifyAgeWarning(cb func(map[string]idtrack.Item)) error
	NotifyExpired(cb func(map[string]idtrack.Item)) error
	RecordAdvised(v string)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL