packet

package
v0.0.0-...-82a22e8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 11, 2023 License: GPL-3.0 Imports: 15 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Source Files

View all Source files

Directories

Path Synopsis
nbt
v112
v1121
v113
v114
v115
v116
v1162
v117
v118
v119
v1191
v1193
v17
v18
v19

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.