Versions in this module Expand all Collapse all v1 v1.2.0 May 15, 2020 Changes in this version + const GiB + func BytesToGiB(volumeSizeBytes int64) int64 + func CleanupMountPoint(mountPath string, mounter mount.Interface, extensiveMountPointCheck bool) error + func GetK8sNamespace() string + func GiBToBytes(volumeSizeGiB int64) int64 + func IsCorruptedMnt(err error) bool + func NewK8sClient() *k8s.Clientset + func PathExists(path string) (bool, error) + func RoundUpBytes(volumeSizeBytes int64) int64 + func RoundUpGiB(volumeSizeBytes int64) int64 + type CacheEntryNotFound struct + type CachePersister interface + Create func(identifier string, data interface{}) error + Delete func(identifier string) error + ForAll func(pattern string, destObj interface{}, f ForAllFunc) error + Get func(identifier string, data interface{}) error + func NewCachePersister() CachePersister + type ForAllFunc func(identifier string) error + type Idempotent struct + func NewIdempotent() *Idempotent + func (idem *Idempotent) Delete(h RequestItem) + func (idem *Idempotent) Insert(entry RequestItem) bool + type K8sCMCache struct + Client *k8s.Clientset + Namespace string + func (k8scm *K8sCMCache) Create(identifier string, data interface{}) error + func (k8scm *K8sCMCache) Delete(identifier string) error + func (k8scm *K8sCMCache) ForAll(pattern string, destObj interface{}, f ForAllFunc) error + func (k8scm *K8sCMCache) Get(identifier string, data interface{}) error + type RequestItem interface + String func() string
Go to main page