block

type BlockProcessor interface {
	// PreWork performs tasks that need to be done before the main processing loop starts.
	// In parallel mode, this method is called by a single instance.
	PreWork(ctx context.Context) error

	// ProcessBlock processes the provided block, retrieving all required information
	// from source storage and committing an atomically-executed batch of queries
	// to target storage.
	//
	// The implementation must commit processed blocks (update the analysis.processed_blocks record with processed_time timestamp).
	ProcessBlock(ctx context.Context, height uint64) error
	// FinalizeFastSync updates any data that was neglected during the indexing of blocks
	// up to and including `lastFastSyncHeight`, e.g. dead-reckoned balances.
	// It is intended to be used when an analyzer wishes to transition from fast-sync mode
	// into slow-sync mode. If the analyzer never used fast-sync and is starting from
	// height 0 in slow-sync mode, `lastFastSyncHeight` will be -1.
	// The method should be a no-op if all the blocks up to `height` have been analyzed
	// in slow-sync mode, assuming no bugs in dead reckoning code.
	FinalizeFastSync(ctx context.Context, lastFastSyncHeight int64) error
}