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 NewServerFromConfig() (*Server, error)
  • func (s *Server) AnalyzeFlows(flows []*flow.Flow)
  • func (s *Server) Flush()
  • func (s *Server) ListenAndServe()
  • func (s *Server) SetStorage(storage storage.Storage)
  • func (s *Server) SetStorageFromConfig()
  • 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 {
	HTTPServer          *shttp.Server
	GraphServer         *graph.Server
	AlertServer         *alert.Server
	FlowMappingPipeline *mappings.FlowMappingPipeline
	Storage             storage.Storage
	FlowTable           *flow.FlowTable

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

func (s *Server) Flush()

func (*Server) ListenAndServe

func (s *Server) ListenAndServe()

func (*Server) SetStorage

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

func (*Server) SetStorageFromConfig

func (s *Server) SetStorageFromConfig()

func (*Server) Stop

func (s *Server) Stop()