work

type FullStoreFile = block.Range

type Job struct {
	ModuleName   string // target
	RequestRange *block.Range
	// contains filtered or unexported fields
}

type ModuleStorageState struct {
	ModuleName         string
	ModuleInitialBlock uint64

	InitialCompleteRange *FullStoreFile // Points to a complete .kv file, to initialize the store upon getting started.
	PartialsMissing      PartialStoreFiles
	PartialsPresent      PartialStoreFiles
}

type ModuleStorageStateMap map[string]*ModuleStorageState

type PartialStoreFile = block.Range

type PartialStoreFiles = block.Ranges

type Plan struct {
	ModulesStateMap ModuleStorageStateMap
	// contains filtered or unexported fields
}

type Prioritizer interface {
	Sort(jobs []*Job) []*Job
}

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

type Result struct {
	PartialsWritten []*block.Range
	Error           error
}

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

type Snapshot struct {
	block.Range
	Path string
}

type Snapshots struct {
	Completes block.Ranges // Shortest completes first, largest last.
	Partials  block.Ranges // First partials first, last last
}

type StorageState struct {
	sync.Mutex
	Snapshots map[string]*Snapshots
}

type Worker interface {
	Work(ctx context.Context, request *pbsubstreams.Request, respFunc substreams.ResponseFunc) *Result
}

type WorkerFactory = func(logger *zap.Logger) Worker

type WorkerFunc func(ctx context.Context, request *pbsubstreams.Request, respFunc substreams.ResponseFunc) *Result

type WorkerPool interface {
	Borrow(context.Context) Worker
	Return(Worker)
}