Documentation
¶
Index ¶
- func NewAnalyzerWSStructClientPool(authOptions *shttp.AuthenticationOpts) (*shttp.WSStructClientPool, error)
- func NewTopologyProbeBundleFromConfig(g *graph.Graph, n *graph.Node) (*probe.ProbeBundle, error)
- type Agent
- type AgentStatus
- type AnalyzerConnStatus
- type CPUInfo
- type TopologyForwarder
- func (t *TopologyForwarder) GetMaster() shttp.WSSpeaker
- 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 shttp.WSSpeaker)
- 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 NewAnalyzerWSStructClientPool ¶ added in v0.18.0
func NewAnalyzerWSStructClientPool(authOptions *shttp.AuthenticationOpts) (*shttp.WSStructClientPool, error)
NewAnalyzerWSStructClientPool creates a new http WebSocket client Pool with authentification
Types ¶
type Agent ¶
type Agent struct {
shttp.DefaultWSSpeakerEventHandler
// 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 AgentStatus ¶ added in v0.16.0
type AgentStatus struct {
Clients map[string]shttp.WSConnStatus
Analyzers map[string]AnalyzerConnStatus
TopologyProbes []string
FlowProbes []string
}
AgentStatus represents the status of an agent
type AnalyzerConnStatus ¶ added in v0.16.0
type AnalyzerConnStatus struct {
shttp.WSConnStatus
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 TopologyForwarder ¶ added in v0.16.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.16.0
func NewTopologyForwarder(host string, g *graph.Graph, pool shttp.WSStructSpeakerPool) *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.16.0
func NewTopologyForwarderFromConfig(g *graph.Graph, pool shttp.WSStructSpeakerPool) *TopologyForwarder
NewTopologyForwarderFromConfig creates a TopologyForwarder from configuration
func (*TopologyForwarder) GetMaster ¶ added in v0.16.0
func (t *TopologyForwarder) GetMaster() shttp.WSSpeaker
GetMaster returns the current analyzer the agent is sending its events to
func (*TopologyForwarder) OnEdgeAdded ¶ added in v0.16.0
func (t *TopologyForwarder) OnEdgeAdded(e *graph.Edge)
OnEdgeAdded graph edge added event. Implements the GraphEventListener interface.
func (*TopologyForwarder) OnEdgeDeleted ¶ added in v0.16.0
func (t *TopologyForwarder) OnEdgeDeleted(e *graph.Edge)
OnEdgeDeleted graph edge deleted event. Implements the GraphEventListener interface.
func (*TopologyForwarder) OnEdgeUpdated ¶ added in v0.16.0
func (t *TopologyForwarder) OnEdgeUpdated(e *graph.Edge)
OnEdgeUpdated graph edge updated event. Implements the GraphEventListener interface.
func (*TopologyForwarder) OnNewMaster ¶ added in v0.16.0
func (t *TopologyForwarder) OnNewMaster(c shttp.WSSpeaker)
OnNewMaster is called by the master election mechanism when a new master is elected. In such case a "Re-sync" is triggerd in order to be in sync with the new master.
func (*TopologyForwarder) OnNodeAdded ¶ added in v0.16.0
func (t *TopologyForwarder) OnNodeAdded(n *graph.Node)
OnNodeAdded graph node added event. Implements the GraphEventListener interface.
func (*TopologyForwarder) OnNodeDeleted ¶ added in v0.16.0
func (t *TopologyForwarder) OnNodeDeleted(n *graph.Node)
OnNodeDeleted graph node deleted event. Implements the GraphEventListener interface.
func (*TopologyForwarder) OnNodeUpdated ¶ added in v0.16.0
func (t *TopologyForwarder) OnNodeUpdated(n *graph.Node)
OnNodeUpdated graph node updated event. Implements the GraphEventListener interface.
Source Files
¶
- agent.go
- host.go
- host_linux.go
- probes.go
- topology_forwarder.go