cherryConnector

Documentation

Index

• func CheckOrigin(_ *http.Request) bool
• func GetNetListener(address, certFile, keyFile string) (net.Listener, error)
• type Component
  • func NewComponent(connector facade.IConnector) *Component
  • func (c *Component) Name() string
  • func (c *Component) OnAfterInit()
  • func (c *Component) OnConnect(listener ...facade.OnConnectListener)
  • func (c *Component) OnStart()
  • func (c *Component) OnStop()
• type TCPConnector
  • func NewTCP(address string) *TCPConnector
  • func NewTCPLTS(address, certFile, keyFile string) *TCPConnector
  • func (t *TCPConnector) OnConnect(listener ...cherryFacade.OnConnectListener)
  • 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 NewWebsocketLTS(address, certFile, keyFile string) *WSConnector
  • func (w *WSConnector) OnConnect(listener ...cherryFacade.OnConnectListener)
  • func (w *WSConnector) OnStart()
  • func (w *WSConnector) OnStop()
  • func (w *WSConnector) ServeHTTP(rw http.ResponseWriter, r *http.Request)

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 Component

type Component struct {
	facade.Component
	// contains filtered or unexported fields
}

Component (连接器组件适用于前端节点)

func NewComponent

func NewComponent(connector facade.IConnector) *Component

func (*Component) Name

func (c *Component) Name() string

func (*Component) OnAfterInit

func (c *Component) OnAfterInit()

func (*Component) OnConnect

func (c *Component) OnConnect(listener ...facade.OnConnectListener)

func (*Component) OnStart

func (c *Component) OnStart()

func (*Component) OnStop

func (c *Component) OnStop()

type TCPConnector

type TCPConnector struct {
	// contains filtered or unexported fields
}

func NewTCP

func NewTCP(address string) *TCPConnector

func NewTCPLTS

func NewTCPLTS(address, certFile, keyFile string) *TCPConnector

func (*TCPConnector) OnConnect

func (t *TCPConnector) OnConnect(listener ...cherryFacade.OnConnectListener)

func (*TCPConnector) OnStart

func (t *TCPConnector) OnStart()

func (*TCPConnector) OnStop

func (t *TCPConnector) OnStop()

OnStop stops the connector

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 {
	// contains filtered or unexported fields
}

func NewWS

func NewWS(address string) *WSConnector

func NewWebsocketLTS

func NewWebsocketLTS(address, certFile, keyFile string) *WSConnector

func (*WSConnector) OnConnect

func (w *WSConnector) OnConnect(listener ...cherryFacade.OnConnectListener)

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