codec

Documentation

Index

• Constants
• func NewDecryptReader(r io.Reader, secret []byte) (reader io.Reader, err error)
• func NewEncryptWriter(w io.Writer, secret []byte) (wr io.Writer, err error)
• type Decoder
  • func NewDecoder(r io.Reader, direction proto.Direction, log logr.Logger) *Decoder
  • func (d *Decoder) Decode() (ctx *proto.PacketContext, err error)
  • func (d *Decoder) SetCompressionThreshold(threshold int)
  • func (d *Decoder) SetProtocol(protocol proto.Protocol)
  • func (d *Decoder) SetReader(rd io.Reader)
  • func (d *Decoder) SetState(state *state.Registry)
• type Encoder
  • func NewEncoder(w io.Writer, direction proto.Direction) *Encoder
  • func (e *Encoder) SetCompression(threshold, level int) (err error)
  • func (e *Encoder) SetProtocol(protocol proto.Protocol)
  • func (e *Encoder) SetState(state *state.Registry)
  • func (e *Encoder) SetWriter(w io.Writer)
  • func (e *Encoder) Sync(fn func() error) error
  • func (e *Encoder) Write(payload []byte) (n int, err error)
  • func (e *Encoder) WritePacket(packet proto.Packet) (n int, err error)

Constants

const (
	VanillaMaximumUncompressedSize = 2 * 1024 * 1024  // 2MiB
	HardMaximumUncompressedSize    = 16 * 1024 * 1024 // 16MiB
	UncompressedCap                = VanillaMaximumUncompressedSize
)

Functions

func NewDecryptReader

func NewDecryptReader(r io.Reader, secret []byte) (reader io.Reader, err error)

func NewEncryptWriter

func NewEncryptWriter(w io.Writer, secret []byte) (wr io.Writer, err error)

Types

type Decoder

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

Decoder is a synchronized packet decoder for the Minecraft Java edition.

func NewDecoder

func NewDecoder(
	r io.Reader,
	direction proto.Direction,
	log logr.Logger,
) *Decoder

func (*Decoder) Decode

func (d *Decoder) Decode() (ctx *proto.PacketContext, err error)

Decode reads the next packet from the underlying reader. It blocks other calls to Decode until return.

func (*Decoder) SetCompressionThreshold

func (d *Decoder) SetCompressionThreshold(threshold int)

func (*Decoder) SetProtocol

func (d *Decoder) SetProtocol(protocol proto.Protocol)

func (*Decoder) SetReader

func (d *Decoder) SetReader(rd io.Reader)

func (*Decoder) SetState

func (d *Decoder) SetState(state *state.Registry)

type Encoder

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

Encoder is a synchronized packet encoder.

func NewEncoder

func NewEncoder(w io.Writer, direction proto.Direction) *Encoder

func (*Encoder) SetCompression

func (e *Encoder) SetCompression(threshold, level int) (err error)

func (*Encoder) SetProtocol

func (e *Encoder) SetProtocol(protocol proto.Protocol)

func (*Encoder) SetState

func (e *Encoder) SetState(state *state.Registry)

func (*Encoder) SetWriter

func (e *Encoder) SetWriter(w io.Writer)

func (*Encoder) Sync

func (e *Encoder) Sync(fn func() error) error

Sync locks the encoder while running fn, making sure no writes calls are run during this call.

func (*Encoder) Write

func (e *Encoder) Write(payload []byte) (n int, err error)

Write encodes payload (uncompressed and unencrypted, containing packed id + data) and writes it to the underlying writer.

func (*Encoder) WritePacket

func (e *Encoder) WritePacket(packet proto.Packet) (n int, err error)