getty

package module

Go to main page

Versions in this module

v1

v1.8.4

Nov 6, 2021

v1.8.3

Nov 6, 2021

v1.8.2

Oct 30, 2021

v1.8.1

Oct 30, 2021

v1.8.0

Oct 29, 2021

v1.0.3

Oct 19, 2018

v1.0.2

Aug 19, 2018

v0

v0.9.3

Aug 7, 2018

Changes in this version

+ func GetTimeWheel() *gxtime.Wheel

v0.9.1

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

v0.8.5

Jun 25, 2018

v0.8.3

Apr 24, 2018

Changes in this version

+ const DATE

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

type Client

+ func NewWSClient(opts ...ClientOption) Client

+ func NewWSSClient(opts ...ClientOption) Client

type Connection

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

type Server

+ func NewUDPPEndPoint(opts ...ServerOption) Server

v0.3.14

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.")

type Client

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

+ 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

+ func NewSession(conn net.Conn) *Session

+ func (this *Session) RunEventLoop()

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

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

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

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

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

v0.0.5

Dec 18, 2022

v0.0.4

Dec 11, 2022

v0.0.3

Dec 11, 2022

v0.0.2

Dec 10, 2022

v0.0.1

Nov 12, 2021

Changes in this version

+ const CompressBestCompression

+ const CompressBestSpeed

+ const CompressHuffman

+ const CompressNone

+ const CompressSnappy

+ const CompressZip

+ const LoggerLevelDPanic

+ const LoggerLevelDebug

+ const LoggerLevelError

+ const LoggerLevelFatal

+ const LoggerLevelInfo

+ const LoggerLevelPanic

+ const LoggerLevelWarn

+ const MaxWheelTimeSpan

+ var EndPointType_name = map[int32]string

+ var EndPointType_value = map[string]int32

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

+ var ErrSessionBlocked = perrors.New("session Full Blocked")

+ var ErrSessionClosed = perrors.New("session Already Closed")

+ func Online(logfile string) error

+ func SetLogger(logger Logger)

+ func SetLoggerCallerDisable() error

+ func SetLoggerLevel(level LoggerLevel) error

+ type Client interface

+ func NewTCPClient(opts ...ClientOption) Client

+ func NewUDPClient(opts ...ClientOption) Client

+ type ClientOption func(*ClientOptions)

+ func WithClientSslEnabled(sslEnabled bool) ClientOption

+ func WithClientTaskPool(pool gxsync.GenericTaskPool) ClientOption

+ func WithClientTlsConfigBuilder(tlsConfigBuilder TlsConfigBuilder) ClientOption

+ func WithConnectionNumber(num int) ClientOption

+ func WithLocalAddressClient(addr net.Addr) ClientOption

+ func WithReconnectInterval(reconnectInterval int) ClientOption

+ func WithRootCertificateFile(cert string) ClientOption

+ func WithServerAddress(addr string) ClientOption

+ type ClientOptions struct

+ type ClientTlsConfigBuilder struct

+ ClientKeyCertChainPath string

+ ClientKeyPassword string

+ ClientPrivateKeyPath string

+ ClientTrustCertCollectionPath string

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

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

+ type EndPoint interface

+ Close func()

+ EndPointType func() EndPointType

+ GetTaskPool func() gxsync.GenericTaskPool

+ ID func() EndPointID

+ IsClosed func() bool

+ RunEventLoop func(newSession NewSessionCallback)

+ type EndPointID = int32

+ 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 EventListener interface

+ OnClose func(Session)

+ OnCron func(Session)

+ OnError func(Session, error)

+ OnMessage func(Session, interface{})

+ OnOpen func(Session) error

+ 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

+ func NewLogger(logName string, level LoggerLevel) Logger

+ type LoggerLevel int8

+ type NewSessionCallback func(Session) error

+ type PacketServer interface

+ PacketConn func() net.PacketConn

+ type ReadWriter interface

+ type Reader interface

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

+ type Server interface

+ func NewTCPServer(opts ...ServerOption) Server

+ func NewUDPEndPoint(opts ...ServerOption) Server

+ func NewWSSServer(opts ...ServerOption) Server

+ func NewWSServer(opts ...ServerOption) Server

+ type ServerOption func(*ServerOptions)

+ func WithLocalAddress(addr string) ServerOption

+ func WithServerSslEnabled(sslEnabled bool) ServerOption

+ func WithServerTaskPool(pool gxsync.GenericTaskPool) ServerOption

+ func WithServerTlsConfigBuilder(tlsConfigBuilder TlsConfigBuilder) 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 ServerTlsConfigBuilder struct

+ ServerKeyCertChainPath string

+ ServerKeyPassword string

+ ServerPrivateKeyPath string

+ ServerTrustCertCollectionPath string

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

+ type Session interface

+ Close func()

+ Conn func() net.Conn

+ EndPoint func() EndPoint

+ GetAttribute func(interface{}) interface{}

+ IsClosed func() bool

+ RemoveAttribute func(interface{})

+ Reset func()

+ SetAttribute func(interface{}, interface{})

+ SetCronPeriod func(int)

+ SetEventListener func(EventListener)

+ SetMaxMsgLen func(int)

+ SetName func(string)

+ SetPkgHandler func(ReadWriter)

+ SetReader func(Reader)

+ SetWaitTime func(time.Duration)

+ SetWriter func(Writer)

+ Stat func() string

+ WriteBytes func([]byte) (int, error)

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

+ WritePkg func(pkg interface{}, timeout time.Duration) (totalBytesLength int, sendBytesLength int, err error)

+ type StreamServer interface

+ Listener func() net.Listener

+ type TlsConfigBuilder interface

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

+ type UDPContext struct

+ PeerAddr *net.UDPAddr

+ Pkg interface{}

+ func (c UDPContext) String() string

+ type Writer interface

+ Write func(Session, interface{}) ([]byte, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL