agent

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 5, 2017 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateRootNode added in v0.8.0 

func CreateRootNode(g *graph.Graph) *graph.Node

func NewAnalyzerWSClientPool added in v0.10.0 

func NewAnalyzerWSClientPool() *shttp.WSAsyncClientPool

func NewTopologyProbeBundleFromConfig added in v0.8.0 

func NewTopologyProbeBundleFromConfig(g *graph.Graph, n *graph.Node, wspool *shttp.WSAsyncClientPool) (*probe.ProbeBundle, error)

Types

type Agent 

type Agent struct {
	shttp.DefaultWSClientEventHandler
	Graph               *graph.Graph
	WSAsyncClientPool   *shttp.WSAsyncClientPool
	WSServer            *shttp.WSServer
	GraphServer         *graph.GraphServer
	Root                *graph.Node
	TopologyProbeBundle *probe.ProbeBundle
	FlowProbeBundle     *fprobes.FlowProbeBundle
	FlowTableAllocator  *flow.TableAllocator
	FlowClientPool      *analyzer.FlowClientPool
	OnDemandProbeServer *ondemand.OnDemandProbeServer
	HTTPServer          *shttp.Server
	EtcdClient          *etcd.EtcdClient
	TIDMapper           *topology.TIDMapper
}

func NewAgent 

func NewAgent() *Agent

func (*Agent) Start 

func (a *Agent) Start()

func (*Agent) Stop 

func (a *Agent) Stop()

type TopologyForwarder added in v0.10.0 

type TopologyForwarder struct {
	shttp.DefaultWSClientEventHandler
	WSAsyncClientPool *shttp.WSAsyncClientPool
	Graph             *graph.Graph
	Host              string
	// contains filtered or unexported fields
}

TopologyForwarder forwards the topology to only one analyzer. Analyzers will forward messages between them in order to be synchronized. When switching from one analyzer to another one the agent will do a full re-sync because some messages could have been lost.

func NewTopologyForwarder added in v0.10.0 

func NewTopologyForwarder(host string, g *graph.Graph, wspool *shttp.WSAsyncClientPool) *TopologyForwarder

func NewTopologyForwarderFromConfig added in v0.10.0 

func NewTopologyForwarderFromConfig(g *graph.Graph, wspool *shttp.WSAsyncClientPool) *TopologyForwarder

func (*TopologyForwarder) OnConnected added in v0.10.0 

func (t *TopologyForwarder) OnConnected(c *shttp.WSAsyncClient)

func (*TopologyForwarder) OnDisconnected added in v0.10.0 

func (t *TopologyForwarder) OnDisconnected(c *shttp.WSAsyncClient)

func (*TopologyForwarder) OnEdgeAdded added in v0.10.0 

func (t *TopologyForwarder) OnEdgeAdded(e *graph.Edge)

func (*TopologyForwarder) OnEdgeDeleted added in v0.10.0 

func (t *TopologyForwarder) OnEdgeDeleted(e *graph.Edge)

func (*TopologyForwarder) OnEdgeUpdated added in v0.10.0 

func (t *TopologyForwarder) OnEdgeUpdated(e *graph.Edge)

func (*TopologyForwarder) OnNodeAdded added in v0.10.0 

func (t *TopologyForwarder) OnNodeAdded(n *graph.Node)

func (*TopologyForwarder) OnNodeDeleted added in v0.10.0 

func (t *TopologyForwarder) OnNodeDeleted(n *graph.Node)

func (*TopologyForwarder) OnNodeUpdated added in v0.10.0 

func (t *TopologyForwarder) OnNodeUpdated(n *graph.Node)

Source Files

  • agent.go
  • probes.go
  • topology_forwarder.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.