server

package

Go to main page

Versions in this module

v0

v0.1.0

Aug 29, 2022

v0.0.2

Aug 14, 2022

Changes in this version

+ const UDPPacketClipHeaderLen

+ const UDPPacketClipLimit

type AsyncReceiver

+ func NewAsyncReceiver(ctx *ServerContext, conn Connection) *AsyncReceiver

+ func (r *AsyncReceiver) Close()

+ func (r *AsyncReceiver) Conn() Connection

+ func (r *AsyncReceiver) Ctx() *ServerContext

+ func (r *AsyncReceiver) Recv() (Message, error)

+ func (r *AsyncReceiver) Send(msg Message) error

+ func (r *AsyncReceiver) String() string

+ type FuncUDPConnectionSend func(addr *net.UDPAddr, data []byte) error

type Listener

+ func NewUDPListener(ctx *ServerContext) (Listener, error)

+ type RawUDPPacket struct

+ Addr *net.UDPAddr

+ Packet []byte

type ServerContext

+ UDPConnectionConfig *UDPConnectionConfig

+ UDPListenerConfig *UDPListenerConfig

type SyncReceiver

+ func NewSyncReceiver(ctx *ServerContext, conn Connection) *SyncReceiver

+ func (r *SyncReceiver) Close()

+ func (r *SyncReceiver) Conn() Connection

+ func (r *SyncReceiver) Ctx() *ServerContext

+ func (r *SyncReceiver) Recv() (Message, error)

+ func (r *SyncReceiver) Send(msg Message) error

+ func (r *SyncReceiver) String() string

+ type UDPConnection struct

+ func NewUDPConnection(cfg *UDPConnectionConfig, id uint64, addr *net.UDPAddr, ...) *UDPConnection

+ func (uc *UDPConnection) Close() error

+ func (uc *UDPConnection) ID() uint64

+ func (uc *UDPConnection) IsClosed() bool

+ func (uc *UDPConnection) LastRecvTs() int64

+ func (uc *UDPConnection) PushPacketClip(clip *UDPPacketClip) error

+ func (uc *UDPConnection) Recv() (*RawMessage, error)

+ func (uc *UDPConnection) Remote() string

+ func (uc *UDPConnection) Send(msg *RawMessage) error

+ type UDPConnectionConfig struct

+ CacheClipLimit int

+ type UDPListener struct

+ func (l *UDPListener) Accepting(cbNewConn func(Connection))

+ func (l *UDPListener) Addr() string

+ func (l *UDPListener) Ctx() *ServerContext

+ func (l *UDPListener) Stop()

+ type UDPListenerConfig struct

+ ConnExpireS int64

+ ConnReadCnt int

+ ListenAddress string

+ type UDPPacket struct

+ Addr *net.UDPAddr

+ Packet []byte

+ type UDPPacketClip struct

+ Addr *net.UDPAddr

+ ClipLen uint16

+ ClipSeq uint16

+ ConnID uint64

+ PacketSeq uint64

+ Payload []byte

+ func (clip *UDPPacketClip) Decode(bs []byte) error

+ func (clip *UDPPacketClip) Encode() ([]byte, error)

v0.0.1

Aug 10, 2022

Changes in this version

+ type AsyncReceiver interface

+ RecvChan func() <-chan Message

+ type Callback struct

+ OnDebug func(string)

+ OnError func(string, error, Receiver, Message)

+ OnNewReceiver func(Receiver)

+ func (rc *Callback) TrigDebug(str string)

+ func (rc *Callback) TrigError(s string, e error, r Receiver, m Message)

+ func (rc *Callback) TrigNewReceiver(r Receiver)

+ type Connection interface

+ Close func() error

+ ID func() uint64

+ Recv func() (*RawMessage, error)

+ Remote func() string

+ Send func(*RawMessage) error

+ type ConnectionConfig struct

+ TimeoutEachRead time.Duration

+ TimeoutEachWrite time.Duration

+ type DefaultMessageMux struct

+ func NewDefaultMessageMux() *DefaultMessageMux

+ func (mux *DefaultMessageMux) Handle(protoID uint32, h MessageHandler)

+ func (mux *DefaultMessageMux) HandleUnknown(h MessageHandler)

+ func (mux *DefaultMessageMux) Handler(protoID uint32) MessageHandler

+ type Listener interface

+ Accepting func(cbNewConn func(Connection))

+ Addr func() string

+ Ctx func() *ServerContext

+ Stop func()

+ func NewTCPListener(ctx *ServerContext) (Listener, error)

+ type Message interface

+ ProtoID func() uint32

+ String func() string

+ type MessageHandler func(Receiver, Message) error

+ type MessageMux interface

+ Handle func(uint32, MessageHandler)

+ HandleUnknown func(MessageHandler)

+ Handler func(uint32) MessageHandler

+ type MessageProtocol interface

+ Decode func(protoID uint32, bs []byte) (Message, error)

+ Encode func(msg Message) ([]byte, error)

+ New func(protoID uint32) Message

+ type MessageServeAsync struct

+ func NewMessageServeAsync(r AsyncReceiver, mux MessageMux) *MessageServeAsync

+ func (ms *MessageServeAsync) Mux() MessageMux

+ func (ms *MessageServeAsync) Processing(ctx context.Context)

+ func (ms *MessageServeAsync) Receiver() AsyncReceiver

+ type MessageServeSync struct

+ func NewMessageServeSync(r SyncReceiver, mux MessageMux) *MessageServeSync

+ func (ms *MessageServeSync) Mux() MessageMux

+ func (ms *MessageServeSync) Receiver() SyncReceiver

+ func (ms *MessageServeSync) RecvOnce() error

+ type RawMessage struct

+ Payload []byte

+ ProtoID uint32

+ type Receiver interface

+ Close func()

+ Conn func() Connection

+ Ctx func() *ServerContext

+ Recv func() (Message, error)

+ Send func(Message) error

+ String func() string

+ type Server struct

+ CBNewConnection func(Connection)

+ Ctx *ServerContext

+ Listener Listener

+ func (s *Server) Close()

+ type ServerBuilder struct

+ Ctx *ServerContext

+ NewListener func(*ServerContext) (Listener, error)

+ NewReceiver func(*ServerContext, Connection) Receiver

+ func (b *ServerBuilder) NewServer() (*Server, error)

+ type ServerContext struct

+ CB *Callback

+ MessageProtocol MessageProtocol

+ TCPConnectionConfig *TCPConnectionConfig

+ TCPListenerConfig *TCPListenerConfig

+ type SyncReceiver interface

+ type TCPAsyncReceiver struct

+ func NewTCPAsyncReceiver(ctx *ServerContext, conn Connection) *TCPAsyncReceiver

+ func (r *TCPAsyncReceiver) Close()

+ func (r *TCPAsyncReceiver) Conn() Connection

+ func (r *TCPAsyncReceiver) Ctx() *ServerContext

+ func (r *TCPAsyncReceiver) Recv() (Message, error)

+ func (r *TCPAsyncReceiver) RecvChan() <-chan Message

+ func (r *TCPAsyncReceiver) Send(msg Message) error

+ func (r *TCPAsyncReceiver) String() string

+ type TCPConnection struct

+ func NewTCPConnection(cfg *TCPConnectionConfig, conn *net.TCPConn, id uint64) *TCPConnection

+ func (tc *TCPConnection) Close() error

+ func (tc *TCPConnection) ID() uint64

+ func (tc *TCPConnection) Recv() (*RawMessage, error)

+ func (tc *TCPConnection) Remote() string

+ func (tc *TCPConnection) Send(msg *RawMessage) error

+ type TCPConnectionConfig struct

+ type TCPListener struct

+ func (l *TCPListener) Accepting(cbNewConn func(Connection))

+ func (l *TCPListener) Addr() string

+ func (l *TCPListener) Ctx() *ServerContext

+ func (l *TCPListener) Stop()

+ type TCPListenerConfig struct

+ ListenAddress string

+ type TCPSyncReceiver struct

+ func NewTCPSyncReceiver(ctx *ServerContext, conn Connection) *TCPSyncReceiver

+ func (r *TCPSyncReceiver) Close()

+ func (r *TCPSyncReceiver) Conn() Connection

+ func (r *TCPSyncReceiver) Ctx() *ServerContext

+ func (r *TCPSyncReceiver) Recv() (Message, error)

+ func (r *TCPSyncReceiver) Send(msg Message) error

+ func (r *TCPSyncReceiver) String() string

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