Documentation ¶
Index ¶
- type OnDemandProbeClient
- func (o *OnDemandProbeClient) InvokeCaptureFromConfig(ch *api.CaptureAPIHandler)
- 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OnDemandProbeClient ¶
type OnDemandProbeClient struct { sync.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) InvokeCaptureFromConfig ¶ added in v0.17.0
func (o *OnDemandProbeClient) InvokeCaptureFromConfig(ch *api.CaptureAPIHandler)
InvokeCaptureFromConfig invokes capture based on preconfigured selected SubGraph
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 ¶ added in v0.12.0
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 ¶ added in v0.12.0
func (o *OnDemandProbeClient) OnStartAsMaster()
OnStartAsMaster event
func (*OnDemandProbeClient) OnStartAsSlave ¶ added in v0.12.0
func (o *OnDemandProbeClient) OnStartAsSlave()
OnStartAsSlave event
func (*OnDemandProbeClient) OnSwitchToMaster ¶ added in v0.12.0
func (o *OnDemandProbeClient) OnSwitchToMaster()
OnSwitchToMaster event
func (*OnDemandProbeClient) OnSwitchToSlave ¶ added in v0.12.0
func (o *OnDemandProbeClient) OnSwitchToSlave()
OnSwitchToSlave event
func (*OnDemandProbeClient) OnWSStructMessage ¶ added in v0.17.0
func (o *OnDemandProbeClient) OnWSStructMessage(c shttp.WSSpeaker, m *shttp.WSStructMessage)
OnMessage event, valid message type : CaptureStartReply or CaptureStopReply message
Click to show internal directories.
Click to hide internal directories.