subscriber

Documentation

Index

• type Errors
  • func (e Errors) Error() error
  • func (e Errors) Errors() Errors
  • func (e Errors) Set(name string, err error)
• type Observer
  • func NewObserver(names []string, sub *Subscriber) *Observer
  • func (o *Observer) Error() error
  • func (o *Observer) Errors() Errors
• type Subscriber
  • func NewSubscriber(names []string) *Subscriber
  • func (s *Subscriber) Receive() <-chan *probe.Tick
  • func (s *Subscriber) Send(tick *probe.Tick)

Types

type Errors

type Errors map[string]error

Errors for observers.

func (Errors) Error

func (e Errors) Error() error

Error the first error from map.

func (Errors) Errors

func (e Errors) Errors() Errors

Errors is a copy.

func (Errors) Set

func (e Errors) Set(name string, err error)

Set the error at the name.

type Observer

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

Observer represents a subscriber that mantaines state about probes.

func NewObserver

func NewObserver(names []string, sub *Subscriber) *Observer

NewObserver from probe names and subscriber.

func (*Observer) Error

func (o *Observer) Error() error

Error is the first error observed.

func (*Observer) Errors

func (o *Observer) Errors() Errors

Error are a copy of rhe errors.

type Subscriber

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

Subscriber subscribes to multiple probes.

func NewSubscriber

func NewSubscriber(names []string) *Subscriber

NewSubscriber for multiple probes.

func (*Subscriber) Receive

func (s *Subscriber) Receive() <-chan *probe.Tick

Receive from the subscriber.

func (*Subscriber) Send

func (s *Subscriber) Send(tick *probe.Tick)

Send tick to subscriber.