getty

Mar 16, 2024

Changes in this version

type Connection

+ CloseConn func(int)

+ IncReadPkgNum func()

+ IncWritePkgNum func()

+ ReadTimeout func() time.Duration

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

+ SetSession func(Session)

+ WriteTimeout func() time.Duration

Oct 28, 2021

Changes in this version

type Server

+ func NewUDPEndPoint(opts ...ServerOption) Server

Nov 27, 2020

Changes in this version

type ClientOption

+ func WithClientTaskPool(pool gxsync.GenericTaskPool) ClientOption

type EndPoint

+ GetTaskPool func() gxsync.GenericTaskPool

type ServerOption

+ func WithServerTaskPool(pool gxsync.GenericTaskPool) ServerOption

Aug 18, 2020

Changes in this version

+ const LoggerLevelDPanic

+ const LoggerLevelDebug

+ const LoggerLevelError

+ const LoggerLevelFatal

+ const LoggerLevelInfo

+ const LoggerLevelPanic

+ const LoggerLevelWarn

+ const MaxWheelTimeSpan

+ func SetLogger(logger Logger)

+ func SetLoggerCallerDisable() error

+ func SetLoggerLevel(level LoggerLevel) error

type ClientOption

+ func WithClientSslEnabled(sslEnabled bool) ClientOption

+ func WithClientTlsConfigBuilder(tlsConfigBuilder TlsConfigBuilder) ClientOption

+ func WithReconnectInterval(reconnectInterval int) ClientOption

+ type ClientTlsConfigBuilder struct

+ ClientKeyCertChainPath string

+ ClientKeyPassword string

+ ClientPrivateKeyPath string

+ ClientTrustCertCollectionPath string

+ func (c *ClientTlsConfigBuilder) BuildTlsConfig() (*tls.Config, error)

type EndPoint

+ ID func() EndPointID

+ type EndPointID = int32

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(fmt string, args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(fmt string, args ...interface{})

+ Info func(args ...interface{})

+ Infof func(fmt string, args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(fmt string, args ...interface{})

+ func GetLogger() Logger

+ type LoggerLevel int8

+ type PacketServer interface

+ PacketConn func() net.PacketConn

type ServerOption

+ func WithServerSslEnabled(sslEnabled bool) ServerOption

+ func WithServerTlsConfigBuilder(tlsConfigBuilder TlsConfigBuilder) ServerOption

+ type ServerTlsConfigBuilder struct

+ ServerKeyCertChainPath string

+ ServerKeyPassword string

+ ServerPrivateKeyPath string

+ ServerTrustCertCollectionPath string

+ func (s *ServerTlsConfigBuilder) BuildTlsConfig() (*tls.Config, error)

type Session

+ SetTaskPool func(*gxsync.TaskPool)

+ type StreamServer interface

+ Listener func() net.Listener

+ type TlsConfigBuilder interface

+ BuildTlsConfig func() (*tls.Config, error)

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