getty

package

Go to main page

Versions in this module

v1

v1.3.2

Nov 20, 2023

v1.3.1

Oct 23, 2022

Changes in this version

type Server

+ func NewUDPEndPoint(opts ...ServerOption) Server

v1.3.0

Dec 13, 2020

Changes in this version

type ClientOption

+ func WithClientSslEnabled(sslEnabled bool) ClientOption

+ func WithClientTaskPool(pool gxsync.GenericTaskPool) ClientOption

+ func WithClientTlsConfigBuilder(tlsConfigBuilder TlsConfigBuilder) ClientOption

+ type ClientTlsConfigBuilder struct

+ ClientKeyCertChainPath string

+ ClientKeyPassword string

+ ClientPrivateKeyPath string

+ ClientTrustCertCollectionPath string

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

type EndPoint

+ GetTaskPool func() gxsync.GenericTaskPool

type ServerOption

+ func WithServerSslEnabled(sslEnabled bool) ServerOption

+ func WithServerTaskPool(pool gxsync.GenericTaskPool) 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 TlsConfigBuilder interface

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

v1.2.10

Jul 31, 2020

v1.2.9

Jun 23, 2020

Changes in this version

+ type PacketServer interface

+ PacketConn func() net.PacketConn

+ type StreamServer interface

+ Listener func() net.Listener

v1.2.8

Apr 17, 2020

v1.2.7

Apr 1, 2020

v1.2.6

Mar 2, 2020

Changes in this version

+ const CompressBestCompression

+ const CompressBestSpeed

+ const CompressHuffman

+ const CompressNone

+ const CompressSnappy

+ const CompressZip

+ const DATE

+ const GETTY_BUILD

+ const GETTY_MAJOR

+ const GETTY_MINOR

+ const MaxWheelTimeSpan

+ const Version

+ var EndPointType_name = map[int32]string

+ var EndPointType_value = map[string]int32

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

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

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

+ func GetTimeWheel() *gxtime.Wheel

+ type Client interface

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

+ type EndPoint interface

+ Close func()

+ EndPointType func() EndPointType

+ 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 NewSessionCallback func(Session) error

+ type ReadWriter interface

+ type Reader interface

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

+ type Server interface

+ Listener func() net.Listener

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

+ SetRQLen func(int)

+ SetReader func(Reader)

+ SetTaskPool func(*gxsync.TaskPool)

+ SetWQLen func(int)

+ SetWaitTime func(time.Duration)

+ SetWriter func(Writer)

+ Stat func() string

+ WriteBytes func([]byte) error

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

+ WritePkg func(pkg interface{}, timeout time.Duration) 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