BytesToGiB conversts Bytes to GiB.

GetK8sNamespace returns pod namespace.

GiBToBytes converts GiB to Bytes.

IsCorruptedMnt return true if err is about corrupted mount point.

NewCachePersister returns K8sCachePersister.

NewIdempotent instanciates a Idempotent structures.

NewK8sClient create kubernetes client.

NewVolumeLocks returns new VolumeLocks.

PathExists TODO: clean this up to use pkg/util/file/FileExists PathExists returns true if the specified path exists.

RoundUpBytes rounds up the volume size in bytes upto multiplications of GiB in the unit of Bytes.

RoundUpGiB rounds up the volume size in bytes upto multiplications of GiB in the unit of GiB.

CacheEntryNotFound is an error type for "Not Found" cache errors.

Idempotent is a struct used to manage in flight requests.

K8sCMCache to store metadata.

VolumeLocks implements a map with atomic operations.

CachePersister interface implemented for store.

RequestItem is the interface required to manage in flight requests.

ForAllFunc is a unary predicate for visiting all cache entries matching the `pattern' in CachePersister's ForAll function.