checkpoint

Documentation

Index

• func NewDriver(scheduler tasks.TaskScheduler, cfg *PolicyCfg) *ckpDriver
• type Driver
• type LeveledPolicy
• type LeveledUnits
  • func NewLeveledUnits(scheduler tasks.TaskScheduler, policy LeveledPolicy) *LeveledUnits
  • func (lunits *LeveledUnits) AddUnit(unit data.CheckpointUnit)
  • func (lunits *LeveledUnits) RunCalibration()
  • func (lunits *LeveledUnits) Scan()
• type PolicyCfg
• type Units
  • func NewUnits() *Units
  • func (units *Units) AddUnit(u data.CheckpointUnit)
  • func (units *Units) AddUnits(us []data.CheckpointUnit)
  • func (units *Units) ConsumeAll() map[data.CheckpointUnit]bool
  • func (units *Units) PrepareConsume(maxDuration time.Duration) bool
  • func (units *Units) UpdateTS()

Functions

func NewDriver

func NewDriver(scheduler tasks.TaskScheduler, cfg *PolicyCfg) *ckpDriver

Types

type Driver

type Driver interface {
	// aware.ChangeAware
	// aware.DataMutationAware
	EnqueueCheckpointUnit(unit data.CheckpointUnit)
	EnqueueCheckpointEntry(wal.LogEntry)
	Start()
	Stop()
	String() string
}

type LeveledPolicy

type LeveledPolicy interface {
	TotalLevels() int
	DecideLevel(score int) int
	ScanInterval(level int) time.Duration
}

var DefaultLeveledPolicy LeveledPolicy

type LeveledUnits

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

func NewLeveledUnits

func NewLeveledUnits(scheduler tasks.TaskScheduler, policy LeveledPolicy) *LeveledUnits

func (*LeveledUnits) AddUnit

func (lunits *LeveledUnits) AddUnit(unit data.CheckpointUnit)

func (*LeveledUnits) RunCalibration

func (lunits *LeveledUnits) RunCalibration()

func (*LeveledUnits) Scan

func (lunits *LeveledUnits) Scan()

type PolicyCfg

type PolicyCfg struct {
	Interval int64 // ms
	Levels   int
}

type Units

type Units struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewUnits

func NewUnits() *Units

func (*Units) AddUnit

func (units *Units) AddUnit(u data.CheckpointUnit)

func (*Units) AddUnits

func (units *Units) AddUnits(us []data.CheckpointUnit)

func (*Units) ConsumeAll

func (units *Units) ConsumeAll() map[data.CheckpointUnit]bool

func (*Units) PrepareConsume

func (units *Units) PrepareConsume(maxDuration time.Duration) bool

func (*Units) UpdateTS

func (units *Units) UpdateTS()