Versions in this module Expand all Collapse all v0 v0.1.1 Oct 29, 2026 v0.1.0 Oct 20, 2026 Changes in this version + func NewDataSetReadySubscriber(handler *Handler) (taskengine.MessageHandler, error) + func NewJoinCommitReceiver(handler *Handler) (taskengine.MessageHandler, error) + type Dependencies struct + Cache cache.Cache + CommitMaxPieces int + CommitMaxWait time.Duration + CommitNonces synapse.CommitNonceReader + CommitSealOnCachePressure bool + EvictionPolicy cache.EvictionPolicy + LegacyPieceStorageIDLimit uint64 + Logger *slog.Logger + Messenger *taskengine.Messenger + ParkedPieces synapse.ParkedPieceChecker + Pressure PressureReader + Repositories *repository.Repositories + Resolver ReadyDataSetResolver + RetryPolicy interface{ ... } + Scheduler *taskengine.Scheduler + type Handler struct + func NewHandler(deps Dependencies) (*Handler, error) + func (h *Handler) OnCachePressure(ctx context.Context) error + type PressureReader interface + TargetBytes func() (int64, bool) + type ReadyDataSetResolver interface + ExecutionIdentity func(context.Context, *model.StorageDataSet) (storagepipeline.ExecutionIdentity, error) + OpenReadyDataSet func(context.Context, *model.StorageDataSet) (synapse.DataSetTarget, error)