chain_flusher

Documentation

Index

• type Flusher
  • func NewFlusher(storeList []Storage, flushMu *sync.RWMutex, chainDir string) (*Flusher, error)
  • func (flusher *Flusher) Abort()
  • func (flusher *Flusher) Close() error
  • func (flusher *Flusher) Flush()
  • func (flusher *Flusher) LoadRedo(fd *os.File) ([][]byte, []Storage, error)
  • func (flusher *Flusher) Recover() error
  • func (flusher *Flusher) ReplaceStore(id types.Hash, store Storage)
  • func (flusher *Flusher) Start()
  • func (flusher *Flusher) Stop()
• type Storage

Types

type Flusher

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

func NewFlusher

func NewFlusher(storeList []Storage, flushMu *sync.RWMutex, chainDir string) (*Flusher, error)

func (*Flusher) Abort

func (flusher *Flusher) Abort()

func (*Flusher) Close

func (flusher *Flusher) Close() error

func (*Flusher) Flush

func (flusher *Flusher) Flush()

force to flush synchronously

func (*Flusher) LoadRedo

func (flusher *Flusher) LoadRedo(fd *os.File) ([][]byte, []Storage, error)

func (*Flusher) Recover

func (flusher *Flusher) Recover() error

func (*Flusher) ReplaceStore

func (flusher *Flusher) ReplaceStore(id types.Hash, store Storage)

func (*Flusher) Start

func (flusher *Flusher) Start()

func (*Flusher) Stop

func (flusher *Flusher) Stop()

type Storage

type Storage interface {
	Id() types.Hash

	Prepare()

	CancelPrepare()

	RedoLog() ([]byte, error)

	Commit() error

	AfterCommit()

	BeforeRecover([]byte)

	AfterRecover()

	PatchRedoLog([]byte) error
}