frontier

package
v0.0.0-...-be15534 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2024 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL