etcdwal

Documentation

Index

• type WalManager
  • func NewWalManager(walDir string, logger *zap.Logger) *WalManager
  • func (e *WalManager) CreateWal(metadata babuzapb.WalMetadata) (ibabuza.EntryStorage, ibabuza.Wal, error)
  • func (e *WalManager) FindSnapshot() ([]walpb.Snapshot, error)
  • func (e *WalManager) HasExistingWals() (bool, error)
  • func (e *WalManager) PurgeWals(purgeCfg ibabuza.WalPurgeConfig)
  • func (e *WalManager) ReplayWal(snapshot *raftpb.Snapshot, deleteUncommitted bool) (ibabuza.EntryStorage, ibabuza.Wal, ibabuza.ReplayWalResult, error)
• type WalWrapper
  • func NewWalWrapper(w *wal.WAL) *WalWrapper
  • func (w *WalWrapper) Purge(snap raftpb.Snapshot) error
  • func (w *WalWrapper) SaveSnapshot(snap raftpb.Snapshot) error

Types

type WalManager

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

func NewWalManager

func NewWalManager(walDir string, logger *zap.Logger) *WalManager

func (*WalManager) CreateWal

func (e *WalManager) CreateWal(metadata babuzapb.WalMetadata) (ibabuza.EntryStorage, ibabuza.Wal, error)

func (*WalManager) FindSnapshot

func (e *WalManager) FindSnapshot() ([]walpb.Snapshot, error)

func (*WalManager) HasExistingWals

func (e *WalManager) HasExistingWals() (bool, error)

func (*WalManager) PurgeWals

func (e *WalManager) PurgeWals(purgeCfg ibabuza.WalPurgeConfig)

StartWalPurgingProcess is to release the locks, which has smaller index than the given index except the largest one among them. For example, if WAL is holding lock 1,2,3,4,5,6, ReleaseLockTo(4) will release lock 1,2 but keep 3. ReleaseLockTo(5) will release 1,2,3 but keep 4.

func (*WalManager) ReplayWal

func (e *WalManager) ReplayWal(snapshot *raftpb.Snapshot, deleteUncommitted bool) (
	ibabuza.EntryStorage, ibabuza.Wal, ibabuza.ReplayWalResult, error)

type WalWrapper

type WalWrapper struct {
	*wal.WAL
}

func NewWalWrapper

func NewWalWrapper(w *wal.WAL) *WalWrapper

func (*WalWrapper) Purge

func (w *WalWrapper) Purge(snap raftpb.Snapshot) error

func (*WalWrapper) SaveSnapshot

func (w *WalWrapper) SaveSnapshot(snap raftpb.Snapshot) error