Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrCacheAdmissionRejected = moerr.NewInternalErrorNoCtx("cache admission rejected")
Functions ¶
This section is empty.
Types ¶
type CapacityFunc ¶
type CapacityFunc func() int64
func CachingCapacity ¶
func CachingCapacity( upstream CapacityFunc, duration time.Duration, ) CapacityFunc
func ConstCapacity ¶
func ConstCapacity(capacity int64) CapacityFunc
type DataCache ¶
type DataCache interface {
EnsureNBytes(ctx context.Context, want int)
Capacity() int64
Used() int64
Available() int64
Get(context.Context, CacheKey) (Data, bool)
Set(context.Context, CacheKey, Data) error
DeletePaths(context.Context, []string)
Flush(ctx context.Context)
Evict(ctx context.Context, done chan int64)
EvictToTargetWithWait(ctx context.Context, target int64) int64
}
Click to show internal directories.
Click to hide internal directories.