analyzer

Documentation

Index

• Variables
• func NewTopologyProbeBundleFromConfig(g *graph.Graph) (*probe.ProbeBundle, error)
• type AgentAnalyzerClientConn
  • func NewAgentAnalyzerClientConn(addr *net.UDPAddr) (a *AgentAnalyzerClientConn, err error)
  • func (a *AgentAnalyzerClientConn) Close()
  • func (a *AgentAnalyzerClientConn) Write(b []byte) (int, error)
• type AgentAnalyzerConnectionType
• type AgentAnalyzerServerConn
  • func NewAgentAnalyzerServerConn(addr *net.UDPAddr) (a *AgentAnalyzerServerConn, err error)
  • func (a *AgentAnalyzerServerConn) Accept() (*AgentAnalyzerServerConn, error)
  • func (a *AgentAnalyzerServerConn) Cleanup()
  • func (a *AgentAnalyzerServerConn) Close()
  • func (a *AgentAnalyzerServerConn) Mode() AgentAnalyzerConnectionType
  • func (a *AgentAnalyzerServerConn) Read(data []byte) (int, error)
  • func (a *AgentAnalyzerServerConn) SetDeadline(t time.Time)
  • func (a *AgentAnalyzerServerConn) Timeout(err error) bool
• type Client
  • func NewClient(addr string, port int) (*Client, error)
  • func (c *Client) SendFlow(f *flow.Flow) error
  • func (c *Client) SendFlows(flows []*flow.Flow)
• type Server
  • func NewServerFromConfig() (*Server, error)
  • func (s *Server) AnalyzeFlows(flows []*flow.Flow)
  • func (s *Server) ListenAndServe()
  • func (s *Server) SetStorage(storage storage.Storage)
  • func (s *Server) Stop()

Variables

var ErrAgentAnalyzerUDPAcceptNotSupported = errors.New("UDP connection is datagram based (not connected), accept() not supported")

Functions

func NewTopologyProbeBundleFromConfig

func NewTopologyProbeBundleFromConfig(g *graph.Graph) (*probe.ProbeBundle, error)

Types

type AgentAnalyzerClientConn

type AgentAnalyzerClientConn struct {
	// contains filtered or unexported fields
}

func NewAgentAnalyzerClientConn

func NewAgentAnalyzerClientConn(addr *net.UDPAddr) (a *AgentAnalyzerClientConn, err error)

func (*AgentAnalyzerClientConn) Close

func (a *AgentAnalyzerClientConn) Close()

func (*AgentAnalyzerClientConn) Write

func (a *AgentAnalyzerClientConn) Write(b []byte) (int, error)

type AgentAnalyzerConnectionType

type AgentAnalyzerConnectionType int

const (
	UDP AgentAnalyzerConnectionType = 1 + iota
	TLS
)

type AgentAnalyzerServerConn

type AgentAnalyzerServerConn struct {
	// contains filtered or unexported fields
}

func NewAgentAnalyzerServerConn

func NewAgentAnalyzerServerConn(addr *net.UDPAddr) (a *AgentAnalyzerServerConn, err error)

func (*AgentAnalyzerServerConn) Accept

func (a *AgentAnalyzerServerConn) Accept() (*AgentAnalyzerServerConn, error)

func (*AgentAnalyzerServerConn) Cleanup

func (a *AgentAnalyzerServerConn) Cleanup()

func (*AgentAnalyzerServerConn) Close

func (a *AgentAnalyzerServerConn) Close()

func (*AgentAnalyzerServerConn) Mode

func (a *AgentAnalyzerServerConn) Mode() AgentAnalyzerConnectionType

func (*AgentAnalyzerServerConn) Read

func (a *AgentAnalyzerServerConn) Read(data []byte) (int, error)

func (*AgentAnalyzerServerConn) SetDeadline

func (a *AgentAnalyzerServerConn) SetDeadline(t time.Time)

func (*AgentAnalyzerServerConn) Timeout

func (a *AgentAnalyzerServerConn) Timeout(err error) bool

type Client

type Client struct {
	Addr string
	Port int
	// contains filtered or unexported fields
}

func NewClient

func NewClient(addr string, port int) (*Client, error)

func (*Client) SendFlow

func (c *Client) SendFlow(f *flow.Flow) error

func (*Client) SendFlows

func (c *Client) SendFlows(flows []*flow.Flow)

type Server

type Server struct {
	HTTPServer          *shttp.Server
	WSServer            *shttp.WSServer
	GraphServer         *graph.GraphServer
	AlertServer         *alert.AlertServer
	OnDemandClient      *ondemand.OnDemandProbeClient
	FlowMappingPipeline *mappings.FlowMappingPipeline
	ProbeBundle         *probe.ProbeBundle
	Storage             storage.Storage
	FlowTable           *flow.Table
	TableClient         *flow.TableClient

	EmbeddedEtcd *etcd.EmbeddedEtcd
	EtcdClient   *etcd.EtcdClient
	// contains filtered or unexported fields
}

func NewServerFromConfig

func NewServerFromConfig() (*Server, error)

func (*Server) AnalyzeFlows

func (s *Server) AnalyzeFlows(flows []*flow.Flow)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe()

func (*Server) SetStorage

func (s *Server) SetStorage(storage storage.Storage)

func (*Server) Stop

func (s *Server) Stop()