Documentation
¶
Index ¶
- func NewContentDurabilityReachedSubscriber(deps EvictionDependencies) (taskengine.MessageHandler, error)
- func NewEvictCacheContentReceiver(deps EvictionDependencies) (taskengine.MessageHandler, error)
- type CapacityDependencies
- type CapacityHandler
- type DurabilityDependencies
- type DurabilityHandler
- type EvictDependencies
- type EvictHandler
- type EvictionDependencies
- type PressureListener
- type State
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContentDurabilityReachedSubscriber ¶
func NewContentDurabilityReachedSubscriber(deps EvictionDependencies) (taskengine.MessageHandler, error)
func NewEvictCacheContentReceiver ¶
func NewEvictCacheContentReceiver(deps EvictionDependencies) (taskengine.MessageHandler, error)
Types ¶
type CapacityDependencies ¶
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 ¶
type CapacityHandler struct {
*taskengine.FuncHandler
// contains filtered or unexported fields
}
func NewCapacityHandler ¶
func NewCapacityHandler(deps CapacityDependencies) (*CapacityHandler, error)
type DurabilityDependencies ¶
type DurabilityDependencies struct {
Repositories *repository.Repositories
Scheduler *taskengine.Scheduler
EvictionPolicy cache.EvictionPolicy
}
type DurabilityHandler ¶
type DurabilityHandler struct {
*taskengine.FuncHandler
// contains filtered or unexported fields
}
func NewDurabilityHandler ¶
func NewDurabilityHandler(deps DurabilityDependencies) (*DurabilityHandler, error)
type EvictDependencies ¶
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 ¶
type EvictHandler struct {
*taskengine.FuncHandler
// contains filtered or unexported fields
}
func NewEvictHandler ¶
func NewEvictHandler(deps EvictDependencies) (*EvictHandler, error)
type EvictionDependencies ¶
type EvictionDependencies struct {
Scheduler *taskengine.Scheduler
EvictionPolicy cache.EvictionPolicy
}
type PressureListener ¶
Click to show internal directories.
Click to hide internal directories.