getty

Jan 11, 2020

Changes in this version

+ const MaxWheelTimeSpan

Jul 27, 2019

Changes in this version

type EndPoint

+ ID func() EndPointID

+ type EndPointID = int32

type Session

+ SetTaskPool func(*TaskPool)

+ type TaskPool struct

+ func NewTaskPool(opts ...TaskPoolOption) *TaskPool

+ func (p *TaskPool) AddTask(t task)

+ func (p *TaskPool) Close()

+ func (p *TaskPool) IsClosed() bool

+ type TaskPoolOption func(*TaskPoolOptions)

+ func WithTaskPoolTaskPoolSize(size int) TaskPoolOption

+ func WithTaskPoolTaskQueueLength(length int) TaskPoolOption

+ func WithTaskPoolTaskQueueNumber(number int) TaskPoolOption

+ type TaskPoolOptions struct

Jun 8, 2019

Changes in this version

type ClientOption

+ func WithReconnectInterval(reconnectInterval int) ClientOption

type Session

+ SetTaskPoolSize func(int)

+ SetTaskQueueLength func(int)

Aug 7, 2018

Changes in this version

+ func GetTimeWheel() *gxtime.Wheel

Jul 6, 2018

Changes in this version

+ var ErrScheduleTimeout = fmt.Errorf("schedule error: timed out")

+ type Pool struct

+ func NewPool(size, queue, spawn int) *Pool

+ func (p *Pool) ScheduleTimeout(timeout time.Duration, task func()) error

Apr 24, 2018

Changes in this version

+ const CompressBestCompression

+ const CompressBestSpeed

+ const CompressHuffman

+ const CompressNone

+ const CompressSnappy

+ const CompressZip

+ const DATE

+ var EndPointType_name = map[int32]string

+ var EndPointType_value = map[string]int32

+ var ErrMsgTooLong = errors.New("Message Too Long")

+ var ErrNullPeerAddr = errors.New("peer address is nil")

type Client

+ func NewTCPClient(opts ...ClientOption) Client

+ func NewUDPClient(opts ...ClientOption) Client

+ func NewWSClient(opts ...ClientOption) Client

+ func NewWSSClient(opts ...ClientOption) Client

+ type ClientOption func(*ClientOptions)

+ func WithConnectionNumber(num int) ClientOption

+ func WithRootCertificateFile(cert string) ClientOption

+ func WithServerAddress(addr string) ClientOption

+ type ClientOptions struct

+ type CompressType int

+ type Connection interface

+ GetActive func() time.Time

+ ID func() uint32

+ LocalAddr func() string

+ RemoteAddr func() string

+ SetCompressType func(CompressType)

+ SetReadTimeout func(time.Duration)

+ SetWriteTimeout func(time.Duration)

+ UpdateActive func()

+ Write func(interface{}) (int, error)

+ type EndPoint interface

+ Close func()

+ EndPointType func() EndPointType

+ IsClosed func() bool

+ RunEventLoop func(newSession NewSessionCallback)

+ type EndPointType int32

+ const TCP_CLIENT

+ const TCP_SERVER

+ const UDP_CLIENT

+ const UDP_ENDPOINT

+ const WSS_CLIENT

+ const WSS_SERVER

+ const WS_CLIENT

+ const WS_SERVER

+ func (x EndPointType) String() string

type Server

+ func NewTCPServer(opts ...ServerOption) Server

+ func NewUDPPEndPoint(opts ...ServerOption) Server

+ func NewWSSServer(opts ...ServerOption) Server

+ func NewWSServer(opts ...ServerOption) Server

+ type ServerOption func(*ServerOptions)

+ func WithLocalAddress(addr string) ServerOption

+ func WithWebsocketServerCert(cert string) ServerOption

+ func WithWebsocketServerPath(path string) ServerOption

+ func WithWebsocketServerPrivateKey(key string) ServerOption

+ func WithWebsocketServerRootCert(cert string) ServerOption

+ type ServerOptions struct

type Session

+ EndPoint func() EndPoint

+ SetMaxMsgLen func(int)

+ SetReader func(Reader)

+ SetWriter func(Writer)

+ WriteBytesArray func(...[]byte) error

+ type UDPContext struct

+ PeerAddr *net.UDPAddr

+ Pkg interface{}

+ func (c UDPContext) String() string

Oct 1, 2016

Changes in this version

+ const GETTY_BUILD

+ const GETTY_MAJOR

+ const GETTY_MINOR

+ const Version

+ var ErrInvalidConnection = errors.New("connection has been closed.")

+ var ErrSessionBlocked = errors.New("Session full blocked")

+ var ErrSessionClosed = errors.New("Session Already Closed")

+ type Client struct

+ func NewClient(connNum int, connInterval time.Duration, serverAddr string) *Client

+ func (this *Client) Close()

+ func (this *Client) IsClosed() bool

+ func (this *Client) RunEventLoop(newSession NewSessionCallback)

+ type EventListener interface

+ OnClose func(*Session)

+ OnCron func(*Session)

+ OnError func(*Session, error)

+ OnMessage func(*Session, interface{})

+ OnOpen func(*Session) error

+ type NewSessionCallback func(*Session) error

+ type ReadWriter interface

+ type Reader interface

+ Read func(*Session, []byte) (interface{}, int, error)

+ type Server struct

+ func NewServer() *Server

+ func (this *Server) Accept(newSession NewSessionCallback) (*Session, error)

+ func (this *Server) Bind(network string, host string, port int) error

+ func (this *Server) Close()

+ func (this *Server) IsClosed() bool

+ func (this *Server) Listen(network string, addr string) error

+ func (this *Server) Listener() net.Listener

+ func (this *Server) RunEventloop(newSession NewSessionCallback)

+ type Session struct

+ func NewSession(conn net.Conn) *Session

+ func (this *Session) Close()

+ func (this *Session) Conn() net.Conn

+ func (this *Session) GetAttribute(key string) interface{}

+ func (this *Session) IsClosed() bool

+ func (this *Session) RemoveAttribute(key string)

+ func (this *Session) Reset()

+ func (this *Session) RunEventLoop()

+ func (this *Session) SetAttribute(key string, value interface{})

+ func (this *Session) SetConn(conn net.Conn)

+ func (this *Session) SetCronPeriod(period int)

+ func (this *Session) SetEventListener(listener EventListener)

+ func (this *Session) SetName(name string)

+ func (this *Session) SetPkgHandler(handler ReadWriter)

+ func (this *Session) SetRQLen(readQLen int)

+ func (this *Session) SetReadDeadline(rDeadline time.Duration)

+ func (this *Session) SetWQLen(writeQLen int)

+ func (this *Session) SetWaitTime(waitTime time.Duration)

+ func (this *Session) SetWriteDeadline(wDeadline time.Duration)

+ func (this *Session) Stat() string

+ func (this *Session) WriteBytes(pkg []byte) error

+ func (this *Session) WritePkg(pkg interface{}) error

+ type Writer interface

+ Write func(*Session, interface{}) error