v2

type Event ¶

type Event queue.Item

type Metrics ¶ added in v0.32.4

type Metrics struct {
	// events_in
	EventsIn metrics.Counter
	// events_in
	EventsHandled metrics.Counter
	// events_out
	EventsOut metrics.Counter
	// errors_in
	ErrorsIn metrics.Counter
	// errors_handled
	ErrorsHandled metrics.Counter
	// errors_out
	ErrorsOut metrics.Counter
	// events_shed
	EventsShed metrics.Counter
	// events_sent
	EventsSent metrics.Counter
	// errors_sent
	ErrorsSent metrics.Counter
	// errors_shed
	ErrorsShed metrics.Counter
}

Metrics contains metrics exposed by this package.

func NopMetrics() *Metrics

func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics

type PeerByID ¶ added in v0.33.0

type PeerByID []p2p.ID

PeerByID is a list of peers sorted by peerID.

func (peers PeerByID) Len() int

func (peers PeerByID) Less(i, j int) bool

func (peers PeerByID) Swap(i, j int)

type Reactor ¶ added in v0.32.4

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

func NewReactor(bufferSize int) *Reactor

func (r *Reactor) AddPeer()

func (r *Reactor) Receive(event Event)

func (r *Reactor) Start()

func (r *Reactor) Stop()

type Routine ¶ added in v0.32.4

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

Routines are a structure which model a finite state machine as serialized stream of events processed by a handle function. This Routine structure handles the concurrency and messaging guarantees. Events are sent via `send` are handled by the `handle` function to produce an iterator `next()`. Calling `stop()` on a routine will conclude processing of all sent events and produce `final()` event representing the terminal state.