monitor

Documentation

Index

• func NewMuxer(t transport.MonitorTransport)
• type Handler
• type Identity
  • func NewIdentity(id string, t transport.MonitorTransport) *Identity
  • func (s *Identity) Drop(n string) error
  • func (s *Identity) Subscribe(n string, h Handler) error
• type Muxer
  • func (m *Muxer) Register(id string, v string, h Handler)
  • func (m *Muxer) Serve()
  • func (m *Muxer) Sub()

Functions

func NewMuxer

func NewMuxer(t transport.MonitorTransport)

Types

type Handler

type Handler func(name string, v transport.Var)

Handler handles a change to a subscribed variable. Only one Handler is guarenteed to be firing for a given variable.

type Identity

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

Identity provides the ability to handle incoming monitoring variables from an application with a specific Identity.

func NewIdentity

func NewIdentity(id string, t transport.MonitorTransport) *Identity

NewIdentity is the constructor for Identity.

func (*Identity) Drop

func (s *Identity) Drop(n string) error

Drop tells the service to stop updating us about the variable and then stops all handlers for that variable.

func (*Identity) Subscribe

func (s *Identity) Subscribe(n string, h Handler) error

type Muxer

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

func (*Muxer) Register

func (m *Muxer) Register(id string, v string, h Handler)

func (*Muxer) Serve

func (m *Muxer) Serve()

func (*Muxer) Sub

func (m *Muxer) Sub()