wal

Apr 1, 2021

Changes in this version

type WAL

+ func (w *WAL) SnapshotUseful() bool

Mar 31, 2021

Changes in this version

+ func Cleanup(dir string) error

+ func OldFiles(dir string) ([]string, error)

+ func PartialFiles(dir string) ([]string, error)

Mar 30, 2021

Changes in this version

type Loader

+ Load func(context.Context, []byte) error

+ type LoaderFunc func(context.Context, []byte) error

+ func (f LoaderFunc) Load(ctx context.Context, b []byte) error

type Option

+ func WithJournalPlayerFunc(f PlayerFunc) Option

+ func WithSnapshotLoaderFunc(f LoaderFunc) Option

+ type Player interface

+ Play func(context.Context, []byte) error

+ type PlayerFunc func(context.Context, []byte) error

+ func (f PlayerFunc) Play(ctx context.Context, b []byte) error

Mar 23, 2021

Changes in this version

type WAL

+ func (w *WAL) CanSnapshot() bool

+ func (w *WAL) CheckCanSnapshot() error

Mar 22, 2021

Changes in this version

type FileMeta

+ func (m *FileMeta) String() string

type Option

+ func WithRequireEmpty(e bool) Option

+ type Snapshotter func(ValueAdder) error

+ type ValueAdder interface

+ AddValue func([]byte) error

type WAL

+ func (w *WAL) CreateSnapshot(s Snapshotter) (string, error)

+ func (w *WAL) Finalize() error

Mar 21, 2021

Changes in this version

+ const FinalSuffix

+ const OldPrefix

+ const PartPrefix

+ type FileMeta struct

+ Base string

+ Index uint64

+ IsFinal bool

+ IsOld bool

+ IsPart bool

+ Name string

type Option

+ func WithEmptyJournalPlayer(a bool) Option

+ func WithEmptySnapshotLoader(a bool) Option

+ func WithExcludeLiveJournal(e bool) Option

+ func WithSnapshotLoader(a Loader) Option

Mar 19, 2021

Changes in this version

type Option

+ func WithAllowEmptyJournalPlayer(a bool) Option

Mar 19, 2021

Changes in this version

+ const DefaultJournalBase

+ const DefaultSnapshotBase

+ func CreateSnapshot(dir, base string, idx uint64) (*stuffedio.WALStuffer, error)

type Option

+ func WithJournalBase(p string) Option

+ func WithSnapshotBase(p string) Option

Mar 19, 2021

Changes in this version

+ const DefaultJournalPrefix

+ const DefaultMaxBytes

+ const DefaultMaxIndices

+ const DefaultSnapshotPrefix

+ func CheckIndexName(name, prefix string, index uint64) error

+ func IndexName(prefix string, idx uint64) string

+ func ParseIndexName(name string) (prefix string, index uint64, err error)

+ type Loader func([]byte) error

+ type Option func(*WAL)

+ func WithAllowEmptySnapshotAdder(a bool) Option

+ func WithAllowWrite(a bool) Option

+ func WithJournalPlayer(p Loader) Option

+ func WithJournalPrefix(p string) Option

+ func WithMaxJournalBytes(m int64) Option

+ func WithMaxJournalIndices(m int) Option

+ func WithSnapshotAdder(a Loader) Option

+ func WithSnapshotPrefix(p string) Option

+ type WAL struct

+ func Open(dir string, opts ...Option) (*WAL, error)

+ func (w *WAL) Append(b []byte) error

+ func (w *WAL) Close() error

+ func (w *WAL) CurrIndex() uint64