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 ConnectStat
  • func (c *ConnectStat) Add(info *LoginRecord)
  • func (c *ConnectStat) ConnCount() int64
  • func (c *ConnectStat) DecreaseConn()
  • func (c *ConnectStat) IncreaseConn()
  • func (c *ConnectStat) LoginCount() int64
  • func (c *ConnectStat) LoginRecords() map[facade.UID]*LoginRecord
  • func (c *ConnectStat) PrintInfo() string
  • func (c *ConnectStat) Remove(uid facade.UID)
• type LoginRecord
• 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 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
	ConnectStat *ConnectStat
	// 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 ConnectStat

type ConnectStat struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ConnectStat 连接统计

func (*ConnectStat) Add

func (c *ConnectStat) Add(info *LoginRecord)

func (*ConnectStat) ConnCount

func (c *ConnectStat) ConnCount() int64

func (*ConnectStat) DecreaseConn

func (c *ConnectStat) DecreaseConn()

func (*ConnectStat) IncreaseConn

func (c *ConnectStat) IncreaseConn()

func (*ConnectStat) LoginCount

func (c *ConnectStat) LoginCount() int64

func (*ConnectStat) LoginRecords

func (c *ConnectStat) LoginRecords() map[facade.UID]*LoginRecord

func (*ConnectStat) PrintInfo

func (c *ConnectStat) PrintInfo() string

func (*ConnectStat) Remove

func (c *ConnectStat) Remove(uid facade.UID)

type LoginRecord

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

LoginRecord 登录记录器

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 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