packet

Documentation

Index

• func NewCFB8Decrypt(block cipher.Block, iv []byte) (stream cipher.Stream)
• func NewCFB8Encrypt(block cipher.Block, iv []byte) (stream cipher.Stream)
• func NewFullReader(reader io.Reader) (this io.Reader)
• func ReadBool(reader io.Reader) (val bool, err error)
• func ReadFloat32(reader io.Reader) (val float32, err error)
• func ReadFloat64(reader io.Reader) (val float64, err error)
• func ReadInt16(reader io.Reader) (val int16, err error)
• func ReadInt32(reader io.Reader) (val int32, err error)
• func ReadInt64(reader io.Reader) (val int64, err error)
• func ReadInt8(reader io.Reader) (val int8, err error)
• func ReadString(reader io.Reader) (val string, err error)
• func ReadUUID(reader io.Reader) (result uuid.UUID, err error)
• func ReadUint16(reader io.Reader) (val uint16, err error)
• func ReadUint32(reader io.Reader) (val uint32, err error)
• func ReadUint64(reader io.Reader) (val uint64, err error)
• func ReadUint8(reader io.Reader) (val uint8, err error)
• func ReadVarInt(reader io.Reader) (result int, err error)
• func WriteBool(writer io.Writer, val bool) (err error)
• func WriteFixedBitSet(writer io.Writer, val *BitSet, size int) (err error)
• func WriteFloat32(writer io.Writer, val float32) (err error)
• func WriteFloat64(writer io.Writer, val float64) (err error)
• func WriteInt16(writer io.Writer, val int16) (err error)
• func WriteInt32(writer io.Writer, val int32) (err error)
• func WriteInt64(writer io.Writer, val int64) (err error)
• func WriteInt8(writer io.Writer, val int8) (err error)
• func WriteString(writer io.Writer, val string) (err error)
• func WriteUUID(writer io.Writer, val uuid.UUID) (err error)
• func WriteUint16(writer io.Writer, val uint16) (err error)
• func WriteUint32(writer io.Writer, val uint32) (err error)
• func WriteUint64(writer io.Writer, val uint64) (err error)
• func WriteUint8(writer io.Writer, val uint8) (err error)
• func WriteVarInt(writer io.Writer, val int) (err error)
• type BitSet
  • func NewBitSet(initialSize int) *BitSet
  • func NewBitSetFrom(bytes []byte) *BitSet
  • func ReadFixedBitSet(reader io.Reader, size int) (val *BitSet, err error)
  • func (this *BitSet) Get(bitIndex int) bool
  • func (this *BitSet) Len() int
  • func (this *BitSet) Set(bitIndex int)
  • func (this *BitSet) ToByteArray() []byte
• type Byteser
• type Packet
• type PacketCodec
• type PacketCodecCfb8
  • func NewPacketCodecCfb8(sharedSecret []byte) (this *PacketCodecCfb8, err error)
  • func (this *PacketCodecCfb8) Decode(reader io.Reader) (packet Packet, err error)
  • func (this *PacketCodecCfb8) Encode(writer io.Writer, packet Packet) (err error)
  • func (this *PacketCodecCfb8) SetCodec(codec PacketCodec)
• type PacketCodecRegistry
  • func NewPacketCodecRegistry(codecs []PacketCodec) (this *PacketCodecRegistry)
  • func NewPacketCodecRegistryDual(encodeCodecs []PacketCodec, decodeCodecs []PacketCodec) (this *PacketCodecRegistry)
  • func (this *PacketCodecRegistry) Copy() (thisCopy *PacketCodecRegistry)
  • func (this *PacketCodecRegistry) Decode(reader io.Reader) (packet Packet, err error)
  • func (this *PacketCodecRegistry) Encode(writer io.Writer, packet Packet) (err error)
  • func (this *PacketCodecRegistry) Flip() (thisCopy *PacketCodecRegistry)
  • func (this *PacketCodecRegistry) SetCodec(codec PacketCodec)
  • func (this *PacketCodecRegistry) SetInterceptDecode(intercept PacketIntercept)
  • func (this *PacketCodecRegistry) SetInterceptEncode(intercept PacketIntercept)
• type PacketCodecVarIntLength
  • func NewPacketCodecVarIntLength() (this *PacketCodecVarIntLength)
  • func (this *PacketCodecVarIntLength) Decode(reader io.Reader) (packet Packet, err error)
  • func (this *PacketCodecVarIntLength) Encode(writer io.Writer, packet Packet) (err error)
  • func (this *PacketCodecVarIntLength) SetCodec(codec PacketCodec)
• type PacketCodecZlib
  • func NewPacketCodecZlib(threshold int) (this *PacketCodecZlib)
  • func NewPacketCodecZlibLevel(threshold int, level int) (this *PacketCodecZlib)
  • func (this *PacketCodecZlib) Decode(reader io.Reader) (packet Packet, err error)
  • func (this *PacketCodecZlib) Encode(writer io.Writer, packet Packet) (err error)
  • func (this *PacketCodecZlib) SetCodec(codec PacketCodec)
• type PacketConnCodec
  • func NewPacketConnCodec(conn net.Conn, packetCodec PacketCodec, timeout time.Duration) (this *PacketConnCodec)
  • func (this *PacketConnCodec) ReadConn(packetHandler PacketHandler)
  • func (this *PacketConnCodec) SetTimeout(timeout time.Duration)
  • func (this *PacketConnCodec) Write(packet Packet) (err error)
• type PacketDecodeError
  • func (this PacketDecodeError) Error() string
• type PacketHandler
• type PacketIntercept
• type PacketPipeline
  • func NewPacketPipeline() (this *PacketPipeline)
  • func (this *PacketPipeline) AddAfter(name string, subject string, child PacketPipelineChild) (err error)
  • func (this *PacketPipeline) AddBefore(name string, subject string, child PacketPipelineChild) (err error)
  • func (this *PacketPipeline) AddFirst(name string, child PacketPipelineChild) (err error)
  • func (this *PacketPipeline) AddLast(name string, child PacketPipelineChild) (err error)
  • func (this *PacketPipeline) Decode(reader io.Reader) (packet Packet, err error)
  • func (this *PacketPipeline) Encode(writer io.Writer, packet Packet) (err error)
  • func (this *PacketPipeline) Get(name string) (child PacketPipelineChild)
  • func (this *PacketPipeline) HasName(name string) (ok bool)
  • func (this *PacketPipeline) Remove(name string) (err error)
  • func (this *PacketPipeline) Replace(name string, child PacketPipelineChild) (err error)
• type PacketPipelineChild
• type PacketRaw
• type ZlibToggleReader
  • func NewZlibToggleReaderBuffer(rawBytes []byte, zlibBytes []byte) (this *ZlibToggleReader, err error)
  • func (this *ZlibToggleReader) Close() (err error)
  • func (this *ZlibToggleReader) Read(p []byte) (n int, err error)
  • func (this *ZlibToggleReader) SetCompression(compression bool)
  • func (this *ZlibToggleReader) SetRaw(raw bool)

Functions

func NewCFB8Decrypt

func NewCFB8Decrypt(block cipher.Block, iv []byte) (stream cipher.Stream)

func NewCFB8Encrypt

func NewCFB8Encrypt(block cipher.Block, iv []byte) (stream cipher.Stream)

func NewFullReader

func NewFullReader(reader io.Reader) (this io.Reader)

func ReadBool

func ReadBool(reader io.Reader) (val bool, err error)

func ReadFloat32

func ReadFloat32(reader io.Reader) (val float32, err error)

func ReadFloat64

func ReadFloat64(reader io.Reader) (val float64, err error)

func ReadInt16

func ReadInt16(reader io.Reader) (val int16, err error)

func ReadInt32

func ReadInt32(reader io.Reader) (val int32, err error)

func ReadInt64

func ReadInt64(reader io.Reader) (val int64, err error)

func ReadInt8

func ReadInt8(reader io.Reader) (val int8, err error)

func ReadString

func ReadString(reader io.Reader) (val string, err error)

func ReadUUID

func ReadUUID(reader io.Reader) (result uuid.UUID, err error)

func ReadUint16

func ReadUint16(reader io.Reader) (val uint16, err error)

func ReadUint32

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

func ReadUint64

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

func ReadUint8

func ReadUint8(reader io.Reader) (val uint8, err error)

func ReadVarInt

func ReadVarInt(reader io.Reader) (result int, err error)

func WriteBool

func WriteBool(writer io.Writer, val bool) (err error)

func WriteFixedBitSet

func WriteFixedBitSet(writer io.Writer, val *BitSet, size int) (err error)

func WriteFloat32

func WriteFloat32(writer io.Writer, val float32) (err error)

func WriteFloat64

func WriteFloat64(writer io.Writer, val float64) (err error)

func WriteInt16

func WriteInt16(writer io.Writer, val int16) (err error)

func WriteInt32

func WriteInt32(writer io.Writer, val int32) (err error)

func WriteInt64

func WriteInt64(writer io.Writer, val int64) (err error)

func WriteInt8

func WriteInt8(writer io.Writer, val int8) (err error)

func WriteString

func WriteString(writer io.Writer, val string) (err error)

func WriteUUID

func WriteUUID(writer io.Writer, val uuid.UUID) (err error)

func WriteUint16

func WriteUint16(writer io.Writer, val uint16) (err error)

func WriteUint32

func WriteUint32(writer io.Writer, val uint32) (err error)

func WriteUint64

func WriteUint64(writer io.Writer, val uint64) (err error)

func WriteUint8

func WriteUint8(writer io.Writer, val uint8) (err error)

func WriteVarInt

func WriteVarInt(writer io.Writer, val int) (err error)

Types

type BitSet

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

func NewBitSet

func NewBitSet(initialSize int) *BitSet

func NewBitSetFrom

func NewBitSetFrom(bytes []byte) *BitSet

func ReadFixedBitSet

func ReadFixedBitSet(reader io.Reader, size int) (val *BitSet, err error)

func (*BitSet) Get

func (this *BitSet) Get(bitIndex int) bool

func (*BitSet) Len

func (this *BitSet) Len() int

func (*BitSet) Set

func (this *BitSet) Set(bitIndex int)

func (*BitSet) ToByteArray

func (this *BitSet) ToByteArray() []byte

type Byteser

type Byteser interface {
	Bytes() []byte
}

type Packet

type Packet interface {
	Id() int
}

type PacketCodec

type PacketCodec interface {
	Decode(reader io.Reader) (packet Packet, err error)
	Encode(writer io.Writer, packet Packet) (err error)
}

type PacketCodecCfb8

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

func NewPacketCodecCfb8

func NewPacketCodecCfb8(sharedSecret []byte) (this *PacketCodecCfb8, err error)

func (*PacketCodecCfb8) Decode

func (this *PacketCodecCfb8) Decode(reader io.Reader) (packet Packet, err error)

func (*PacketCodecCfb8) Encode

func (this *PacketCodecCfb8) Encode(writer io.Writer, packet Packet) (err error)

func (*PacketCodecCfb8) SetCodec

func (this *PacketCodecCfb8) SetCodec(codec PacketCodec)

type PacketCodecRegistry

type PacketCodecRegistry struct {
	EncodeCodecs []PacketCodec
	DecodeCodecs []PacketCodec
	// contains filtered or unexported fields
}

func NewPacketCodecRegistry

func NewPacketCodecRegistry(codecs []PacketCodec) (this *PacketCodecRegistry)

func NewPacketCodecRegistryDual

func NewPacketCodecRegistryDual(encodeCodecs []PacketCodec, decodeCodecs []PacketCodec) (this *PacketCodecRegistry)

func (*PacketCodecRegistry) Copy

func (this *PacketCodecRegistry) Copy() (thisCopy *PacketCodecRegistry)

func (*PacketCodecRegistry) Decode

func (this *PacketCodecRegistry) Decode(reader io.Reader) (packet Packet, err error)

func (*PacketCodecRegistry) Encode

func (this *PacketCodecRegistry) Encode(writer io.Writer, packet Packet) (err error)

func (*PacketCodecRegistry) Flip

func (this *PacketCodecRegistry) Flip() (thisCopy *PacketCodecRegistry)

func (*PacketCodecRegistry) SetCodec

func (this *PacketCodecRegistry) SetCodec(codec PacketCodec)

func (*PacketCodecRegistry) SetInterceptDecode

func (this *PacketCodecRegistry) SetInterceptDecode(intercept PacketIntercept)

func (*PacketCodecRegistry) SetInterceptEncode

func (this *PacketCodecRegistry) SetInterceptEncode(intercept PacketIntercept)

type PacketCodecVarIntLength

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

func NewPacketCodecVarIntLength

func NewPacketCodecVarIntLength() (this *PacketCodecVarIntLength)

func (*PacketCodecVarIntLength) Decode

func (this *PacketCodecVarIntLength) Decode(reader io.Reader) (packet Packet, err error)

func (*PacketCodecVarIntLength) Encode

func (this *PacketCodecVarIntLength) Encode(writer io.Writer, packet Packet) (err error)

func (*PacketCodecVarIntLength) SetCodec

func (this *PacketCodecVarIntLength) SetCodec(codec PacketCodec)

type PacketCodecZlib

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

func NewPacketCodecZlib

func NewPacketCodecZlib(threshold int) (this *PacketCodecZlib)

func NewPacketCodecZlibLevel

func NewPacketCodecZlibLevel(threshold int, level int) (this *PacketCodecZlib)

func (*PacketCodecZlib) Decode

func (this *PacketCodecZlib) Decode(reader io.Reader) (packet Packet, err error)

func (*PacketCodecZlib) Encode

func (this *PacketCodecZlib) Encode(writer io.Writer, packet Packet) (err error)

func (*PacketCodecZlib) SetCodec

func (this *PacketCodecZlib) SetCodec(codec PacketCodec)

type PacketConnCodec

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

func NewPacketConnCodec

func NewPacketConnCodec(conn net.Conn, packetCodec PacketCodec, timeout time.Duration) (this *PacketConnCodec)

func (*PacketConnCodec) ReadConn

func (this *PacketConnCodec) ReadConn(packetHandler PacketHandler)

func (*PacketConnCodec) SetTimeout

func (this *PacketConnCodec) SetTimeout(timeout time.Duration)

func (*PacketConnCodec) Write

func (this *PacketConnCodec) Write(packet Packet) (err error)

type PacketDecodeError

type PacketDecodeError struct {
	Id    int
	Codec PacketCodec
	Err   error
}

func (PacketDecodeError) Error

func (this PacketDecodeError) Error() string

type PacketHandler

type PacketHandler interface {
	HandlePacket(packet Packet) (err error)
	ErrorCaught(err error)
}

type PacketIntercept

type PacketIntercept func(Packet, *bytes.Buffer) error

type PacketPipeline

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

func NewPacketPipeline

func NewPacketPipeline() (this *PacketPipeline)

func (*PacketPipeline) AddAfter

func (this *PacketPipeline) AddAfter(name string, subject string, child PacketPipelineChild) (err error)

func (*PacketPipeline) AddBefore

func (this *PacketPipeline) AddBefore(name string, subject string, child PacketPipelineChild) (err error)

func (*PacketPipeline) AddFirst

func (this *PacketPipeline) AddFirst(name string, child PacketPipelineChild) (err error)

func (*PacketPipeline) AddLast

func (this *PacketPipeline) AddLast(name string, child PacketPipelineChild) (err error)

func (*PacketPipeline) Decode

func (this *PacketPipeline) Decode(reader io.Reader) (packet Packet, err error)

func (*PacketPipeline) Encode

func (this *PacketPipeline) Encode(writer io.Writer, packet Packet) (err error)

func (*PacketPipeline) Get

func (this *PacketPipeline) Get(name string) (child PacketPipelineChild)

func (*PacketPipeline) HasName

func (this *PacketPipeline) HasName(name string) (ok bool)

func (*PacketPipeline) Remove

func (this *PacketPipeline) Remove(name string) (err error)

func (*PacketPipeline) Replace

func (this *PacketPipeline) Replace(name string, child PacketPipelineChild) (err error)

type PacketPipelineChild

type PacketPipelineChild interface {
	PacketCodec
	SetCodec(codec PacketCodec)
}

type PacketRaw

type PacketRaw interface {
	Raw() bool
}

type ZlibToggleReader

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

func NewZlibToggleReaderBuffer

func NewZlibToggleReaderBuffer(rawBytes []byte, zlibBytes []byte) (this *ZlibToggleReader, err error)

func (*ZlibToggleReader) Close

func (this *ZlibToggleReader) Close() (err error)

func (*ZlibToggleReader) Read

func (this *ZlibToggleReader) Read(p []byte) (n int, err error)

func (*ZlibToggleReader) SetCompression

func (this *ZlibToggleReader) SetCompression(compression bool)

func (*ZlibToggleReader) SetRaw

func (this *ZlibToggleReader) SetRaw(raw bool)