server

Documentation

Index

• type OnDemandProbeServer
  • func NewOnDemandProbeServer(fb *probes.FlowProbeBundle, g *graph.Graph, wspool *shttp.WSAsyncClientPool) (*OnDemandProbeServer, error)
  • func (o *OnDemandProbeServer) OnMessage(c *shttp.WSAsyncClient, msg shttp.WSMessage)
  • func (o *OnDemandProbeServer) OnNodeDeleted(n *graph.Node)
  • func (o *OnDemandProbeServer) Start() error
  • func (o *OnDemandProbeServer) Stop()

Types

type OnDemandProbeServer

type OnDemandProbeServer struct {
	sync.RWMutex
	graph.DefaultGraphListener
	shttp.DefaultWSClientEventHandler
	Graph             *graph.Graph
	Probes            *probes.FlowProbeBundle
	WSAsyncClientPool *shttp.WSAsyncClientPool
	// contains filtered or unexported fields
}

OnDemandProbeServer describes an ondemand probe server based on websocket

func NewOnDemandProbeServer

func NewOnDemandProbeServer(fb *probes.FlowProbeBundle, g *graph.Graph, wspool *shttp.WSAsyncClientPool) (*OnDemandProbeServer, error)

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

func (*OnDemandProbeServer) OnMessage

func (o *OnDemandProbeServer) OnMessage(c *shttp.WSAsyncClient, msg shttp.WSMessage)

OnMessage websocket message, valid message type are CaptureStart, CaptureStop

func (*OnDemandProbeServer) OnNodeDeleted

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

OnNodeDeleted graph event

func (*OnDemandProbeServer) Start

func (o *OnDemandProbeServer) Start() error

Start the probe

func (*OnDemandProbeServer) Stop

func (o *OnDemandProbeServer) Stop()

Stop the probe