client

Documentation

Index

• type OnDemandProbeClient
  • func NewOnDemandProbeClient(g *graph.Graph, ch *api.CaptureAPIHandler, agentPool shttp.WSStructSpeakerPool, ...) *OnDemandProbeClient
  • func (o *OnDemandProbeClient) OnEdgeAdded(e *graph.Edge)
  • func (o *OnDemandProbeClient) OnNodeAdded(n *graph.Node)
  • func (o *OnDemandProbeClient) OnNodeDeleted(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) OnWSStructMessage(c shttp.WSSpeaker, m *shttp.WSStructMessage)
  • func (o *OnDemandProbeClient) Start()
  • func (o *OnDemandProbeClient) Stop()

Types

type OnDemandProbeClient

type OnDemandProbeClient struct {
	common.RWMutex
	*etcd.MasterElector
	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, agentPool shttp.WSStructSpeakerPool, subscriberPool shttp.WSStructSpeakerPool, etcdClient *etcd.Client) *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 graph event

func (*OnDemandProbeClient) OnNodeAdded

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

OnNodeAdded graph event

func (*OnDemandProbeClient) OnNodeDeleted

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

OnNodeDeleted graph event

func (*OnDemandProbeClient) OnNodeUpdated

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

OnNodeUpdated graph 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) OnWSStructMessage

func (o *OnDemandProbeClient) OnWSStructMessage(c shttp.WSSpeaker, m *shttp.WSStructMessage)

OnWSStructMessage event, valid message type : CaptureStartReply or CaptureStopReply message

func (*OnDemandProbeClient) Start

func (o *OnDemandProbeClient) Start()

Start the probe

func (*OnDemandProbeClient) Stop

func (o *OnDemandProbeClient) Stop()

Stop the probe