Documentation ¶
Index ¶
- func CheckOrigin(_ *http.Request) bool
- func GetNetListener(address, certFile, keyFile string) (net.Listener, error)
- type Connector
- func (p *Connector) ConnectListeners() []cfacade.OnConnectListener
- func (p *Connector) ExecuteListener()
- func (p *Connector) GetConnChan() chan cfacade.INetConn
- func (p *Connector) InChan(conn cfacade.INetConn)
- func (p *Connector) IsSetListener() bool
- func (p *Connector) OnConnectListener(listener ...cfacade.OnConnectListener)
- type TCPConnector
- type TcpConn
- type WSConn
- func (c *WSConn) Close() error
- func (c *WSConn) GetNextMessage() (b []byte, err error)
- func (c *WSConn) LocalAddr() net.Addr
- func (c *WSConn) Read(b []byte) (int, error)
- func (c *WSConn) RemoteAddr() net.Addr
- func (c *WSConn) SetDeadline(t time.Time) error
- func (c *WSConn) SetReadDeadline(t time.Time) error
- func (c *WSConn) SetWriteDeadline(t time.Time) error
- func (c *WSConn) Write(b []byte) (int, error)
- type WSConnector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Connector ¶
type Connector struct { Address string Listener net.Listener CertFile string KeyFile string // contains filtered or unexported fields }
func NewConnector ¶
func (*Connector) ConnectListeners ¶
func (p *Connector) ConnectListeners() []cfacade.OnConnectListener
func (*Connector) ExecuteListener ¶
func (p *Connector) ExecuteListener()
func (*Connector) GetConnChan ¶
func (*Connector) IsSetListener ¶
func (*Connector) OnConnectListener ¶
func (p *Connector) OnConnectListener(listener ...cfacade.OnConnectListener)
type TCPConnector ¶
func NewTCP ¶
func NewTCP(address string) *TCPConnector
func NewTCPLTS ¶
func NewTCPLTS(address, certFile, keyFile string) *TCPConnector
func (*TCPConnector) Name ¶
func (t *TCPConnector) Name() string
func (*TCPConnector) OnAfterInit ¶
func (t *TCPConnector) OnAfterInit()
func (*TCPConnector) OnStart ¶
func (t *TCPConnector) OnStart()
func (*TCPConnector) OnStop ¶
func (t *TCPConnector) OnStop()
type TcpConn ¶
func (*TcpConn) GetNextMessage ¶
type WSConn ¶
type WSConn struct {
// contains filtered or unexported fields
}
WSConn is an adapter to t.INetConn, which implements all t.INetConn interface base on *websocket.INetConn
func (*WSConn) GetNextMessage ¶
GetNextMessage reads the next message available in the stream
func (*WSConn) RemoteAddr ¶
type WSConnector ¶
func NewWS ¶
func NewWS(address string) *WSConnector
func NewWSLTS ¶
func NewWSLTS(address, certFile, keyFile string) *WSConnector
func (*WSConnector) Name ¶
func (w *WSConnector) Name() string
func (*WSConnector) OnAfterInit ¶
func (w *WSConnector) OnAfterInit()
func (*WSConnector) OnStart ¶
func (w *WSConnector) OnStart()
func (*WSConnector) OnStop ¶
func (w *WSConnector) OnStop()
func (*WSConnector) ServeHTTP ¶
func (w *WSConnector) ServeHTTP(rw http.ResponseWriter, r *http.Request)
ServerHTTP server.Handler
func (*WSConnector) SetUpgrade ¶
func (w *WSConnector) SetUpgrade(upgrade *websocket.Upgrader)
Click to show internal directories.
Click to hide internal directories.