protocol

Documentation

Index

• Constants
• type AuthInfo
• type Conn
  • func Wrapper(conn ReadWriteCloser) *Conn
  • func (c *Conn) Accept(apply func(msg Packet, c *Conn)) error
  • func (c *Conn) Close() error
  • func (c *Conn) ID() int64
  • func (c *Conn) IP() string
  • func (c *Conn) Read() (*Packet, error)
  • func (c *Conn) State() int
  • func (c *Conn) Write(packet Packet) error
• type Packet
  • func ErrorPacket(err error) Packet
  • func ObjectPacket(obj interface{}) Packet
  • func StringPacket(msg string) Packet
  • func (p Packet) Int() (int, error)
  • func (p Packet) Int64() (int64, error)
  • func (p Packet) String() string
  • func (p Packet) Unmarshal(v interface{}) error
• type ReadWriteCloser
• type TcpReadWriteCloser
  • func NewTcpReadWriteCloser(conn net.Conn) TcpReadWriteCloser
  • func (t TcpReadWriteCloser) Close() error
  • func (t TcpReadWriteCloser) IP() string
  • func (t TcpReadWriteCloser) Read() (*Packet, error)
  • func (t TcpReadWriteCloser) Write(msg Packet) error
• type WebsocketReadWriteCloser
  • func NewWebsocketReadWriteCloser(conn *websocket.Conn) WebsocketReadWriteCloser
  • func (w WebsocketReadWriteCloser) Close() error
  • func (w WebsocketReadWriteCloser) IP() string
  • func (w WebsocketReadWriteCloser) Read() (*Packet, error)
  • func (w WebsocketReadWriteCloser) Write(msg Packet) error

Constants

const MaxPacketSize = 65536

Types

type AuthInfo

type AuthInfo struct {
	ID       int    `json:"id"`
	Name     string `json:"name"`
	Password string `json:"password"`
}

type Conn

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

func Wrapper

func Wrapper(conn ReadWriteCloser) *Conn

func (*Conn) Accept

func (c *Conn) Accept(apply func(msg Packet, c *Conn)) error

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) ID

func (c *Conn) ID() int64

func (*Conn) IP

func (c *Conn) IP() string

func (*Conn) Read

func (c *Conn) Read() (*Packet, error)

func (*Conn) State

func (c *Conn) State() int

func (*Conn) Write

func (c *Conn) Write(packet Packet) error

type Packet

type Packet struct {
	Body []byte `json:"data"`
}

func ErrorPacket

func ErrorPacket(err error) Packet

func ObjectPacket

func ObjectPacket(obj interface{}) Packet

func StringPacket

func StringPacket(msg string) Packet

func (Packet) Int

func (p Packet) Int() (int, error)

func (Packet) Int64

func (p Packet) Int64() (int64, error)

func (Packet) String

func (p Packet) String() string

func (Packet) Unmarshal

func (p Packet) Unmarshal(v interface{}) error

type ReadWriteCloser

type ReadWriteCloser interface {
	Read() (*Packet, error)
	Write(msg Packet) error
	Close() error
	IP() string
}

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

func (t TcpReadWriteCloser) IP() string

func (TcpReadWriteCloser) Read

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

func (TcpReadWriteCloser) Write

func (t TcpReadWriteCloser) Write(msg Packet) 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) IP

func (w WebsocketReadWriteCloser) IP() string

func (WebsocketReadWriteCloser) Read

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

func (WebsocketReadWriteCloser) Write

func (w WebsocketReadWriteCloser) Write(msg Packet) error