subscriber

Documentation

Index

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

Types

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.

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.