Skip to main content

internal/formation/projectrebuild.go

internal/formation · 68 lines · 4 declarations · source

Declarations​

const MaxRebuildPage​

const MaxRebuildPage = 100

source

type ProjectRebuilder​

type ProjectRebuilder struct {
	rebuilder *Rebuilder
	jobs      *pg.RebuildJobStore
}

source

func NewProjectRebuilder​

func NewProjectRebuilder(rebuilder *Rebuilder, jobs *pg.RebuildJobStore) *ProjectRebuilder

source

method ProjectRebuilder.RunPage​

func (r *ProjectRebuilder) RunPage(ctx context.Context, schema pg.Schema, scope, key, actor string, limit int) (pg.RebuildJob, error)

RunPage is restartable from its durable pending offset. A publication whose progress write was interrupted replays its source operation key, so retries do not spend another inference call.

source