cherryConnector

Documentation

Index

• func CheckOrigin(_ *http.Request) bool
• func GetNetListener(address, certFile, keyFile string) (net.Listener, error)
• type Connector
  • func NewConnector(address, certFile, keyFile string) 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
  • func NewTCP(address string) *TCPConnector
  • func NewTCPLTS(address, certFile, keyFile string) *TCPConnector
  • func (t *TCPConnector) Name() string
  • func (t *TCPConnector) OnAfterInit()
  • func (t *TCPConnector) OnStart()
  • func (t *TCPConnector) OnStop()
• type TcpConn
  • func (t *TcpConn) GetNextMessage() (b []byte, err error)
• type WSConn
  • func NewWSConn(conn *websocket.Conn) (*WSConn, error)
  • 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
  • func NewWS(address string) *WSConnector
  • func NewWSLTS(address, certFile, keyFile string) *WSConnector
  • func (w *WSConnector) Name() string
  • func (w *WSConnector) OnAfterInit()
  • func (w *WSConnector) OnStart()
  • func (w *WSConnector) OnStop()
  • func (w *WSConnector) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (w *WSConnector) SetUpgrade(upgrade *websocket.Upgrader)

Functions

func CheckOrigin

func CheckOrigin(_ *http.Request) bool

CheckOrigin 请求检查函数 防止跨站请求伪造 true则不检查

func GetNetListener

func GetNetListener(address, certFile, keyFile string) (net.Listener, error)

GetNetListener 证书构造 net.Listener

Types

type Connector

type Connector struct {
	Address  string
	Listener net.Listener
	CertFile string
	KeyFile  string
	// contains filtered or unexported fields
}

func NewConnector

func NewConnector(address, certFile, keyFile string) Connector

func (*Connector) ConnectListeners

func (p *Connector) ConnectListeners() []cfacade.OnConnectListener

func (*Connector) ExecuteListener

func (p *Connector) ExecuteListener()

func (*Connector) GetConnChan

func (p *Connector) GetConnChan() chan cfacade.INetConn

func (*Connector) InChan

func (p *Connector) InChan(conn cfacade.INetConn)

func (*Connector) IsSetListener

func (p *Connector) IsSetListener() bool

func (*Connector) OnConnectListener

func (p *Connector) OnConnectListener(listener ...cfacade.OnConnectListener)

type TCPConnector

type TCPConnector struct {
	cfacade.Component
	Connector
	// contains filtered or unexported fields
}

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

type TcpConn struct {
	net.Conn
}

func (*TcpConn) GetNextMessage

func (t *TcpConn) GetNextMessage() (b []byte, err error)

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 NewWSConn

func NewWSConn(conn *websocket.Conn) (*WSConn, error)

NewWSConn return an initialized *WSConn

func (*WSConn) Close

func (c *WSConn) Close() error

func (*WSConn) GetNextMessage

func (c *WSConn) GetNextMessage() (b []byte, err error)

GetNextMessage reads the next message available in the stream

func (*WSConn) LocalAddr

func (c *WSConn) LocalAddr() net.Addr

func (*WSConn) Read

func (c *WSConn) Read(b []byte) (int, error)

func (*WSConn) RemoteAddr

func (c *WSConn) RemoteAddr() net.Addr

func (*WSConn) SetDeadline

func (c *WSConn) SetDeadline(t time.Time) error

func (*WSConn) SetReadDeadline

func (c *WSConn) SetReadDeadline(t time.Time) error

func (*WSConn) SetWriteDeadline

func (c *WSConn) SetWriteDeadline(t time.Time) error

func (*WSConn) Write

func (c *WSConn) Write(b []byte) (int, error)

type WSConnector

type WSConnector struct {
	cfacade.Component
	Connector
	// contains filtered or unexported fields
}

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)