agent

Documentation

Index

• func NewFlowProbeBundle(tb *probe.Bundle, g *graph.Graph, fta *flow.TableAllocator) *probe.Bundle
• func NewTopologyProbe(name string, ctx tp.Context, bundle *probe.Bundle) (probe.Handler, error)
• func NewTopologyProbeBundle(g *graph.Graph, hostNode *graph.Node) (*probe.Bundle, error)
• type Agent
  • func NewAgent() (*Agent, error)
  • func (a *Agent) GetStatus() interface{}
  • func (a *Agent) Start()
  • func (a *Agent) Stop()
• type Status
  • func (v Status) MarshalEasyJSON(w *jwriter.Writer)
  • func (v Status) MarshalJSON() ([]byte, error)
  • func (v *Status) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (v *Status) UnmarshalJSON(data []byte) error

Functions

func NewFlowProbeBundle

func NewFlowProbeBundle(tb *probe.Bundle, g *graph.Graph, fta *flow.TableAllocator) *probe.Bundle

NewFlowProbeBundle returns a new bundle of flow probes

func NewTopologyProbe

func NewTopologyProbe(name string, ctx tp.Context, bundle *probe.Bundle) (probe.Handler, error)

NewTopologyProbe creates a new topology probe

func NewTopologyProbeBundle

func NewTopologyProbeBundle(g *graph.Graph, hostNode *graph.Node) (*probe.Bundle, error)

NewTopologyProbeBundle creates a new topology probe.Bundle based on the configuration

Types

type Agent

type Agent struct {
	ws.DefaultSpeakerEventHandler
	// contains filtered or unexported fields
}

Agent object started on each hosts/namespaces

func NewAgent

func NewAgent() (*Agent, error)

NewAgent instantiates a new Agent aiming to launch probes (topology and flow)

func (*Agent) GetStatus

func (a *Agent) GetStatus() interface{}

GetStatus returns the status of an agent

func (*Agent) Start

func (a *Agent) Start()

Start the agent services

func (*Agent) Stop

func (a *Agent) Stop()

Stop agent services

type Status

type Status struct {
	Clients        map[string]ws.ConnStatus
	Analyzers      map[string]pod.ConnStatus
	TopologyProbes map[string]interface{}
	FlowProbes     []string
}

Status agent object

Status describes the status of an agent

swagger:model AgentStatus easyjson:json

func (Status) MarshalEasyJSON

func (v Status) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (Status) MarshalJSON

func (v Status) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*Status) UnmarshalEasyJSON

func (v *Status) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Status) UnmarshalJSON

func (v *Status) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface