ego

Jun 14, 2023

Changes in this version

+ func New() *server.Aggregator

Aug 25, 2022

Changes in this version

+ func NewAggregatorServer() *aggregator.Aggregator

+ func NewGRPCServer(addr string) *server.RPCServer

+ func NewHTTPServer(addr string) *server.HTTPServer

+ func NewWebsocketServer(addr string) *server.WebSocketServer

+ type ServerRunOptions struct

+ HttpAddr string

+ HttpTraceHeader string

+ RPCAddr string

+ WebSocketAddr string

Dec 11, 2020

Changes in this version

+ func HttpServer() *httpServer

+ func WebsocketServer() *websocketServer

+ type Handler func(message []byte)

+ type WebsocketConn struct

+ ID string

+ func (c *WebsocketConn) GetID() string

+ type WsServer interface

+ Broadcast func(message []byte, ignore *WebsocketConn)

+ GetConnection func(uuid string) *WebsocketConn

+ GetOnline func() int

+ IsRegist func(uuid string) int

+ Register func(conn *WebsocketConn, handler Handler)

+ Send func(message []byte, c *WebsocketConn)

+ Start func()

+ Unregister func(id string)

+ UpgradeConn func(w http.ResponseWriter, r *http.Request) (*WebsocketConn, error)