 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
      Index ¶
- func NewAnalyzerStructClientPool(authOptions *shttp.AuthenticationOpts) (*ws.StructClientPool, error)
- func NewTopologyProbeBundleFromConfig(g *graph.Graph, hostNode *graph.Node) (*probe.Bundle, error)
- type Agent
- type AnalyzerConnStatus
- type CPUInfo
- type Status
- type TopologyForwarder
- func (t *TopologyForwarder) GetMaster() ws.Speaker
- func (t *TopologyForwarder) OnEdgeAdded(e *graph.Edge)
- func (t *TopologyForwarder) OnEdgeDeleted(e *graph.Edge)
- func (t *TopologyForwarder) OnEdgeUpdated(e *graph.Edge)
- func (t *TopologyForwarder) OnNewMaster(c ws.Speaker)
- func (t *TopologyForwarder) OnNodeAdded(n *graph.Node)
- func (t *TopologyForwarder) OnNodeDeleted(n *graph.Node)
- func (t *TopologyForwarder) OnNodeUpdated(n *graph.Node)
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAnalyzerStructClientPool ¶ added in v0.19.1
func NewAnalyzerStructClientPool(authOptions *shttp.AuthenticationOpts) (*ws.StructClientPool, error)
NewAnalyzerStructClientPool creates a new http WebSocket client Pool with authentification
Types ¶
type Agent ¶
type Agent struct {
	ws.DefaultSpeakerEventHandler
	// contains filtered or unexported fields
}
    Agent object started on each hosts/namespaces
func NewAgent ¶
NewAgent instanciates a new Agent aiming to launch probes (topology and flow)
type AnalyzerConnStatus ¶ added in v0.13.0
type AnalyzerConnStatus struct {
	ws.ConnStatus
	IsMaster bool
}
    AnalyzerConnStatus represents the status of a connection to an analyzer
type CPUInfo ¶ added in v0.16.0
type CPUInfo struct {
	CPU        int64
	VendorID   string `json:"VendorID,omitempty"`
	Family     string `json:"Family,omitempty"`
	Model      string `json:"Model,omitempty"`
	Stepping   int64  `json:"Stepping,omitempty"`
	PhysicalID string `json:"PhysicalID,omitempty"`
	CoreID     string `json:"CoreID,omitempty"`
	Cores      int64  `json:"Cores,omitempty"`
	ModelName  string `json:"ModelName,omitempty"`
	Mhz        int64  `json:"Mhz,omitempty"`
	CacheSize  int64  `json:"CacheSize,omitempty"`
	Microcode  string `json:"Microcode,omitempty"`
}
    CPUInfo defines host information
type Status ¶ added in v0.20.1
type Status struct {
	Clients        map[string]ws.ConnStatus
	Analyzers      map[string]AnalyzerConnStatus
	TopologyProbes []string
	FlowProbes     []string
}
    Status represents the status of an agent
type TopologyForwarder ¶ added in v0.12.0
type TopologyForwarder struct {
	// contains filtered or unexported fields
}
    TopologyForwarder forwards the topology to only one master server. When switching from one analyzer to another one the agent does a full re-sync since some messages could have been lost.
func NewTopologyForwarder ¶ added in v0.12.0
func NewTopologyForwarder(host string, g *graph.Graph, pool ws.StructSpeakerPool) *TopologyForwarder
NewTopologyForwarder returns a new Graph forwarder which forwards event of the given graph to the given WebSocket JSON speakers.
func NewTopologyForwarderFromConfig ¶ added in v0.12.0
func NewTopologyForwarderFromConfig(g *graph.Graph, pool ws.StructSpeakerPool) *TopologyForwarder
NewTopologyForwarderFromConfig creates a TopologyForwarder from configuration
func (*TopologyForwarder) GetMaster ¶ added in v0.13.0
func (t *TopologyForwarder) GetMaster() ws.Speaker
GetMaster returns the current analyzer the agent is sending its events to
func (*TopologyForwarder) OnEdgeAdded ¶ added in v0.12.0
func (t *TopologyForwarder) OnEdgeAdded(e *graph.Edge)
OnEdgeAdded graph edge added event. Implements the EventListener interface.
func (*TopologyForwarder) OnEdgeDeleted ¶ added in v0.12.0
func (t *TopologyForwarder) OnEdgeDeleted(e *graph.Edge)
OnEdgeDeleted graph edge deleted event. Implements the EventListener interface.
func (*TopologyForwarder) OnEdgeUpdated ¶ added in v0.12.0
func (t *TopologyForwarder) OnEdgeUpdated(e *graph.Edge)
OnEdgeUpdated graph edge updated event. Implements the EventListener interface.
func (*TopologyForwarder) OnNewMaster ¶ added in v0.13.0
func (t *TopologyForwarder) OnNewMaster(c ws.Speaker)
OnNewMaster is called by the master election mechanism when a new master is elected. In such case a "Re-sync" is triggered in order to be in sync with the new master.
func (*TopologyForwarder) OnNodeAdded ¶ added in v0.12.0
func (t *TopologyForwarder) OnNodeAdded(n *graph.Node)
OnNodeAdded graph node added event. Implements the EventListener interface.
func (*TopologyForwarder) OnNodeDeleted ¶ added in v0.12.0
func (t *TopologyForwarder) OnNodeDeleted(n *graph.Node)
OnNodeDeleted graph node deleted event. Implements the EventListener interface.
func (*TopologyForwarder) OnNodeUpdated ¶ added in v0.12.0
func (t *TopologyForwarder) OnNodeUpdated(n *graph.Node)
OnNodeUpdated graph node updated event. Implements the EventListener interface.
       Source Files
      ¶
      Source Files
      ¶
    
- agent.go
- host.go
- host_linux.go
- probes.go
- topology_forwarder.go