utils

Jun 7, 2023

Changes in this version

+ func StealBytes(reader io.WriterTo) ([]byte, error)

+ type ByteStealer struct

+ Data []byte

+ func (s *ByteStealer) Write(p []byte) (n int, err error)

Jun 2, 2023

Changes in this version

+ var ErrDisposed = errors.New(`queue: disposed`)

+ var ErrEmpty = errors.New(`queue: empty queue`)

+ var ErrTimeout = errors.New(`queue: poll timed out`)

+ type RingBuffer struct

+ func NewRingBuffer(size uint64) *RingBuffer

+ func (rb *RingBuffer) Cap() uint64

+ func (rb *RingBuffer) Dispose()

+ func (rb *RingBuffer) Get() (interface{}, error)

+ func (rb *RingBuffer) IsDisposed() bool

+ func (rb *RingBuffer) Len() uint64

+ func (rb *RingBuffer) Offer(item interface{}) (bool, error)

+ func (rb *RingBuffer) Poll(timeout time.Duration) (interface{}, error)

+ func (rb *RingBuffer) Put(item interface{}) error

+ type SpinLocker int32

+ func (s *SpinLocker) Lock()

+ func (s *SpinLocker) Unlock()

May 31, 2023

Changes in this version

+ func Assert(err error, msg ...interface{})

+ func AssertBytes(b []byte, err error) []byte

+ func AssertIf(exp bool, msg string, args ...interface{})

+ func AssertLength(n int, err error) int

+ func AssertLong(n int64, err error) int64

+ func CountOf(buffs [][]byte) (n int64)

+ func MustToBytes(message interface{}) []byte

+ func MustToReader(message interface{}) io.Reader

+ func ToBytes(message interface{}) ([]byte, error)

+ func ToReader(message interface{}) (io.Reader, error)

+ type ByteReader interface

+ func NewByteReader(r io.Reader) ByteReader