peer

README

Peer

This folder contains peers without any third party dependencies.

BasicPeer

You can construct your own peer based on BasicPeer.

FilePeer

• Not readable.
• Write to this peer to store data in a file.

NetPeer

Read from and write to a net.Conn.

StdioPeer

• Read from stdin.
• Write to stdout.

Documentation

Index

• Variables
• type BasicPeer
  • func NewBasicPeer(gs rua.GameServer) *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) 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 SafePeer
  • func NewSafePeer(gs rua.GameServer) *SafePeer
  • func (sp *SafePeer) Lock()
  • func (sp *SafePeer) OnCloseSafe(f func() error) *SafePeer
  • func (sp *SafePeer) OnStartSafe(f func()) *SafePeer
  • func (sp *SafePeer) OnWriteSafe(f func([]byte) error) *SafePeer
  • func (sp *SafePeer) Unlock()

Variables

var (
	ErrClosed = errors.New("peer already closed")
)

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

func (bp *BasicPeer) Close() error

func (*BasicPeer) GameServer

func (bp *BasicPeer) GameServer() rua.GameServer

func (*BasicPeer) Id

func (bp *BasicPeer) Id() int

func (*BasicPeer) Logger

func (bp *BasicPeer) Logger() rua.Logger

func (*BasicPeer) OnClose

func (bp *BasicPeer) OnClose(f func() error) *BasicPeer

This hook may be triggered concurrently

func (*BasicPeer) OnStart

func (bp *BasicPeer) OnStart(f func()) *BasicPeer

This hook may NOT be triggered concurrently

func (*BasicPeer) OnWrite

func (bp *BasicPeer) OnWrite(f func(data []byte) error) *BasicPeer

This hook may be triggered concurrently

func (*BasicPeer) SetId

func (bp *BasicPeer) SetId(id int)

func (*BasicPeer) SetTag

func (bp *BasicPeer) SetTag(t string)

func (*BasicPeer) Start

func (bp *BasicPeer) Start()

Start and wait.

func (*BasicPeer) Tag

func (bp *BasicPeer) Tag() string

func (*BasicPeer) WithLogger

func (bp *BasicPeer) WithLogger(l rua.Logger) *BasicPeer

func (*BasicPeer) WithTag

func (bp *BasicPeer) WithTag(t string) *BasicPeer

func (*BasicPeer) Write

func (bp *BasicPeer) Write(data []byte) error

type SafePeer

type SafePeer struct {
	*BasicPeer
	// contains filtered or unexported fields
}

func NewSafePeer

func NewSafePeer(gs rua.GameServer) *SafePeer

func (*SafePeer) Lock

func (sp *SafePeer) Lock()

func (*SafePeer) OnCloseSafe

func (sp *SafePeer) OnCloseSafe(f func() error) *SafePeer

This hook can be safely triggered concurrently.

func (*SafePeer) OnStartSafe

func (sp *SafePeer) OnStartSafe(f func()) *SafePeer

This hook can be safely triggered concurrently.

func (*SafePeer) OnWriteSafe

func (sp *SafePeer) OnWriteSafe(f func([]byte) error) *SafePeer

This hook can be safely triggered concurrently.

func (*SafePeer) Unlock

func (sp *SafePeer) Unlock()