wal

Apr 6, 2023

Changes in this version

+ const FileIDByteSize

+ var ErrSegmentNotOpen = errors.New("segment not open")

+ type FileID struct

+ Rand int64

+ Time int64

+ func CreateFileID(t, r int64) FileID

+ func NextFileID() FileID

+ func ParseFileID(fileID string) (FileID, bool)

+ func (f FileID) Equal(target FileID) bool

+ func (f FileID) IsZero() bool

+ func (f FileID) Newer(target FileID) bool

+ func (f FileID) String() string

type Log

+ func (l *Log) Segments() int

+ func (l *Log) Size() uint64

type OptionFunc

+ func WithMaxSegmentSize(size uint64) OptionFunc

Feb 19, 2023

Changes in this version

+ type DataLoadFunc func(Index, []byte)

type OptionFunc

+ func WithDataLoadFunc(fn DataLoadFunc) OptionFunc

Feb 19, 2023

Changes in this version

type Log

+ func (l *Log) ReadFrom(r io.Reader) (int64, error)

+ func (l *Log) WriteTo(w io.Writer) (int64, error)

Feb 18, 2023

Changes in this version

+ var ErrLocked = errors.Errorf("locked")

+ type FileLocker struct

+ func NewFileLocker(path string) *FileLocker

+ func (lock *FileLocker) TryLock() error

+ func (lock *FileLocker) Unlock() error

+ type Locker interface

+ TryLock func() error

+ Unlock func() error

type Log

+ func (l *Log) NeedCompaction() bool

type OptionFunc

+ func WithCloseCompaction(enable bool) OptionFunc

Feb 12, 2023

Changes in this version

+ const AppName

+ const Version

+ var ErrClosed = errors.New("closed")

+ var ErrCompactRunning = errors.New("compat already in progress")

+ var ErrLogLocked = errors.New("cloed")

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

+ type Index codec.ID

+ type Log struct

+ func Open(dir string, funcs ...OptionFunc) (*Log, error)

+ func (l *Log) Close() error

+ func (l *Log) Compact() error

+ func (l *Log) Delete(idxs ...Index) error

+ func (l *Log) LastIndex() Index

+ func (l *Log) Len() int

+ func (l *Log) Read(idx Index) ([]byte, error)

+ func (l *Log) ReclaimableSpace() uint64

+ func (l *Log) Sync() error

+ func (l *Log) Write(data []byte) (Index, error)

+ func (l *Log) WriteAt(idx Index, data []byte) error

+ type OptionFunc func(*logOpt)

+ func WithSync(enable bool) OptionFunc

+ func WithWriteBufferSize(size int) OptionFunc