Versions in this module Expand all Collapse all v0 v0.0.2 Apr 20, 2023 Changes in this version + type Error string + func (e Error) Error() string + type RingBuffer struct + func NewRingBuffer(size int) *RingBuffer + func (r *RingBuffer) Add(item interface{}) + func (r *RingBuffer) OldestCursor() int + func (r *RingBuffer) ReadFrom(cursor int) ([]interface{}, int) + type Streamer struct + func NewStreamer(sb *SyncBuffer) *Streamer + func (st *Streamer) Close() + func (st *Streamer) Stream() chan []byte + type SyncBuffer struct + func NewSyncBuffer(freq time.Duration, size int) *SyncBuffer + func (sb *SyncBuffer) Add(item []byte) + func (sb *SyncBuffer) Close()
Go to main page