task

type Dependencies struct {
	Repositories                  *repository.Repositories
	DecorateTaskHandler           func(taskengine.Handler) taskengine.Handler
	Events                        EventPublisher
	Cache                         cache.Cache
	CacheGate                     *cacheaccess.Gate
	CacheTracker                  *cacheaccess.Tracker
	Storage                       synapse.StorageClient
	Wallet                        synapse.WalletOperator
	Receipts                      wallet.WalletReceiptChecker
	WalletBroadcastTimeout        time.Duration
	WalletReceiptTimeout          time.Duration
	Terminator                    synapse.ServiceTerminator
	Epochs                        synapse.ChainEpochReader
	RemovalChain                  synapse.RemovalChainReader
	Observability                 *observability.Service
	UploadSpeedProbe              providerbenchmark.UploadProbe
	UploadSpeedTestAutoScope      string
	UploadSpeedTestRetestInterval time.Duration
	UploadConcurrency             int
	ParkedPieces                  synapse.ParkedPieceChecker
	CommitNonces                  synapse.CommitNonceReader
	EvictionPolicy                cache.EvictionPolicy
	MaxCacheBytes                 int64
	MaxWriteBytes                 int64 // largest single cache write; 0 means no room is kept for it
	LRUHighPercent                int
	LRULowPercent                 int
	AnchorProviderTier            providerselect.Tier
	DefaultCopies                 int

	// CommitMaxPieces, CommitMaxWait and CommitMaxBacklog shape how transferred
	// copies of one data set are registered together.
	CommitMaxPieces           int
	CommitMaxWait             time.Duration
	CommitMaxBacklog          int
	CommitSealOnCachePressure bool
	RemovalMaxPieces          int
	RemovalMaxWait            time.Duration
	// LegacyPieceStorageIDLimit is the first data set ID of the deployment's
	// compact piece layout; zero applies no legacy piece limit.
	LegacyPieceStorageIDLimit uint64
	Logger                    *slog.Logger
}

type EntryPoints struct {
	AdminReplacement     *taskengine.Messenger
	AdminCopyRetry       *taskengine.Messenger
	BackendCacheEviction *taskengine.Messenger
}

type EventPublisher interface {
	Publish(string, map[string]any)
}