Documentation
¶
Index ¶
- type BasicPeer
- func (bp *BasicPeer) Close() error
- func (bp *BasicPeer) GameServer() rua.GameServer
- func (bp *BasicPeer) Id() int
- func (bp *BasicPeer) Logger() rua.Logger
- func (bp *BasicPeer) OnClose(f func() error) *BasicPeer
- func (bp *BasicPeer) OnStart(f func()) *BasicPeer
- func (bp *BasicPeer) OnWrite(f func(data []byte) error) *BasicPeer
- func (bp *BasicPeer) SetId(id int)
- func (bp *BasicPeer) SetLogger(l rua.Logger)
- func (bp *BasicPeer) SetTag(t string)
- func (bp *BasicPeer) Start()
- func (bp *BasicPeer) Tag() string
- func (bp *BasicPeer) WithLogger(l rua.Logger) *BasicPeer
- func (bp *BasicPeer) WithTag(t string) *BasicPeer
- func (bp *BasicPeer) Write(data []byte) error
- type BufferPeer
- type SafePeer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicPeer ¶
type BasicPeer struct {
// contains filtered or unexported fields
}
func NewBasicPeer ¶
func NewBasicPeer(gs rua.GameServer) *BasicPeer
Create a basic peer. You can use BasicPeer.OnWrite(), BasicPeer.OnClose(), BasicPeer.OnStart() to register lifecycle hooks.
func (*BasicPeer) GameServer ¶
func (bp *BasicPeer) GameServer() rua.GameServer
type BufferPeer ¶ added in v0.5.0
type BufferPeer struct { *SafePeer // contains filtered or unexported fields }
func NewBufferPeer ¶ added in v0.5.0
func NewBufferPeer(gs rua.GameServer) *BufferPeer
Create a new BufferPeer. Data write to a BufferPeer will be stored in a buffer. Use `WithConsumer` instead of `OnWrite` to register a consumer to consume data in buffer. Use `OnStartBuffer` instead of `OnStart` to register the `onStart` hook for BufferPeer.
func (*BufferPeer) OnStartBuffer ¶ added in v0.5.0
func (bp *BufferPeer) OnStartBuffer(f func()) *BufferPeer
func (*BufferPeer) WithBufferSize ¶ added in v0.5.0
func (bp *BufferPeer) WithBufferSize(n int) *BufferPeer
func (*BufferPeer) WithConsumer ¶ added in v0.5.0
func (bp *BufferPeer) WithConsumer(f func(b []byte) error) *BufferPeer
This consumer will NOT be triggered in parallel.
func (*BufferPeer) WithWriteTimeout ¶ added in v0.5.0
func (bp *BufferPeer) WithWriteTimeout(ms int) *BufferPeer
type SafePeer ¶
type SafePeer struct { *BasicPeer // contains filtered or unexported fields }
func NewSafePeer ¶
func NewSafePeer(gs rua.GameServer) *SafePeer
func (*SafePeer) OnCloseSafe ¶
This hook can be safely triggered concurrently.
func (*SafePeer) OnStartSafe ¶
This hook can be safely triggered concurrently.
func (*SafePeer) OnWriteSafe ¶
This hook can be safely triggered concurrently.
Click to show internal directories.
Click to hide internal directories.