Versions in this module Expand all Collapse all v0 v0.25.0 Sep 12, 2019 Changes in this version type FlowSubscriberEndpoint + func (fs *FlowSubscriberEndpoint) OnConnected(c ws.Speaker) + func (fs *FlowSubscriberEndpoint) OnDisconnected(c ws.Speaker) + func (fs *FlowSubscriberEndpoint) OnMessage(c ws.Speaker, m ws.Message) v0.24.0 Jul 16, 2019 Changes in this version + const FlowBulkInsertDeadlineDefault + const FlowBulkInsertDefault + const FlowBulkMaxDelayDefault + type FlowServer struct + func NewFlowServer(s *shttp.Server, g *graph.Graph, store storage.Storage, ...) (*FlowServer, error) + func (s *FlowServer) Start() + func (s *FlowServer) Stop() + type FlowServerConn interface + Serve func(ch chan *flow.Flow, quit chan struct{}, wg *sync.WaitGroup) + type FlowServerUDPConn struct + func NewFlowServerUDPConn(addr string, port int) (*FlowServerUDPConn, error) + func (c *FlowServerUDPConn) Serve(ch chan *flow.Flow, quit chan struct{}, wg *sync.WaitGroup) + type FlowServerWebSocketConn struct + func NewFlowServerWebSocketConn(server *shttp.Server, auth shttp.AuthenticationBackend) (*FlowServerWebSocketConn, error) + func (c *FlowServerWebSocketConn) OnMessage(client ws.Speaker, m ws.Message) + func (c *FlowServerWebSocketConn) Serve(ch chan *flow.Flow, quit chan struct{}, wg *sync.WaitGroup) + type FlowSubscriberEndpoint struct + func NewFlowSubscriberEndpoint(pool ws.StructSpeakerPool) *FlowSubscriberEndpoint + func (fs *FlowSubscriberEndpoint) SendFlows(flows []*flow.Flow)
Go to main page