encoder

Documentation

Index

• func EncodeHeader(packetType byte, header *packet.Header, remLength int, buff []byte) (int, error)
• func WithStatRecorder(recorder StatRecorder) option
• type BufferProvider
• type Encoder
  • func New(opts ...option) *Encoder
  • func (e *Encoder) ConnAck(w io.Writer, p *packet.ConnAck) error
  • func (e *Encoder) Encode(w io.Writer, p packet.Packet) error
  • func (e *Encoder) Marshal(p packet.Packet) ([]byte, error)
  • func (e *Encoder) PingResp(w io.Writer, p *packet.PingResp) error
  • func (e *Encoder) PubAck(w io.Writer, p *packet.PubAck) error
  • func (e *Encoder) Publish(w io.Writer, p *packet.Publish) error
  • func (e *Encoder) SubAck(w io.Writer, p *packet.SubAck) error
  • func (e *Encoder) UnsubAck(w io.Writer, p *packet.UnsubAck) error
• type StatRecorder

Functions

func EncodeHeader

func EncodeHeader(packetType byte, header *packet.Header, remLength int, buff []byte) (int, error)

func WithStatRecorder

func WithStatRecorder(recorder StatRecorder) option

Types

type BufferProvider

type BufferProvider interface {
	New(size int) ([]byte, error)
}

type Encoder

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

func New

func New(opts ...option) *Encoder

func (*Encoder) ConnAck

func (e *Encoder) ConnAck(w io.Writer, p *packet.ConnAck) error

func (*Encoder) Encode

func (e *Encoder) Encode(w io.Writer, p packet.Packet) error

func (*Encoder) Marshal

func (e *Encoder) Marshal(p packet.Packet) ([]byte, error)

func (*Encoder) PingResp

func (e *Encoder) PingResp(w io.Writer, p *packet.PingResp) error

func (*Encoder) PubAck

func (e *Encoder) PubAck(w io.Writer, p *packet.PubAck) error

func (*Encoder) Publish

func (e *Encoder) Publish(w io.Writer, p *packet.Publish) error

func (*Encoder) SubAck

func (e *Encoder) SubAck(w io.Writer, p *packet.SubAck) error

func (*Encoder) UnsubAck

func (e *Encoder) UnsubAck(w io.Writer, p *packet.UnsubAck) error

type StatRecorder

type StatRecorder interface {
	Add(float64)
}