message

Jan 29, 2023

Changes in this version

+ const OffsetInvalid

+ const OffsetNewest

+ const OffsetOldest

+ var ErrCorrupted = errors.New("message corrupted")

+ var ErrInvalidOffset = errors.New("invalid offset")

+ var ErrNotFound = errors.New("not found")

+ var Invalid = Message

+ func Size(m Message) int64

+ func ValidateOffset(offset int64) error

+ type Message struct

+ Key []byte

+ Offset int64

+ Time time.Time

+ Value []byte

+ func Gen(count int) []Message

+ type Reader struct

+ Path string

+ func OpenReader(path string) (*Reader, error)

+ func OpenReaderMem(path string) (*Reader, error)

+ func (r *Reader) Close() error

+ func (r *Reader) Consume(position int64, maxCount int64) ([]Message, error)

+ func (r *Reader) Get(position int64) (Message, error)

+ func (r *Reader) Read(position int64) (Message, int64, error)

+ type Writer struct

+ Path string

+ func OpenWriter(path string) (*Writer, error)

+ func (w *Writer) Close() error

+ func (w *Writer) Size() int64

+ func (w *Writer) Sync() error

+ func (w *Writer) SyncAndClose() error

+ func (w *Writer) Write(m Message) (int64, error)