probes

Documentation

Index

• Variables
• type Context
• type Handler
• type ProbeWrapper
  • func NewProbeWrapper(handler handler) *ProbeWrapper
  • func NewProbeWrapperWithDuration(handler handler, interval time.Duration) *ProbeWrapper
  • func (p *ProbeWrapper) GetStatus() interface{}
  • func (p *ProbeWrapper) Start()
  • func (p *ProbeWrapper) Stop()

Variables

var (
	// ErrNotStopped is used when a not stopped probe is started
	ErrNotStopped = errors.New("service is not stopped")
)

Types

type Context

type Context struct {
	Logger   logging.Logger
	Config   config.Config
	Graph    *graph.Graph
	RootNode *graph.Node
}

Context defines a context to be used by constructor of probes

type Handler

type Handler interface {
	probe.Handler
	Init(ctx Context, bundle *probe.Bundle) (Handler, error)
}

Handler defines a topology probe handler

type ProbeWrapper

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

ProbeWrapper wraps a probe so that it tries to reconnect if the connection to the daemon is lost

func NewProbeWrapper

func NewProbeWrapper(handler handler) *ProbeWrapper

NewProbeWrapper returns a new probe wrapper

func NewProbeWrapperWithDuration

func NewProbeWrapperWithDuration(handler handler, interval time.Duration) *ProbeWrapper

NewProbeWrapperWithDuration returns a new probe wrapper from a given interval

func (*ProbeWrapper) GetStatus

func (p *ProbeWrapper) GetStatus() interface{}

GetStatus returns the status of the probe

func (*ProbeWrapper) Start

func (p *ProbeWrapper) Start()

Start the probe

func (*ProbeWrapper) Stop

func (p *ProbeWrapper) Stop()

Stop the probe