memlog

Jan 17, 2022

Changes in this version

type Log

+ func (l *Log) ReadBatch(ctx context.Context, offset Offset, batch []Record) (int, error)

Jan 13, 2022

Changes in this version

+ type Stream struct

+ func (s *Stream) Err() error

+ func (s *Stream) Next() (r Record, ok bool)

Jan 5, 2022

Changes in this version

+ const DefaultMaxRecordDataBytes

+ const DefaultSegmentSize

+ const DefaultStartOffset

+ var ErrFutureOffset = errors.New("future offset")

+ var ErrOutOfRange = errors.New("offset out of range")

+ var ErrRecordTooLarge = errors.New("record data too large")

+ var ErrSlowReader = errors.New("slow reader blocking stream channel send")

+ type Header struct

+ Created time.Time

+ Offset Offset

+ type Log struct

+ func New(_ context.Context, options ...Option) (*Log, error)

+ func (l *Log) Range(_ context.Context) (earliest, latest Offset)

+ func (l *Log) Read(ctx context.Context, offset Offset) (Record, error)

+ func (l *Log) Stream(ctx context.Context, start Offset) (<-chan StreamRecord, <-chan error)

+ func (l *Log) Write(ctx context.Context, data []byte) (Offset, error)

+ type Offset int

+ type Option func(*Log) error

+ func WithClock(c clock.Clock) Option

+ func WithMaxRecordDataSize(size int) Option

+ func WithMaxSegmentSize(size int) Option

+ func WithStartOffset(offset Offset) Option

+ type Record struct

+ Data []byte

+ Metadata Header

+ type StreamHeader struct

+ Earliest Offset

+ Latest Offset

+ type StreamRecord struct

+ Metadata StreamHeader

+ Record Record