wal

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 18, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.6.0 

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

func NewDriverWithLogservice added in v0.6.0 

func NewDriverWithLogservice(factory logservicedriver.LogServiceClientFactory) Driver

func NewDriverWithStore 

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

type DriverConfig added in v0.6.0 

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)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.