server

Documentation

Index

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

Types

type OnDemandProbeServer

type OnDemandProbeServer struct {
	common.RWMutex
	graph.DefaultGraphListener
	shttp.DefaultWSSpeakerEventHandler
	Graph              *graph.Graph
	Probes             *probe.ProbeBundle
	WSStructClientPool *shttp.WSStructClientPool
	// 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.WSStructClientPool) (*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) OnWSStructMessage

func (o *OnDemandProbeServer) OnWSStructMessage(c shttp.WSSpeaker, msg *shttp.WSStructMessage)

OnWSStructMessage 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