probes

package

v0.25.0 Latest Latest Go to latest Published: Sep 12, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

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 interface {
	probe.Handler
	Init(ctx Context, bundle *probe.Bundle) (Handler, error)
}

Handler defines a topology probe handler

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(handler handler) *ProbeWrapper

NewProbeWrapper returns a new probe wrapper

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

GetStatus returns the status of the probe

func (p *ProbeWrapper) Start()

Start the probe

func (p *ProbeWrapper) Stop()

Stop the probe