arnet

Documentation

Index

• func HistDecoder(histBytes []byte) (hist *bg.Hist, err error)
• func HistEncode(hist *bg.Hist) (histBytes []byte, err error)
• func PokeClient(clientAdr, myAddr string)
• func PokeListener(ln net.Listener, addCh chan<- string)
• type Receiver
  • func NewReceiver(port string) (nz *Receiver, err error)
  • func (nz *Receiver) Close() (err error)
  • func (nz *Receiver) Start()
• type Sender
  • func NewSender(addr string) (nz *Sender, err error)
  • func (nz *Sender) Start()
  • func (nz *Sender) Stop()

Functions

func HistDecoder

func HistDecoder(histBytes []byte) (hist *bg.Hist, err error)

HistDecoder decodes game history.

func HistEncode

func HistEncode(hist *bg.Hist) (histBytes []byte, err error)

HistEncode encodes game history.

func PokeClient

func PokeClient(clientAdr, myAddr string)

PokeClient poke the client with address to signal it is ready.

func PokeListener

func PokeListener(ln net.Listener, addCh chan<- string)

PokeListener listen for pokes and send them on. Create listner with ln, err := net.Listen("tcp", clientAddr) stop with ln.Close() should be called in a goroutine.

Types

type Receiver

type Receiver struct {
	HistCh chan []byte
	// contains filtered or unexported fields
}

Receiver a zmq receiver of game histories.

func NewReceiver

func NewReceiver(port string) (nz *Receiver, err error)

NewReceiver creates a zmq receiver of game histories.

func (*Receiver) Close

func (nz *Receiver) Close() (err error)

Close closes the zmq receiver.

func (*Receiver) Start

func (nz *Receiver) Start()

Start starts zmg reciver of histories.

type Sender

type Sender struct {
	HistCh   chan *bg.Hist
	BrokenCh chan *bg.Hist
	// contains filtered or unexported fields
}

Sender a zmq sender of game history

func NewSender

func NewSender(addr string) (nz *Sender, err error)

NewSender creates a zmq sender of game histories.

func (*Sender) Start

func (nz *Sender) Start()

Start starts a zmq sender.

func (*Sender) Stop

func (nz *Sender) Stop()

Stop stops a zmq sender.