wal

Documentation

Index

• Constants
• type Driver
  • func NewDriver(dir, name string, cfg *store.StoreCfg) Driver
  • func NewDriverWithStore(impl store.Store, own bool) Driver
• type Index
  • func NewIndex(lsn uint64, csn, size uint32) *Index
  • func (index *Index) Clone() *Index
  • func (index *Index) Compare(o *Index) int
  • func (index *Index) ReadFrom(r io.Reader) (n int64, err error)
  • func (index *Index) String() string
  • func (index *Index) WriteTo(w io.Writer) (n int64, err error)
• type LogEntry
• type ReplayObserver

Constants

const (
	GroupUC        = entry.GTUncommit
	GroupC  uint32 = iota + 10
	GroupCatalog
)

Types

type Driver

type Driver interface {
	GetCheckpointed() uint64
	Checkpoint(indexes []*Index) (LogEntry, error)
	AppendEntry(uint32, LogEntry) (uint64, error)
	LoadEntry(groupId uint32, lsn uint64) (LogEntry, error)
	GetCurrSeqNum() uint64
	GetPenddingCnt() uint64
	Compact() error
	Replay(handle store.ApplyHandle) (err error)
	Close() error
}

func NewDriver

func NewDriver(dir, name string, cfg *store.StoreCfg) Driver

func NewDriverWithStore

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

type Index

type Index struct {
	LSN  uint64
	CSN  uint32
	Size uint32
}

func NewIndex

func NewIndex(lsn uint64, csn, size uint32) *Index

func (*Index) Clone

func (index *Index) Clone() *Index

func (*Index) Compare

func (index *Index) Compare(o *Index) int

func (*Index) ReadFrom

func (index *Index) ReadFrom(r io.Reader) (n int64, err error)

func (*Index) String

func (index *Index) String() string

func (*Index) WriteTo

func (index *Index) WriteTo(w io.Writer) (n int64, err error)

type LogEntry

type LogEntry entry.Entry

type ReplayObserver

type ReplayObserver interface {
	OnTimeStamp(uint64)
	OnStaleIndex(*Index)
}