cherryConnector

Feb 28, 2023

Changes in this version

type Connector

+ func (p *Connector) GetListener(certFile, keyFile, address string) (net.Listener, error)

+ func (p *Connector) OnConnect(fn cfacade.OnConnectFunc)

+ func (p *Connector) Running() bool

+ func (p *Connector) Start()

+ func (p *Connector) Stop()

+ type Option func(*Options)

+ func WithCert(certFile, keyFile string) Option

+ func WithChanSize(size int) Option

+ type Options struct

type WSConnector

+ func (w *WSConnector) Start()

+ func (w *WSConnector) Stop()

Aug 22, 2022

Changes in this version

+ type Connector struct

+ Address string

+ CertFile string

+ KeyFile string

+ Listener net.Listener

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

Jul 20, 2022

Changes in this version

type TCPConnector

+ func (t *TCPConnector) Name() string

+ func (t *TCPConnector) OnAfterInit()

+ func (w *TCPConnector) GetConnChan() chan cfacade.INetConn

+ func (w *TCPConnector) IsSetListener() bool

+ func (w *TCPConnector) OnConnectListener(listener ...cfacade.OnConnectListener)

type WSConnector

+ func NewWSLTS(address, certFile, keyFile string) *WSConnector

+ func (w *WSConnector) GetConnChan() chan cfacade.INetConn

+ func (w *WSConnector) IsSetListener() bool

+ func (w *WSConnector) Name() string

+ func (w *WSConnector) OnAfterInit()

+ func (w *WSConnector) OnConnectListener(listener ...cfacade.OnConnectListener)

+ func (w *WSConnector) SetUpgrade(upgrade *websocket.Upgrader)

Mar 24, 2022

Changes in this version

+ type TcpConn struct

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

+ type WSConn struct

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

Jul 24, 2021

Changes in this version

type Component

+ func NewComponent(connector facade.IConnector) *Component

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

+ func (c *Component) OnStart()

Jul 8, 2021

Changes in this version

+ var DefaultHeartbeat = 60 * time.Second

+ type Component struct

+ ConnectStat *ConnectStat

+ func NewComponentWithOpt(opts cherryAgent.Options, connector facade.IConnector) *Component

+ func NewTCPComponent(address string) *Component

+ func NewWSComponent(address string) *Component

+ func (c *Component) AddPacketHandle(typ cherryPacket.Type, listener cherryAgent.PacketListener)

+ func (c *Component) Init()

+ func (c *Component) Name() string

+ func (c *Component) OnAfterInit()

+ func (c *Component) OnStop()

+ type ConnectStat struct

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

+ func NewTCP(address string) *TCPConnector

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

+ func (t *TCPConnector) OnStart()

+ func (t *TCPConnector) OnStop()

+ type WSConnector struct

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

Feb 3, 2021

Changes in this version

+ func CheckOrigin(_ *http.Request) bool

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

+ type BlackListFn func(list []string)

+ type CheckClientFn func(typ string, version string) bool

+ type Connection struct

+ func (c *Connection) Add(info *LoginRecord)

+ func (c *Connection) DecreaseConn()

+ func (c *Connection) IncreaseConn()

+ func (c *Connection) List() (connCount int32, loginCount int32, ...)

+ func (c *Connection) Remove(uid cherryInterfaces.UID)

+ type LoginRecord struct

+ type PomeloComponent struct

+ func NewPomelo() *PomeloComponent

+ func NewPomeloWithOpts(opts PomeloComponentOptions) *PomeloComponent

+ func (p *PomeloComponent) AfterInit()

+ func (p *PomeloComponent) Init()

+ func (p *PomeloComponent) Name() string

+ func (p *PomeloComponent) Stop()

+ type PomeloComponentOptions struct

+ BlackList []string

+ BlackListFunc BlackListFn

+ CheckClient CheckClientFn

+ ConnectListener cherryInterfaces.IConnectListener

+ Connector cherryInterfaces.IConnector

+ DataCompression bool

+ DisconnectOnTimeout bool

+ ForwardMessage bool

+ Heartbeat int

+ PacketDecode cherryInterfaces.PacketDecoder

+ PacketEncode cherryInterfaces.PacketEncoder

+ Serializer cherryInterfaces.ISerializer

+ SessionOnClosed cherryInterfaces.SessionListener

+ SessionOnError cherryInterfaces.SessionListener

+ UseCrypto bool

+ UseDict bool

+ UseHostFilter bool

+ UseProtobuf bool

+ type SimpleComponent struct

+ func (t *SimpleComponent) AfterInit()

+ func (t *SimpleComponent) Init()

+ func (t *SimpleComponent) Name() string

+ type SimpleComponentOptions struct

+ Connector cherryInterfaces.IConnector

+ Decode cherryInterfaces.PacketDecoder

+ Encode cherryInterfaces.PacketEncoder

+ ForwardMessage bool

+ Heartbeat int

+ Serializer cherryInterfaces.ISerializer

+ type TCPConnector struct

+ func NewTCPConnector(address string) *TCPConnector

+ func NewTCPConnectorLTS(address, certFile, keyFile string) *TCPConnector

+ func (t *TCPConnector) OnConnect(listener cherryInterfaces.IConnectListener)

+ func (t *TCPConnector) Start()

+ func (t *TCPConnector) Stop()

+ type WebSocketConnector struct

+ func NewWSConnectorLTS(address, certFile, keyFile string) *WebSocketConnector

+ func NewWebSocketConnector(address string) *WebSocketConnector

+ func (w *WebSocketConnector) OnConnect(listener cherryInterfaces.IConnectListener)

+ func (w *WebSocketConnector) ServeHTTP(rw http.ResponseWriter, r *http.Request)

+ func (w *WebSocketConnector) Start()

+ func (w *WebSocketConnector) Stop()