bucket

Documentation

Index

• Constants
• Variables
• type Bucket
  • func NewBucket[T number](capacity int) *Bucket[T]
  • func (b *Bucket[T]) AddPacket(pkt []byte) ([]byte, error)
  • func (b *Bucket[T]) AddPacketWithSequenceNumber(pkt []byte, sn T) ([]byte, error)
  • func (b *Bucket[T]) Capacity() int
  • func (b *Bucket[T]) GetPacket(buf []byte, sn T) (int, error)
  • func (b *Bucket[T]) Grow() int
  • func (b *Bucket[T]) HeadSequenceNumber() T
  • func (b *Bucket[T]) ResyncOnNextPacket()

Constants

const (
	MaxPktSize = 1500
)

Variables

var (
	ErrBufferTooSmall    = errors.New("buffer too small")
	ErrPacketTooOld      = errors.New("received packet too old")
	ErrPacketTooNew      = errors.New("received packet too new")
	ErrRTXPacket         = errors.New("packet already received")
	ErrRTXPacketSize     = errors.New("packet already received, size mismatch")
	ErrPacketMismatch    = errors.New("sequence number mismatch")
	ErrPacketSizeInvalid = errors.New("invalid size")
	ErrPacketTooLarge    = errors.New("packet too large")
)

Types

type Bucket

type Bucket[T number] struct {
	// contains filtered or unexported fields
}

func NewBucket

func NewBucket[T number](capacity int) *Bucket[T]

func (*Bucket[T]) AddPacket

func (b *Bucket[T]) AddPacket(pkt []byte) ([]byte, error)

func (*Bucket[T]) AddPacketWithSequenceNumber

func (b *Bucket[T]) AddPacketWithSequenceNumber(pkt []byte, sn T) ([]byte, error)

func (*Bucket[T]) Capacity

func (b *Bucket[T]) Capacity() int

func (*Bucket[T]) GetPacket

func (b *Bucket[T]) GetPacket(buf []byte, sn T) (int, error)

func (*Bucket[T]) Grow

func (b *Bucket[T]) Grow() int

Grow increases the capacity of the bucket by adding initial capacity to the buffer

func (*Bucket[T]) HeadSequenceNumber

func (b *Bucket[T]) HeadSequenceNumber() T

func (*Bucket[T]) ResyncOnNextPacket

func (b *Bucket[T]) ResyncOnNextPacket()