Versions in this module Expand all Collapse all v0 v0.2.2 Oct 26, 2021 Changes in this version + const MaxMessageSize + var ErrServerClosed = errors.New("Server closed") + func Encode(pack MessagePack) (bytes.Buffer, error) + func StreamConn(stream grpc.Stream) *common.Conn + type Conn struct + Decode common.Decoder + Encode common.Encoder + InMsg proto.Message + OutMsg proto.Message + Stream *websocket.Conn + WriteLock *sync.Mutex + func WebSocketConn(stream *websocket.Conn) *Conn + func (c *Conn) Close() error + func (c *Conn) LocalAddr() net.Addr + func (c *Conn) Read(p []byte) (n int, err error) + func (c *Conn) RemoteAddr() net.Addr + func (c *Conn) SetDeadline(time.Time) error + func (c *Conn) SetReadDeadline(time.Time) error + func (c *Conn) SetWriteDeadline(time.Time) error + func (c *Conn) Write(p []byte) (int, error) + type GrpcServer server + func NewGrpcServer(opts ...Options) *GrpcServer + func (s *GrpcServer) Serve(list net.Listener) error + func (s *GrpcServer) Stream(stream pbx.Unitdb_StreamServer) error + type Handler func(c net.Conn) + type HttpServer server + func NewHttpServer(opts ...Options) *HttpServer + func (s *HttpServer) HandleFunc(w http.ResponseWriter, r *http.Request) + func (s *HttpServer) Serve(list net.Listener) error + type MessagePack interface + FromBinary func(fh utp.FixedHeader, data []byte) + Info func() utp.Info + ToBinary func() (bytes.Buffer, error) + Type func() utp.MessageType + func Read(r io.Reader) (MessagePack, error) + type Options interface + func WithDefaultOptions() Options + func WithTLSConfig(t *tls.Config) Options + type Proto int + const UNITQL + const UTP + type Server interface + Serve func(net.Listener) error + type TcpServer server + func NewTcpServer(opts ...Options) *TcpServer + func (s *TcpServer) Serve(list net.Listener) error v0.2.2-alpha Oct 26, 2021
Go to main page