frontier

Documentation

Index

• type Frontier
  • func NewFrontier(checkpointTs uint64, spans ...tablepb.Span) Frontier

Types

type Frontier

type Frontier interface {
	Forward(regionID uint64, span tablepb.Span, ts uint64)
	Frontier() uint64
	String() string
	SpanString(span tablepb.Span) string
	Entries(fn func(key []byte, ts uint64))
}

Frontier checks resolved event of spans and moves the global resolved ts ahead

func NewFrontier

func NewFrontier(checkpointTs uint64, spans ...tablepb.Span) Frontier

NewFrontier creates Frontier from the given spans. spanFrontier don't support use Nil as the maximum key of End range So we use set it as util.UpperBoundKey, the means the real use case *should not* have an End key bigger than util.UpperBoundKey