commit

type Dependencies struct {
	Repositories *repository.Repositories
	Scheduler    *taskengine.Scheduler
	RetryPolicy  interface {
		RetryableContext(context.Context, *model.Task) (bool, error)
	}
	Messenger                 *taskengine.Messenger
	Resolver                  ReadyDataSetResolver
	CommitNonces              synapse.CommitNonceReader
	ParkedPieces              synapse.ParkedPieceChecker
	Cache                     cache.Cache
	EvictionPolicy            cache.EvictionPolicy
	Pressure                  PressureReader
	CommitSealOnCachePressure bool
	CommitMaxPieces           int
	CommitMaxWait             time.Duration
	LegacyPieceStorageIDLimit uint64
	Logger                    *slog.Logger
}

type Handler struct {
	*taskengine.FuncHandler
	// contains filtered or unexported fields
}

type PressureReader interface {
	TargetBytes() (int64, bool)
}

type ReadyDataSetResolver interface {
	ExecutionIdentity(context.Context, *model.StorageDataSet) (storagepipeline.ExecutionIdentity, error)
	OpenReadyDataSet(context.Context, *model.StorageDataSet) (synapse.DataSetTarget, error)
}