ondisk

Oct 3, 2023

Changes in this version

+ const B

+ const GB

+ const KB

+ const MB

Apr 11, 2023

Changes in this version

+ type Stream struct

+ func Init(name string, ctx context.Context) (es *Stream, err error)

+ func (es *Stream) End() (pos uint64, err error)

+ func (es *Stream) Name() string

+ func (es *Stream) Stream(from store.StreamPosition, ctx context.Context) (out <-chan store.ReadEvent, err error)

+ func (es *Stream) Write() chan<- store.WriteEvent