probe

package

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

Details

This section is empty.

View Source

var ErrProbeNotCompiled = fmt.Errorf("probe not compiled")

ErrProbeNotCompiled is thrown when a flow probe was not compiled within the binary

This section is empty.

type Bundle struct {
	common.RWMutex
	Handlers map[string]Handler
}

Bundle describes a bundle of probes (topology of flow)

func NewBundle() *Bundle

NewBundle creates a new probe handler bundle

func (p *Bundle) AddHandler(typ string, handler Handler)

AddHandler adds a probe to the bundle

func (p *Bundle) EnabledProbes() []string

EnabledProbes returns all enabled probes name

func (p *Bundle) GetHandler(typ string) Handler

GetHandler retrieve a specific handler

func (p *Bundle) GetStatus() map[string]interface{}

GetStatus returns the status of all the probes

func (p *Bundle) Start()

Start a bundle of probes

func (p *Bundle) Stop()

Stop a bundle of probes

type Handler interface {
	Start()
	Stop()
}

Handler describes a ProbeHandler. A ProbeHandler aims to create probe

type ServiceStatus struct {
	Status common.ServiceState
}

ServiceStatus describes the status returned by GetStatus

type StatusReporter interface {
	GetStatus() interface{}
}

StatusReporter can be implemented by probes to report their status