Versions in this module Expand all Collapse all v0 v0.1.1 Oct 29, 2026 Changes in this version + const LocalReconcileInterval + type LocalDependencies struct + Cache cache.Cache + CacheGate *cacheaccess.Gate + CacheTracker *cacheaccess.Tracker + EvictionPolicy cache.EvictionPolicy + Logger *slog.Logger + Repositories *repository.Repositories + Scheduler *taskengine.Scheduler + type LocalFilesystem interface + DeleteQuarantined func(context.Context, string, int64) error + ListUploadIDs func(context.Context) ([]string, error) + Quarantine func(context.Context, string, int64) error + WalkContentFiles func(context.Context, bool, func(bucket string, contentID int64) error) error + type LocalHandler struct + func NewLocalHandler(deps LocalDependencies) (*LocalHandler, error) v0.1.0 Oct 20, 2026 Changes in this version + func NewContentDurabilityReachedSubscriber(deps EvictionDependencies) (taskengine.MessageHandler, error) + func NewEvictCacheContentReceiver(deps EvictionDependencies) (taskengine.MessageHandler, error) + type CapacityDependencies struct + Cache cache.Cache + CacheTracker *cacheaccess.Tracker + CommitSealOnCachePressure bool + EvictionPolicy cache.EvictionPolicy + LRUHighPercent int + LRULowPercent int + MaxCacheBytes int64 + MaxWriteBytes int64 + PressureListener PressureListener + Repositories *repository.Repositories + Scheduler *taskengine.Scheduler + State *State + type CapacityHandler struct + func NewCapacityHandler(deps CapacityDependencies) (*CapacityHandler, error) + type DurabilityDependencies struct + EvictionPolicy cache.EvictionPolicy + Repositories *repository.Repositories + Scheduler *taskengine.Scheduler + type DurabilityHandler struct + func NewDurabilityHandler(deps DurabilityDependencies) (*DurabilityHandler, error) + type EvictDependencies struct + Cache cache.Cache + CacheGate *cacheaccess.Gate + CacheTracker *cacheaccess.Tracker + EvictionPolicy cache.EvictionPolicy + LRULowPercent int + MaxCacheBytes int64 + MaxWriteBytes int64 + Repositories *repository.Repositories + State *State + type EvictHandler struct + func NewEvictHandler(deps EvictDependencies) (*EvictHandler, error) + type EvictionDependencies struct + EvictionPolicy cache.EvictionPolicy + Scheduler *taskengine.Scheduler + type PressureListener interface + OnCachePressure func(context.Context) error + type State struct + func NewState() *State + func (s *State) TargetBytes() (int64, bool)