Documentation
¶
Index ¶
- type 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) OnStructMessage(c ws.Speaker, m *ws.StructMessage)
- func (o *OnDemandProbeClient) OnSwitchToMaster()
- func (o *OnDemandProbeClient) OnSwitchToSlave()
- 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 { 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 ws.StructSpeakerPool, subscriberPool ws.StructSpeakerPool, 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 ¶ 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) OnStructMessage ¶ added in v0.19.1
func (o *OnDemandProbeClient) OnStructMessage(c ws.Speaker, m *ws.StructMessage)
OnStructMessage event, valid message type : CaptureStartReply or CaptureStopReply message
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
Click to show internal directories.
Click to hide internal directories.