network

Documentation

Index

• type BroadcastPeer
  • func NewBroadcastPeer(gs rua.GameServer) *BroadcastPeer
  • func (bp *BroadcastPeer) WithSelector(f func(p rua.Peer) bool) *BroadcastPeer
  • func (bp *BroadcastPeer) WithSyncWrite(sync bool) *BroadcastPeer
• type NetPeer
  • func NewNetPeer(conn net.Conn, gs rua.GameServer) *NetPeer
  • func (np *NetPeer) WithBufSize(n int) *NetPeer
  • func (np *NetPeer) WithReadTimeout(ms int) *NetPeer
  • func (np *NetPeer) WithTimeout(ms int) *NetPeer
  • func (np *NetPeer) WithWriteTimeout(ms int) *NetPeer

Types

type BroadcastPeer

type BroadcastPeer struct {
	*peer.SafePeer
	// contains filtered or unexported fields
}

func NewBroadcastPeer

func NewBroadcastPeer(gs rua.GameServer) *BroadcastPeer

Create a new BroadcastPeer. By default, the broadcast peer will broadcast message in parallel to all other peers except it self. You can use `WithSelector` to select broadcast targets. The BroadcastPeer will never write message to itself to avoid recursive call.

func (*BroadcastPeer) WithSelector

func (bp *BroadcastPeer) WithSelector(f func(p rua.Peer) bool) *BroadcastPeer

If the selector returns true, the target peer will be notified.

func (*BroadcastPeer) WithSyncWrite

func (bp *BroadcastPeer) WithSyncWrite(sync bool) *BroadcastPeer

type NetPeer

type NetPeer struct {
	*peer.BufferPeer
	// contains filtered or unexported fields
}

func NewNetPeer

func NewNetPeer(conn net.Conn, gs rua.GameServer) *NetPeer

Create a peer with a connection of `net.Conn`. If `timeout` == 0 (in ms), there is no timeout.

func (*NetPeer) WithBufSize

func (np *NetPeer) WithBufSize(n int) *NetPeer

func (*NetPeer) WithReadTimeout

func (np *NetPeer) WithReadTimeout(ms int) *NetPeer

func (*NetPeer) WithTimeout

func (np *NetPeer) WithTimeout(ms int) *NetPeer

Set the readTimeout and writeTimeout to the specified ms.

func (*NetPeer) WithWriteTimeout

func (np *NetPeer) WithWriteTimeout(ms int) *NetPeer