socket

Documentation

Index

• Constants
• Variables
• type PacketBuilder
  • func (p *PacketBuilder) WriteBytes(bytes []byte)
  • func (p *PacketBuilder) WriteCString(s string)
• type PacketReader
  • func NewPacketReader(bytes []byte) *PacketReader
  • func (p *PacketReader) CanRead(size int) bool
  • func (p *PacketReader) More() bool
  • func (p *PacketReader) Pos() int
  • func (p *PacketReader) ReadFloat32() float32
  • func (p *PacketReader) ReadIPv4() (net.IP, error)
  • func (p *PacketReader) ReadInt32() int32
  • func (p *PacketReader) ReadPort() (uint16, error)
  • func (p *PacketReader) ReadString() string
  • func (p *PacketReader) ReadUint16() uint16
  • func (p *PacketReader) ReadUint32() uint32
  • func (p *PacketReader) ReadUint64() uint64
  • func (p *PacketReader) ReadUint8() uint8
  • func (p *PacketReader) Split(count int) []byte
  • func (p *PacketReader) TryReadString() (string, error)
• type Udp
  • func NewUdp(address string, timeout time.Duration) (*Udp, error)
  • func (u *Udp) Close() error
  • func (u *Udp) Connect() error
  • func (u *Udp) Receive() ([]byte, error)
  • func (u *Udp) RemoteAddr() net.Addr
  • func (u *Udp) Send(data []byte) error
  • func (u *Udp) SetRateLimit(ratePerMinute int)
  • func (u *Udp) SetTimeout(duration time.Duration)

Constants

const MTU = 1400

Variables

var ErrOutOfBounds = errors.New("read out of bounds")

Types

type PacketBuilder

type PacketBuilder struct {
	bytes.Buffer
}

func (*PacketBuilder) WriteBytes

func (p *PacketBuilder) WriteBytes(bytes []byte)

func (*PacketBuilder) WriteCString

func (p *PacketBuilder) WriteCString(s string)

type PacketReader

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

func NewPacketReader

func NewPacketReader(bytes []byte) *PacketReader

func (*PacketReader) CanRead

func (p *PacketReader) CanRead(size int) bool

CanRead returns true if there are at least size bytes left to read

func (*PacketReader) More

func (p *PacketReader) More() bool

More returns true if there are more bytes to read

func (*PacketReader) Pos

func (p *PacketReader) Pos() int

Pos returns the current position

func (*PacketReader) ReadFloat32

func (p *PacketReader) ReadFloat32() float32

ReadFloat32 reads a float32

func (*PacketReader) ReadIPv4

func (p *PacketReader) ReadIPv4() (net.IP, error)

ReadIPv4 reads an IPv4 address

func (*PacketReader) ReadInt32

func (p *PacketReader) ReadInt32() int32

ReadInt32 reads an int32

func (*PacketReader) ReadPort

func (p *PacketReader) ReadPort() (uint16, error)

ReadPort reads a port

func (*PacketReader) ReadString

func (p *PacketReader) ReadString() string

ReadString reads a string

func (*PacketReader) ReadUint16

func (p *PacketReader) ReadUint16() uint16

ReadUint16 reads a uint16

func (*PacketReader) ReadUint32

func (p *PacketReader) ReadUint32() uint32

ReadUint32 reads a uint32

func (*PacketReader) ReadUint64

func (p *PacketReader) ReadUint64() uint64

ReadUint64 reads a uint64

func (*PacketReader) ReadUint8

func (p *PacketReader) ReadUint8() uint8

ReadUint8 reads a uint8

func (*PacketReader) Split

func (p *PacketReader) Split(count int) []byte

Split returns the remaining bytes

func (*PacketReader) TryReadString

func (p *PacketReader) TryReadString() (string, error)

TryReadString reads a string

type Udp

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

func NewUdp

func NewUdp(address string, timeout time.Duration) (*Udp, error)

func (*Udp) Close

func (u *Udp) Close() error

func (*Udp) Connect

func (u *Udp) Connect() error

func (*Udp) Receive

func (u *Udp) Receive() ([]byte, error)

func (*Udp) RemoteAddr

func (u *Udp) RemoteAddr() net.Addr

func (*Udp) Send

func (u *Udp) Send(data []byte) error

func (*Udp) SetRateLimit

func (u *Udp) SetRateLimit(ratePerMinute int)

func (*Udp) SetTimeout

func (u *Udp) SetTimeout(duration time.Duration)