server

Documentation

Index

• type OnDemandProbeServer
  • func NewOnDemandProbeServer(fb *probe.ProbeBundle, g *graph.Graph, pool *shttp.WSJSONClientPool) (*OnDemandProbeServer, error)
  • func (o *OnDemandProbeServer) OnNodeDeleted(n *graph.Node)
  • func (o *OnDemandProbeServer) OnWSJSONMessage(c shttp.WSSpeaker, msg *shttp.WSJSONMessage)
  • func (o *OnDemandProbeServer) Start() error
  • func (o *OnDemandProbeServer) Stop()

Types

type OnDemandProbeServer

type OnDemandProbeServer struct {
	sync.RWMutex
	graph.DefaultGraphListener
	shttp.DefaultWSSpeakerEventHandler
	Graph            *graph.Graph
	Probes           *probe.ProbeBundle
	WSJSONClientPool *shttp.WSJSONClientPool
	// contains filtered or unexported fields
}

OnDemandProbeServer describes an ondemand probe server based on websocket

func NewOnDemandProbeServer

func NewOnDemandProbeServer(fb *probe.ProbeBundle, g *graph.Graph, pool *shttp.WSJSONClientPool) (*OnDemandProbeServer, error)

NewOnDemandProbeServer creates a new Ondemand probes server based on graph and websocket

func (*OnDemandProbeServer) OnNodeDeleted

func (o *OnDemandProbeServer) OnNodeDeleted(n *graph.Node)

OnNodeDeleted graph event

func (*OnDemandProbeServer) OnWSJSONMessage

func (o *OnDemandProbeServer) OnWSJSONMessage(c shttp.WSSpeaker, msg *shttp.WSJSONMessage)

OnWSJSONMessage websocket message, valid message type are CaptureStart, CaptureStop

func (*OnDemandProbeServer) Start

func (o *OnDemandProbeServer) Start() error

Start the probe

func (*OnDemandProbeServer) Stop

func (o *OnDemandProbeServer) Stop()

Stop the probe