Versions in this module Expand all Collapse all v0 v0.9.0 Apr 11, 2023 Changes in this version + type Buffer struct + func New(i int) *Buffer + func (b *Buffer) Get(n int) []*Entry + func (b *Buffer) Put(v interface{}) + func (b *Buffer) Since(t time.Time) []*Entry + func (b *Buffer) Size() int + func (b *Buffer) Stream() (<-chan *Entry, chan bool) + type Entry struct + Timestamp time.Time + Value interface{} + type Stream struct + Entries chan *Entry + Id string + Stop chan bool
Go to main page