protocol

Documentation

Index

• func Encode(msg Msg) []byte
• func ReadUint32(reader io.Reader) (uint32, error)
• func ReadUint64(reader io.Reader) (uint64, error)
• type Msg
  • func Decode(r io.Reader) (*Msg, error)
• type ReadWriteCloser
• type TcpReadWriteCloser
  • func NewTcpReadWriteCloser(conn net.Conn) TcpReadWriteCloser
  • func (t TcpReadWriteCloser) Close() error
  • func (t TcpReadWriteCloser) Read() (*Msg, error)
  • func (t TcpReadWriteCloser) Write(msg Msg) error
• type WebsocketReadWriteCloser
  • func NewWebsocketReadWriteCloser(conn *websocket.Conn) WebsocketReadWriteCloser
  • func (w WebsocketReadWriteCloser) Close() error
  • func (w WebsocketReadWriteCloser) Read() (*Msg, error)
  • func (w WebsocketReadWriteCloser) Write(msg Msg) error

Functions

func Encode

func Encode(msg Msg) []byte

func ReadUint32

func ReadUint32(reader io.Reader) (uint32, error)

func ReadUint64

func ReadUint64(reader io.Reader) (uint64, error)

Types

type Msg

type Msg struct {
	ID   int64  `json:"id"`
	Data []byte `json:"data"`
}

func Decode

func Decode(r io.Reader) (*Msg, error)

type ReadWriteCloser

type ReadWriteCloser interface {
	Read() (*Msg, error)
	Write(msg Msg) error
	Close() error
}

type TcpReadWriteCloser

type TcpReadWriteCloser struct {
	// contains filtered or unexported fields
}

func NewTcpReadWriteCloser

func NewTcpReadWriteCloser(conn net.Conn) TcpReadWriteCloser

func (TcpReadWriteCloser) Close

func (t TcpReadWriteCloser) Close() error

func (TcpReadWriteCloser) Read

func (t TcpReadWriteCloser) Read() (*Msg, error)

func (TcpReadWriteCloser) Write

func (t TcpReadWriteCloser) Write(msg Msg) error

type WebsocketReadWriteCloser

type WebsocketReadWriteCloser struct {
	// contains filtered or unexported fields
}

func NewWebsocketReadWriteCloser

func NewWebsocketReadWriteCloser(conn *websocket.Conn) WebsocketReadWriteCloser

func (WebsocketReadWriteCloser) Close

func (w WebsocketReadWriteCloser) Close() error

func (WebsocketReadWriteCloser) Read

func (w WebsocketReadWriteCloser) Read() (*Msg, error)

func (WebsocketReadWriteCloser) Write

func (w WebsocketReadWriteCloser) Write(msg Msg) error