snapshot

Documentation

Index

• func WithClock(clock clock.Clock) func(engine *Engine)
• func WithDirectory(directory string) func(engine *Engine)
• func WithFinishSnapshotFunc(f func()) func(engine *Engine)
• func WithGetLatestSnapshotTimeFunc(f func() int64) func(engine *Engine)
• func WithGetStateFunc(f func() map[int]map[string]internal.KeyData) func(engine *Engine)
• func WithInterval(interval time.Duration) func(engine *Engine)
• func WithSetKeyDataFunc(f func(database int, key string, data internal.KeyData)) func(engine *Engine)
• func WithSetLatestSnapshotTimeFunc(f func(mset int64)) func(engine *Engine)
• func WithStartSnapshotFunc(f func()) func(engine *Engine)
• func WithThreshold(threshold uint64) func(engine *Engine)
• type Engine
  • func NewSnapshotEngine(options ...func(engine *Engine)) *Engine
  • func (engine *Engine) IncrementChangeCount()
  • func (engine *Engine) Restore() error
  • func (engine *Engine) TakeSnapshot() error
• type Manifest

Functions

func WithClock

func WithClock(clock clock.Clock) func(engine *Engine)

func WithDirectory

func WithDirectory(directory string) func(engine *Engine)

func WithFinishSnapshotFunc

func WithFinishSnapshotFunc(f func()) func(engine *Engine)

func WithGetLatestSnapshotTimeFunc

func WithGetLatestSnapshotTimeFunc(f func() int64) func(engine *Engine)

func WithGetStateFunc

func WithGetStateFunc(f func() map[int]map[string]internal.KeyData) func(engine *Engine)

func WithInterval

func WithInterval(interval time.Duration) func(engine *Engine)

func WithSetKeyDataFunc

func WithSetKeyDataFunc(f func(database int, key string, data internal.KeyData)) func(engine *Engine)

func WithSetLatestSnapshotTimeFunc

func WithSetLatestSnapshotTimeFunc(f func(mset int64)) func(engine *Engine)

func WithStartSnapshotFunc

func WithStartSnapshotFunc(f func()) func(engine *Engine)

func WithThreshold

func WithThreshold(threshold uint64) func(engine *Engine)

Types

type Engine

type Engine struct {
	// contains filtered or unexported fields
}

func NewSnapshotEngine

func NewSnapshotEngine(options ...func(engine *Engine)) *Engine

func (*Engine) IncrementChangeCount

func (engine *Engine) IncrementChangeCount()

func (*Engine) Restore

func (engine *Engine) Restore() error

func (*Engine) TakeSnapshot

func (engine *Engine) TakeSnapshot() error

type Manifest

type Manifest struct {
	LatestSnapshotMilliseconds int64
	LatestSnapshotHash         [16]byte
}