client

Documentation

Index

• type OnDemandProbeClient
  • func NewOnDemandProbeClient(g *graph.Graph, ch *api.CaptureAPIHandler, w *shttp.WSServer, ...) *OnDemandProbeClient
  • func (o *OnDemandProbeClient) OnEdgeAdded(e *graph.Edge)
  • func (o *OnDemandProbeClient) OnMessage(c *shttp.WSClient, m shttp.WSMessage)
  • func (o *OnDemandProbeClient) OnNodeAdded(n *graph.Node)
  • func (o *OnDemandProbeClient) OnNodeUpdated(n *graph.Node)
  • func (o *OnDemandProbeClient) OnStartAsMaster()
  • func (o *OnDemandProbeClient) OnStartAsSlave()
  • func (o *OnDemandProbeClient) OnSwitchToMaster()
  • func (o *OnDemandProbeClient) OnSwitchToSlave()
  • func (o *OnDemandProbeClient) Start()
  • func (o *OnDemandProbeClient) Stop()

Types

type OnDemandProbeClient

type OnDemandProbeClient struct {
	sync.RWMutex
	shttp.DefaultWSServerEventHandler
	graph.DefaultGraphListener
	// contains filtered or unexported fields
}

OnDemandProbeClient describes an ondemand probe client based on a websocket

func NewOnDemandProbeClient

func NewOnDemandProbeClient(g *graph.Graph, ch *api.CaptureAPIHandler, w *shttp.WSServer, etcdClient *etcd.EtcdClient) *OnDemandProbeClient

NewOnDemandProbeClient creates a new ondemand probe client based on Capture API, graph and websocket

func (*OnDemandProbeClient) OnEdgeAdded

func (o *OnDemandProbeClient) OnEdgeAdded(e *graph.Edge)

OnEdgeAdded event

func (*OnDemandProbeClient) OnMessage

func (o *OnDemandProbeClient) OnMessage(c *shttp.WSClient, m shttp.WSMessage)

OnMessage event, valid message type : CaptureStartReply or CaptureStopReply message

func (*OnDemandProbeClient) OnNodeAdded

func (o *OnDemandProbeClient) OnNodeAdded(n *graph.Node)

OnNodeAdded event

func (*OnDemandProbeClient) OnNodeUpdated

func (o *OnDemandProbeClient) OnNodeUpdated(n *graph.Node)

OnNodeUpdated event

func (*OnDemandProbeClient) OnStartAsMaster

func (o *OnDemandProbeClient) OnStartAsMaster()

OnStartAsMaster event

func (*OnDemandProbeClient) OnStartAsSlave

func (o *OnDemandProbeClient) OnStartAsSlave()

OnStartAsSlave event

func (*OnDemandProbeClient) OnSwitchToMaster

func (o *OnDemandProbeClient) OnSwitchToMaster()

OnSwitchToMaster event

func (*OnDemandProbeClient) OnSwitchToSlave

func (o *OnDemandProbeClient) OnSwitchToSlave()

OnSwitchToSlave event

func (*OnDemandProbeClient) Start

func (o *OnDemandProbeClient) Start()

Start the probe

func (*OnDemandProbeClient) Stop

func (o *OnDemandProbeClient) Stop()

Stop the probe