immuta

Jun 12, 2026

Changes in this version

type OptionFunc

+ func WithSyncOnSave(enabled bool) OptionFunc

Jan 6, 2026

Changes in this version

+ var ErrReaderCountIsZero = errors.New("reader count must be greater than zero")

type Appender

+ Save func(err *error)

type Storage

+ func (s *Storage) Save(namespace string, err *error)

Nov 27, 2025

Changes in this version

type OptionFunc

+ func WithReadTransform(t Transformer) OptionFunc

+ func WithWriteTransform(t Transformer) OptionFunc

+ type Transformer func(r io.Reader) (io.Reader, error)

+ func ChainTransformers(transformers ...Transformer) Transformer

Oct 1, 2025

Changes in this version

+ var ErrStorageClosed = errors.New("storage is closed")

Oct 1, 2025

Changes in this version

+ type Compressor interface

+ Compress func(r io.Reader) (io.Reader, error)

+ Decompress func(r io.Reader) (io.Reader, error)

type OptionFunc

+ func WithCompression(compressor Compressor) OptionFunc

Jan 9, 2025

Changes in this version

+ var ErrNamesapceNotFound = errors.New("namespace not found")

+ var ErrNamespaceRequired = errors.New("namespace is required")

+ type OptionFunc func(*options) error

+ func WithLogsDirPath(path string) OptionFunc

+ func WithNamespaces(namespaces ...string) OptionFunc

+ func WithReaderCount(count int) OptionFunc

Nov 4, 2024

Changes in this version

+ const FileHeaderSize

+ const RecordHeaderSize

+ type Reader struct

+ func (r *Reader) Done() error

+ func (r *Reader) Read(p []byte) (n int, err error)

type Storage

+ func (s *Storage) Details() (string, error)

+ func (s *Storage) Verify() error

Oct 11, 2024

Changes in this version

+ const HeaderSize

+ type Appender interface

+ Append func(r io.Reader) (size int64, err error)

+ type Storage struct

+ func New(opts ...StorageOpt) (*Storage, error)

+ func (f *Storage) Append(r io.Reader) (size int64, err error)

+ func (f *Storage) Close() error

+ func (f *Storage) LastIndex() int64

+ func (f *Storage) Size() int64

+ func (f *Storage) Stream(ctx context.Context, opts ...StreamOpt) (Stream, error)

+ type StorageOpt interface

+ func WithFastWrite(path string) StorageOpt

+ func WithHighDurability(path string) StorageOpt

+ func WithQueueSize(size int) StorageOpt

+ type Stream interface

+ Done func()

+ Next func() (r io.Reader, size int64, err error)

+ type StreamOpt interface

+ func WithAbsolutePosition(idx int64) StreamOpt

+ func WithRelativeMessage(count int64) StreamOpt