wal

Documentation

Index

• Constants
• type Driver
  • func NewDriverWithBatchStore(dir, name string, cfg *DriverConfig) Driver
  • func NewDriverWithLogservice(factory logservicedriver.LogServiceClientFactory) Driver
  • func NewDriverWithStore(impl store.Store, own bool, ckpDuration time.Duration) Driver
• type DriverConfig
• type Index
• type LogEntry
• type ReplayObserver

Constants

const (
	GroupC uint32 = iota + 10
	GroupUC
	GroupPrepare
	GroupCatalog
)

Types

type Driver

type Driver interface {
	GetCheckpointed() uint64
	Checkpoint(indexes []*Index) (LogEntry, error)
	RangeCheckpoint(start, end uint64) (e LogEntry, err error)
	AppendEntry(uint32, LogEntry) (uint64, error)
	LoadEntry(groupID uint32, lsn uint64) (LogEntry, error)
	GetCurrSeqNum() uint64
	GetPenddingCnt() uint64
	Replay(handle store.ApplyHandle) error
	Start()
	Close() error
}

func NewDriverWithBatchStore

func NewDriverWithBatchStore(dir, name string, cfg *DriverConfig) Driver

func NewDriverWithLogservice

func NewDriverWithLogservice(factory logservicedriver.LogServiceClientFactory) Driver

func NewDriverWithStore

func NewDriverWithStore(impl store.Store, own bool, ckpDuration time.Duration) Driver

type DriverConfig

type DriverConfig struct {
	BatchStoreConfig   *batchstoredriver.StoreCfg
	CheckpointDuration time.Duration
}

type Index

type Index = store.Index

type LogEntry

type LogEntry entry.Entry

type ReplayObserver

type ReplayObserver interface {
	OnTimeStamp(ts types.TS)
	OnStaleIndex(*Index)
}