rua

package module

Go to main page

Versions in this module

v0

v0.6.0

Nov 16, 2021

Changes in this version

+ func Wait(ms uint64, c chan<- bool)

+ type Broadcaster struct

+ func NewBroadcaster() *Broadcaster

+ func (b *Broadcaster) AddTarget(handle *Handle)

+ func (b *Broadcaster) AddTargetThen(handle *Handle, callback func(uint))

+ func (b *Broadcaster) KeepDeadTargets(enable bool) *Broadcaster

+ func (b *Broadcaster) RemoveTarget(id uint)

+ func (b *Broadcaster) RemoveTargetThen(id uint, callback func(*Handle))

+ func (b *Broadcaster) StopAll()

+ func (b *Broadcaster) StopAllThen(callback func(error))

+ func (b *Broadcaster) TimedWrite(data []byte, timeoutMs uint64)

+ func (b *Broadcaster) TimedWriteThen(data []byte, timeoutMs uint64, callback func(error))

+ func (b *Broadcaster) TimeoutMs(ms uint64) *Broadcaster

+ func (b *Broadcaster) Write(data []byte)

+ func (b *Broadcaster) WriteThen(data []byte, callback func(error))

+ type Ctrlc struct

+ func NewCtrlc() *Ctrlc

+ func (c *Ctrlc) Handle() *StopOnlyHandle

+ func (c *Ctrlc) OnSignal(handler func()) *Ctrlc

+ func (c Ctrlc) Go() *StopOnlyHandle

+ func (c Ctrlc) Wait()

+ type FileNode struct

+ func DefaultFileNode() *FileNode

+ func NewFileNode(buffer uint) *FileNode

+ func (n *FileNode) Filename(name string) *FileNode

+ func (n *FileNode) Handle() *Handle

+ func (n FileNode) Go() (*Handle, error)

+ type Handle struct

+ func (h *Handle) ClearTimeout()

+ func (h *Handle) SetTimeoutMs(ms uint64)

+ func (h *Handle) TimedWrite(data []byte, timeoutMs uint64)

+ func (h *Handle) TimedWriteThen(data []byte, timeoutMs uint64, callback func(error))

+ func (h *Handle) Write(data []byte)

+ func (h *Handle) WriteThen(data []byte, callback func(error))

+ type HandleBuilder struct

+ func NewHandleBuilder() *HandleBuilder

+ func (b *HandleBuilder) StopTx(stopTx chan *StopPayload) *HandleBuilder

+ func (b *HandleBuilder) TimeoutMs(timeoutMs uint64) *HandleBuilder

+ func (b *HandleBuilder) Tx(tx chan *WritePayload) *HandleBuilder

+ func (b HandleBuilder) Build() (*Handle, error)

+ func (b HandleBuilder) BuildStopOnly() (*StopOnlyHandle, error)

+ type HandleIdManager struct

+ func NewHandleIdManager() *HandleIdManager

+ func (m *HandleIdManager) Next() uint

+ type StdioNode struct

+ func DefaultStdioNode() *StdioNode

+ func NewStdioNode(buffer uint) *StdioNode

+ func (n *StdioNode) Handle() *Handle

+ func (n *StdioNode) OnInput(f func([]byte)) *StdioNode

+ func (n StdioNode) Go() *Handle

+ type StopOnlyHandle struct

+ func (h StopOnlyHandle) Stop()

+ func (h StopOnlyHandle) StopThen(callback func(error))

+ type StopPayload struct

+ Callback func(error)

+ func NewStopPayload() *StopPayload

+ func (p *StopPayload) WithCallback(f func(error)) *StopPayload

+ type TailNode struct

+ func NewTailNode(filename string) *TailNode

+ func (n *TailNode) CheckIntervalMs(ms uint64) *TailNode

+ func (n *TailNode) Go() (*StopOnlyHandle, error)

+ func (n *TailNode) Handle() *StopOnlyHandle

+ func (n *TailNode) OnNewLine(f func([]byte)) *TailNode

+ type TcpListener struct

+ func NewTcpListener(addr string) *TcpListener

+ func (l *TcpListener) Go() (*StopOnlyHandle, error)

+ func (l *TcpListener) Handle() *StopOnlyHandle

+ func (l *TcpListener) OnNewPeer(f func(*TcpNode)) *TcpListener

+ func (l *TcpListener) PeerWriteBuffer(buffer uint) *TcpListener

+ type TcpNode struct

+ func NewTcpNode(conn net.Conn, buffer uint) *TcpNode

+ func (n *TcpNode) Conn() net.Conn

+ func (n *TcpNode) Go() *Handle

+ func (n *TcpNode) Handle() *Handle

+ func (n *TcpNode) OnInput(f func([]byte)) *TcpNode

+ type Ticker struct

+ func DefaultTicker() *Ticker

+ func NewTicker(intervalMs uint64) *Ticker

+ func (t *Ticker) Go() (*StopOnlyHandle, error)

+ func (t *Ticker) Handle() *StopOnlyHandle

+ func (t *Ticker) IntervalMs(ms uint64) *Ticker

+ func (t *Ticker) OnTick(f func(uint64)) *Ticker

+ type WritePayload struct

+ Callback func(error)

+ Data []byte

+ func NewWritePayload(data []byte) *WritePayload

+ func (p *WritePayload) WithCallback(f func(error)) *WritePayload

v0.5.0

Sep 23, 2021

Changes in this version

+ var ErrPeerClosed = errors.New("peer already closed")

+ var ErrPeerNotExist = errors.New("peer not exist")

+ var ErrPeerWriteTimeout = errors.New("peer write timeout")

+ func WriteOrLog(p Peer, msg []byte)

type GameServer

+ ForEachPeer func(f func(peer Peer))

+ Peer func(id int) (Peer, error)

type Peer

+ Logger func() Logger

+ SetLogger func(Logger)

v0.4.2

Sep 12, 2021

v0.4.1

Sep 12, 2021

v0.4.0

Sep 11, 2021

Changes in this version

type EventDrivenServer

+ func (s *EventDrivenServer) ForEachPeer(f func(id int, peer Peer))

+ func (s *EventDrivenServer) Logger() Logger

+ func (s *EventDrivenServer) Peer(id int) (Peer, error)

+ func (s *EventDrivenServer) PeerCount() int

+ func (s *EventDrivenServer) WithName(n string) *EventDrivenServer

type LockstepServer

+ func (s *LockstepServer) CurrentStep() int

+ func (s *LockstepServer) CurrentStepLength() int

+ func (s *LockstepServer) WithMaxStepLength(maxStepLength int) *LockstepServer

+ func (s *LockstepServer) WithMinStepLength(minStepLength int) *LockstepServer

+ func (s *LockstepServer) WithStepLength(stepLength int) *LockstepServer

type Logger

+ func DefaultLogger() Logger

type Peer

+ Id func() int

+ Tag func() string

type PeerMsg

+ Peer Peer

v0.3.0

Sep 6, 2021

Changes in this version

type LockstepServer

+ func NewLockstepServer() *LockstepServer

v0.2.3

Sep 6, 2021

v0.2.2

Sep 2, 2021

v0.2.1

Aug 31, 2021

v0.2.0

Aug 31, 2021

v0.1.0

Aug 27, 2021

Changes in this version

+ func NewBasicLogger(l SimpleLogger) *basicLogger

+ func NewBasicSimpleLogger(l SmallestLogger) *basicSimpleLogger

+ func NewDefaultLogger() *basicLogger

+ func SetDefaultLogger(logger Logger)

+ type BasicPeer struct

+ func NewBasicPeer(gs GameServer) *BasicPeer

+ func (p *BasicPeer) Close() error

+ func (p *BasicPeer) GetGameServer() GameServer

+ func (p *BasicPeer) GetId() int

+ func (p *BasicPeer) GetLogger() Logger

+ func (p *BasicPeer) GetTag() string

+ func (p *BasicPeer) OnClose(f func(p *BasicPeer) error) *BasicPeer

+ func (p *BasicPeer) OnStart(f func(p *BasicPeer)) *BasicPeer

+ func (p *BasicPeer) OnWrite(f func(data []byte, p *BasicPeer) error) *BasicPeer

+ func (p *BasicPeer) SetId(id int)

+ func (p *BasicPeer) SetLogger(l Logger)

+ func (p *BasicPeer) SetTag(t string)

+ func (p *BasicPeer) Start()

+ func (p *BasicPeer) WithLogger(l Logger) *BasicPeer

+ func (p *BasicPeer) WithTag(t string) *BasicPeer

+ func (p *BasicPeer) Write(data []byte) error

+ type EventDrivenServer struct

+ func NewEventDrivenServer() *EventDrivenServer

+ func (s *EventDrivenServer) AddPeer(p Peer) int

+ func (s *EventDrivenServer) AfterAddPeer(f func(newPeer Peer, s *EventDrivenServer)) *EventDrivenServer

+ func (s *EventDrivenServer) AfterRemovePeer(f func(targetId int, s *EventDrivenServer)) *EventDrivenServer

+ func (s *EventDrivenServer) AppendPeerMsg(peerId int, d []byte)

+ func (s *EventDrivenServer) BeforeAddPeer(f func(newPeer Peer, s *EventDrivenServer)) *EventDrivenServer

+ func (s *EventDrivenServer) BeforeProcPeerMsg(f func(m *PeerMsg, s *EventDrivenServer)) *EventDrivenServer

+ func (s *EventDrivenServer) BeforeRemovePeer(f func(targetId int, s *EventDrivenServer)) *EventDrivenServer

+ func (s *EventDrivenServer) GetLogger() Logger

+ func (s *EventDrivenServer) GetPeer(id int) Peer

+ func (s *EventDrivenServer) GetPeerCount() int

+ func (s *EventDrivenServer) GetPeers() map[int]Peer

+ func (s *EventDrivenServer) OnPeerMsg(f func(m *PeerMsg, s *EventDrivenServer)) *EventDrivenServer

+ func (s *EventDrivenServer) RemovePeer(peerId int) (err error)

+ func (s *EventDrivenServer) SetHandleKeyboardInterrupt(enable bool) *EventDrivenServer

+ func (s *EventDrivenServer) Start() (errs []error)

+ func (s *EventDrivenServer) Stop()

+ func (s *EventDrivenServer) WithLogger(l Logger) *EventDrivenServer

+ type GameServer interface

+ AddPeer func(Peer) int

+ AppendPeerMsg func(peerId int, d []byte)

+ GetPeerCount func() int

+ RemovePeer func(peerId int) error

+ Start func() []error

+ Stop func()

+ type LockstepServer struct

+ func NewLockStepServer() *LockstepServer

+ func (s *LockstepServer) AddPeer(p Peer) int

+ func (s *LockstepServer) AfterAddPeer(f func(newPeer Peer, s *LockstepServer)) *LockstepServer

+ func (s *LockstepServer) AfterRemovePeer(f func(targetId int, s *LockstepServer)) *LockstepServer

+ func (s *LockstepServer) AppendPeerMsg(peerId int, d []byte)

+ func (s *LockstepServer) BeforeAddPeer(f func(newPeer Peer, s *LockstepServer)) *LockstepServer

+ func (s *LockstepServer) BeforeProcPeerMsg(f func(m *PeerMsg, s *LockstepServer)) *LockstepServer

+ func (s *LockstepServer) BeforeRemovePeer(f func(targetId int, s *LockstepServer)) *LockstepServer

+ func (s *LockstepServer) GetCurrentStep() int

+ func (s *LockstepServer) GetCurrentStepLength() int

+ func (s *LockstepServer) GetLogger() Logger

+ func (s *LockstepServer) GetPeer(id int) Peer

+ func (s *LockstepServer) GetPeerCount() int

+ func (s *LockstepServer) GetPeers() map[int]Peer

+ func (s *LockstepServer) OnPeerMsg(f func(m *PeerMsg, s *LockstepServer)) *LockstepServer

+ func (s *LockstepServer) OnStep(f func(peerMsgs []PeerMsg, s *LockstepServer)) *LockstepServer

+ func (s *LockstepServer) RemovePeer(peerId int) (err error)

+ func (s *LockstepServer) SetHandleKeyboardInterrupt(enable bool) *LockstepServer

+ func (s *LockstepServer) SetMaxStepLength(maxStepLength int) *LockstepServer

+ func (s *LockstepServer) SetMinStepLength(minStepLength int) *LockstepServer

+ func (s *LockstepServer) SetStepLength(stepLength int) *LockstepServer

+ func (s *LockstepServer) Start() (errs []error)

+ func (s *LockstepServer) Stop()

+ func (s *LockstepServer) WithLogger(l Logger) *LockstepServer

+ type LogLevel int

+ const DEBUG

+ const ERROR

+ const FATAL

+ const INFO

+ const PANIC

+ const TRACE

+ const WARN

+ type Logger interface

+ Debug func(v ...interface{})

+ Debugf func(format string, v ...interface{})

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ Panic func(v ...interface{})

+ Panicf func(format string, v ...interface{})

+ Trace func(v ...interface{})

+ Tracef func(format string, v ...interface{})

+ Warn func(v ...interface{})

+ Warnf func(format string, v ...interface{})

+ func GetDefaultLogger() Logger

+ type Peer interface

+ Close func() error

+ GetId func() int

+ GetTag func() string

+ SetId func(int)

+ SetTag func(string)

+ Start func()

+ Write func([]byte) error

+ type PeerMsg struct

+ Data []byte

+ PeerId int

+ Time time.Time

+ type SimpleLogger interface

+ Debug func(v ...interface{})

+ Error func(v ...interface{})

+ Fatal func(v ...interface{})

+ Info func(v ...interface{})

+ Panic func(v ...interface{})

+ Trace func(v ...interface{})

+ Warn func(v ...interface{})

+ type SmallestLogger interface

+ Print func(v ...interface{})

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