decoder

Documentation

Index

• func Decode(r io.Reader, buf []byte) (packet.Packet, error)
• type Packet
  • func (p Packet) Err() error
  • func (local Packet) Less(remote btree.Item) bool
  • func (p Packet) Value() interface{}
• type StatRecorder
• type Sync
  • func New(maxPacketSize int) *Sync
  • func (s *Sync) Decode(r io.Reader) (packet.Packet, error)

Functions

func Decode

func Decode(r io.Reader, buf []byte) (packet.Packet, error)

Types

type Packet

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

func (Packet) Err

func (p Packet) Err() error

func (Packet) Less

func (local Packet) Less(remote btree.Item) bool

func (Packet) Value

func (p Packet) Value() interface{}

type StatRecorder

type StatRecorder interface {
	Add(float64)
}

type Sync

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

func New

func New(maxPacketSize int) *Sync

func (*Sync) Decode

func (s *Sync) Decode(r io.Reader) (packet.Packet, error)