aof

Documentation

Overview

Package aof handles AOF logging in standalone mode only. Logging in replication clusters is handled in the raft layer.

Index

• func WithAppendReadWriter(rw logstore.ReadWriter) func(engine *Engine)
• func WithClock(clock clock.Clock) func(engine *Engine)
• func WithDirectory(directory string) func(engine *Engine)
• func WithFinishRewriteFunc(f func()) func(engine *Engine)
• func WithGetStateFunc(f func() map[int]map[string]internal.KeyData) func(engine *Engine)
• func WithHandleCommandFunc(f func(database int, command []byte)) func(engine *Engine)
• func WithPreambleReadWriter(rw preamble.ReadWriter) func(engine *Engine)
• func WithSetKeyDataFunc(f func(database int, key string, data internal.KeyData)) func(engine *Engine)
• func WithStartRewriteFunc(f func()) func(engine *Engine)
• func WithStrategy(strategy string) func(engine *Engine)
• type Engine
  • func NewAOFEngine(options ...func(engine *Engine)) (*Engine, error)
  • func (engine *Engine) Close()
  • func (engine *Engine) LogCommand(database int, command []byte)
  • func (engine *Engine) Restore() error
  • func (engine *Engine) RewriteLog() error

Functions

func WithAppendReadWriter

func WithAppendReadWriter(rw logstore.ReadWriter) func(engine *Engine)

func WithClock

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

func WithDirectory

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

func WithFinishRewriteFunc

func WithFinishRewriteFunc(f func()) func(engine *Engine)

func WithGetStateFunc

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

func WithHandleCommandFunc

func WithHandleCommandFunc(f func(database int, command []byte)) func(engine *Engine)

func WithPreambleReadWriter

func WithPreambleReadWriter(rw preamble.ReadWriter) func(engine *Engine)

func WithSetKeyDataFunc

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

func WithStartRewriteFunc

func WithStartRewriteFunc(f func()) func(engine *Engine)

func WithStrategy

func WithStrategy(strategy string) func(engine *Engine)

Types

type Engine

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

func NewAOFEngine

func NewAOFEngine(options ...func(engine *Engine)) (*Engine, error)

func (*Engine) Close

func (engine *Engine) Close()

func (*Engine) LogCommand

func (engine *Engine) LogCommand(database int, command []byte)

func (*Engine) Restore

func (engine *Engine) Restore() error

func (*Engine) RewriteLog

func (engine *Engine) RewriteLog() error