Documentation ¶
Index ¶
- type Client
- type Server
- 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
func (*Client) AsyncFlowsUpdate ¶
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 (*Server) AnalyzeFlows ¶
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 ¶
Click to show internal directories.
Click to hide internal directories.