cache

type CapacityDependencies struct {
	Repositories              *repository.Repositories
	Cache                     cache.Cache
	CacheTracker              *cacheaccess.Tracker
	Scheduler                 *taskengine.Scheduler
	State                     *State
	PressureListener          PressureListener
	EvictionPolicy            cache.EvictionPolicy
	MaxCacheBytes             int64
	MaxWriteBytes             int64
	LRUHighPercent            int
	LRULowPercent             int
	CommitSealOnCachePressure bool
}

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

type DurabilityDependencies struct {
	Repositories   *repository.Repositories
	Scheduler      *taskengine.Scheduler
	EvictionPolicy cache.EvictionPolicy
}

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

type EvictDependencies struct {
	Repositories   *repository.Repositories
	Cache          cache.Cache
	CacheGate      *cacheaccess.Gate
	CacheTracker   *cacheaccess.Tracker
	State          *State
	EvictionPolicy cache.EvictionPolicy
	MaxCacheBytes  int64
	MaxWriteBytes  int64
	LRULowPercent  int
}

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

type EvictionDependencies struct {
	Scheduler      *taskengine.Scheduler
	EvictionPolicy cache.EvictionPolicy
}

type LocalDependencies struct {
	Repositories   *repository.Repositories
	Cache          cache.Cache
	CacheGate      *cacheaccess.Gate
	CacheTracker   *cacheaccess.Tracker
	Scheduler      *taskengine.Scheduler
	EvictionPolicy cache.EvictionPolicy
	Logger         *slog.Logger
}

type LocalFilesystem interface {
	ListUploadIDs(context.Context) ([]string, error)
	WalkContentFiles(context.Context, bool, func(bucket string, contentID int64) error) error
	Quarantine(context.Context, string, int64) error
	DeleteQuarantined(context.Context, string, int64) error
}

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

type PressureListener interface{ OnCachePressure(context.Context) error }

type State struct {
	// contains filtered or unexported fields
}