server

Documentation

Index

• Constants
• type FlowServer
  • func NewFlowServer(s *shttp.Server, g *graph.Graph, store storage.Storage, ...) (*FlowServer, error)
  • func (s *FlowServer) Start()
  • func (s *FlowServer) Stop()
• type FlowServerConn
• type FlowServerUDPConn
  • func NewFlowServerUDPConn(addr string, port int) (*FlowServerUDPConn, error)
  • func (c *FlowServerUDPConn) Serve(flowChan chan *flow.Flow, statsChan chan *flow.Stats, quit chan struct{}, ...)
• type FlowServerWebSocketConn
  • func NewFlowServerWebSocketConn(server *shttp.Server, auth shttp.AuthenticationBackend) (*FlowServerWebSocketConn, error)
  • func (c *FlowServerWebSocketConn) OnMessage(client ws.Speaker, m ws.Message)
  • func (c *FlowServerWebSocketConn) Serve(flowChan chan *flow.Flow, statsChan chan *flow.Stats, quit chan struct{}, ...)
• type FlowSubscriberEndpoint
  • func NewFlowSubscriberEndpoint(srv *ws.StructServer) *FlowSubscriberEndpoint
  • func (fs *FlowSubscriberEndpoint) OnConnected(c ws.Speaker) error
  • func (fs *FlowSubscriberEndpoint) OnDisconnected(c ws.Speaker)
  • func (fs *FlowSubscriberEndpoint) OnMessage(c ws.Speaker, m ws.Message)
  • func (fs *FlowSubscriberEndpoint) SendFlows(flows []*flow.Flow)
  • func (fs *FlowSubscriberEndpoint) SendStats(stats *flow.Stats)

Constants

const (
	// FlowBulkInsertDefault maximum number of flows aggregated between two data store inserts
	FlowBulkInsertDefault int = 100

	// FlowBulkInsertDeadlineDefault deadline of each bulk insert in second
	FlowBulkInsertDeadlineDefault int = 5

	// FlowBulkMaxDelayDefault delay between two bulk
	FlowBulkMaxDelayDefault int = 5
)

Types

type FlowServer

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

FlowServer describes a flow server

func NewFlowServer

func NewFlowServer(s *shttp.Server, g *graph.Graph, store storage.Storage, endpoint *FlowSubscriberEndpoint, probe *probe.Bundle, auth shttp.AuthenticationBackend) (*FlowServer, error)

NewFlowServer creates a new flow server listening at address/port, based on configuration

func (*FlowServer) Start

func (s *FlowServer) Start()

Start the flow server

func (*FlowServer) Stop

func (s *FlowServer) Stop()

Stop the server

type FlowServerConn

type FlowServerConn interface {
	Serve(flowChan chan *flow.Flow, statsChan chan *flow.Stats, quit chan struct{}, wg *sync.WaitGroup)
}

FlowServerConn describes a flow server connection

type FlowServerUDPConn

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

FlowServerUDPConn describes a UDP flow server connection

func NewFlowServerUDPConn

func NewFlowServerUDPConn(addr string, port int) (*FlowServerUDPConn, error)

NewFlowServerUDPConn return a new UDP flow server

func (*FlowServerUDPConn) Serve

func (c *FlowServerUDPConn) Serve(flowChan chan *flow.Flow, statsChan chan *flow.Stats, quit chan struct{}, wg *sync.WaitGroup)

Serve UDP connections

type FlowServerWebSocketConn

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

FlowServerWebSocketConn describes a WebSocket flow server connection

func NewFlowServerWebSocketConn

func NewFlowServerWebSocketConn(server *shttp.Server, auth shttp.AuthenticationBackend) (*FlowServerWebSocketConn, error)

NewFlowServerWebSocketConn returns a new WebSocket flow server

func (*FlowServerWebSocketConn) OnMessage

func (c *FlowServerWebSocketConn) OnMessage(client ws.Speaker, m ws.Message)

OnMessage event

func (*FlowServerWebSocketConn) Serve

func (c *FlowServerWebSocketConn) Serve(flowChan chan *flow.Flow, statsChan chan *flow.Stats, quit chan struct{}, wg *sync.WaitGroup)

Serve starts a WebSocket flow server

type FlowSubscriberEndpoint

type FlowSubscriberEndpoint struct {
	insanelock.RWMutex
	// contains filtered or unexported fields
}

FlowSubscriberEndpoint sends all the flows to its subscribers.

func NewFlowSubscriberEndpoint

func NewFlowSubscriberEndpoint(srv *ws.StructServer) *FlowSubscriberEndpoint

NewFlowSubscriberEndpoint returns a new server to be used by external flow subscribers

func (*FlowSubscriberEndpoint) OnConnected

func (fs *FlowSubscriberEndpoint) OnConnected(c ws.Speaker) error

OnConnected Server interface

func (*FlowSubscriberEndpoint) OnDisconnected

func (fs *FlowSubscriberEndpoint) OnDisconnected(c ws.Speaker)

OnDisconnected Server interface

func (*FlowSubscriberEndpoint) OnMessage

func (fs *FlowSubscriberEndpoint) OnMessage(c ws.Speaker, m ws.Message)

OnMessage Server interface

func (*FlowSubscriberEndpoint) SendFlows

func (fs *FlowSubscriberEndpoint) SendFlows(flows []*flow.Flow)

SendFlows sends flow to the subscribers

func (*FlowSubscriberEndpoint) SendStats

func (fs *FlowSubscriberEndpoint) SendStats(stats *flow.Stats)

SendStats send stats to subscribers