shard

Documentation

Index

• func NewFixer(shardID int, pr common.PersistenceRetryer, blobstoreClient blobstore.Client, ...) common.Fixer
• func NewScanner(shardID int, pr common.PersistenceRetryer, persistencePageSize int, ...) common.Scanner

Functions

func NewFixer

func NewFixer(
	shardID int,
	pr common.PersistenceRetryer,
	blobstoreClient blobstore.Client,
	keys common.Keys,
	blobstoreFlushThreshold int,
	invariantCollections []common.InvariantCollection,
	progressReportFn func(),
	scanType common.ScanType,
) common.Fixer

NewFixer constructs a new fixer

func NewScanner

func NewScanner(
	shardID int,
	pr common.PersistenceRetryer,
	persistencePageSize int,
	blobstoreClient blobstore.Client,
	blobstoreFlushThreshold int,
	invariantCollections []common.InvariantCollection,
	progressReportFn func(),
	scanType common.ScanType,
) common.Scanner

NewScanner constructs a new scanner