Versions in this module Expand all Collapse all v0 v0.23.1 Apr 25, 2019 Changes in this version + const ACCEPT_TIME_OUT + const CLIENT + const HTTP_CONNECT + const HTTP_DELETE + const HTTP_GET + const HTTP_HEAD + const HTTP_OPTIONS + const HTTP_POST + const HTTP_PUT + const HTTP_TRACE + const MUX_CONN_CLOSE + const MUX_MSG_SEND_OK + const MUX_NEW_CONN + const MUX_NEW_CONN_Fail + const MUX_NEW_CONN_OK + const MUX_NEW_MSG + const MUX_PING + const MUX_PING_FLAG + const MUX_PING_RETURN + func NewBufNode(buf []byte, l int) *bufNode + func NewConn(connId int32, mux *Mux) *conn + func NewConnMap() *connMap + func NewQueue() *sliceEntry + func ReadLenBytes(buf []byte, r io.Reader) (int, error) + func WriteLenBytes(buf []byte, w io.Writer) (int, error) + type Element *bufNode + type Mux struct + IsClose bool + func NewMux(c net.Conn, connType string) *Mux + func (s *Mux) Accept() (net.Conn, error) + func (s *Mux) Addr() net.Addr + func (s *Mux) Close() error + func (s *Mux) NewConn() (*conn, error) + type PortConn struct + Conn net.Conn + func (pConn *PortConn) Close() error + func (pConn *PortConn) LocalAddr() net.Addr + func (pConn *PortConn) Read(b []byte) (n int, err error) + func (pConn *PortConn) RemoteAddr() net.Addr + func (pConn *PortConn) SetDeadline(t time.Time) error + func (pConn *PortConn) SetReadDeadline(t time.Time) error + func (pConn *PortConn) SetWriteDeadline(t time.Time) error + func (pConn *PortConn) Write(b []byte) (n int, err error) + type PortListener struct + func NewPortListener(connCh chan *PortConn, addr net.Addr) *PortListener + func (pListener *PortListener) Accept() (net.Conn, error) + func (pListener *PortListener) Addr() net.Addr + func (pListener *PortListener) Close() error + type PortMux struct + func NewPortMux(port int, managerHost string) *PortMux + func (pMux *PortMux) Close() error + func (pMux *PortMux) GetClientListener() net.Listener + func (pMux *PortMux) GetHttpListener() net.Listener + func (pMux *PortMux) GetHttpsListener() net.Listener + func (pMux *PortMux) GetManagerListener() net.Listener + func (pMux *PortMux) Start() error + type Queue interface + Clear func() bool + IsEmpty func() bool + Pop func() Element + Push func(e Element) + Size func() int
Go to main page