Versions in this module Expand all Collapse all v0 v0.18.3 Apr 18, 2022 v0.18.2 Apr 18, 2022 Changes in this version + const HardMaximumUncompressedSize + const UncompressedCap + const VanillaMaximumUncompressedSize + 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 struct + 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 struct + 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)