analyzer

Documentation

Index

• type Client
  • func NewClient(addr string, port int) (*Client, error)
  • func (c *Client) AsyncFlowsUpdate(ft *flow.FlowTable, every time.Duration)
  • func (c *Client) SendFlow(f *flow.Flow) error
  • func (c *Client) SendFlows(flows []*flow.Flow)
• type Server
  • func NewServer(addr string, port int, router *mux.Router) (*Server, error)
  • func NewServerFromConfig(router *mux.Router) (*Server, error)
  • func (s *Server) AnalyzeFlows(flows []*flow.Flow)
  • func (s *Server) FlowSearch(w http.ResponseWriter, r *http.Request)
  • func (s *Server) ListenAndServe()
  • func (s *Server) RegisterRpcEndpoints()
  • func (s *Server) RegisterStaticEndpoints()
  • func (s *Server) SetStorage(st storage.Storage)
  • func (s *Server) Stop()

Types

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) AsyncFlowsUpdate

func (c *Client) AsyncFlowsUpdate(ft *flow.FlowTable, every time.Duration)

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 {
	Addr                string
	Port                int
	Stopping            bool
	Router              *mux.Router
	TopoServer          *topology.Server
	GraphServer         *graph.Server
	FlowMappingPipeline *mappings.FlowMappingPipeline
	Storage             storage.Storage
	FlowTable           *flow.FlowTable
	Conn                *net.UDPConn
}

func NewServer

func NewServer(addr string, port int, router *mux.Router) (*Server, error)

func NewServerFromConfig

func NewServerFromConfig(router *mux.Router) (*Server, error)

func (*Server) AnalyzeFlows

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

func (*Server) FlowSearch

func (s *Server) FlowSearch(w http.ResponseWriter, r *http.Request)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe()

func (*Server) RegisterRpcEndpoints

func (s *Server) RegisterRpcEndpoints()

func (*Server) RegisterStaticEndpoints

func (s *Server) RegisterStaticEndpoints()

func (*Server) SetStorage

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

func (*Server) Stop

func (s *Server) Stop()