util

package

Go to main page

Versions in this module

v1

v1.2.2

Nov 21, 2019

Changes in this version

+ const GiB

+ func RoundOffBytes(bytes int64) int64

+ func RoundOffVolSize(size int64) int64

type Config

+ ForceKernelCephFS bool

v1.2.1

Sep 25, 2019

Changes in this version

+ const SnapshotOperationAlreadyExistsFmt

+ const VolumeOperationAlreadyExistsFmt

+ type VolumeLocks struct

+ func NewVolumeLocks() *VolumeLocks

+ func (vl *VolumeLocks) Release(volumeID string)

+ func (vl *VolumeLocks) TryAcquire(volumeID string) bool

v1.2.0

Sep 6, 2019

Changes in this version

+ var DriverVersion string

+ var GitCommit string

+ var Key = contextKey("ID")

+ func CreateMountPoint(mountPath string) error

+ func GetPIDLimit() (int, error)

+ func IsMountPoint(p string) (bool, error)

+ func Log(ctx context.Context, format string) string

+ func Mount(source, target, fstype string, options []string) error

+ func SetPIDLimit(limit int) error

+ func StartMetricsServer(c *Config)

+ func ValidateNodePublishVolumeRequest(req *csi.NodePublishVolumeRequest) error

+ func ValidateNodeStageVolumeRequest(req *csi.NodeStageVolumeRequest) error

+ func ValidateNodeUnpublishVolumeRequest(req *csi.NodeUnpublishVolumeRequest) error

+ func ValidateNodeUnstageVolumeRequest(req *csi.NodeUnstageVolumeRequest) error

+ func ValidateURL(c *Config) error

+ type Config struct

+ Containerized bool

+ DriverName string

+ EnableGRPCMetrics bool

+ Endpoint string

+ HistogramOption string

+ InstanceID string

+ IsControllerServer bool

+ IsNodeServer bool

+ MetadataStorage string

+ MetricsIP string

+ MetricsPath string

+ MetricsPort int

+ MountCacheDir string

+ NodeID string

+ PidLimit int

+ PluginPath string

+ PollTime time.Duration

+ PoolTimeout time.Duration

+ Vtype string

type Credentials

+ KeyFile string

+ func NewAdminCredentials(secrets map[string]string) (*Credentials, error)

+ func NewCredentials(id, key string) (*Credentials, error)

+ func NewUserCredentials(secrets map[string]string) (*Credentials, error)

+ func (cr *Credentials) DeleteCredentials()

v1.1.0

Jul 12, 2019

Changes in this version

+ const CephConfigPath

+ const MiB

+ const PluginFolder

+ func CreateObject(monitors string, cr *Credentials, poolName, namespace, objectName string) error

+ func ExecCommand(program string, args ...string) (stdout, stderr []byte, err error)

+ func GenerateVolID(monitors string, cr *Credentials, pool, clusterID, objUUID string, ...) (string, error)

+ func GetK8sNamespace() string

+ func GetMonValFromSecret(secrets map[string]string) (string, error)

+ func GetOMapValue(monitors string, cr *Credentials, ...) (string, error)

+ func GetPoolID(monitors string, cr *Credentials, poolName string) (int64, error)

+ func GetPoolName(monitors string, cr *Credentials, poolID int64) (string, error)

+ func Mons(pathToConfig, clusterID string) (string, error)

+ func NewK8sClient() *k8s.Clientset

+ func RemoveOMapKey(monitors string, cr *Credentials, ...) error

+ func RemoveObject(monitors string, cr *Credentials, poolName, namespace, oMapName string) error

+ func RoundUpToMiB(size int64) int64

+ func SetOMapKeyValue(monitors string, cr *Credentials, ...) error

+ func StripSecretInArgs(args []string) []string

+ func ValidateDriverName(driverName string) error

+ func WriteCephConfig() error

+ type CSIIdentifier struct

+ ClusterID string

+ EncodingVersion uint16

+ LocationID int64

+ ObjectUUID string

+ func (ci *CSIIdentifier) DecomposeCSIID(composedCSIID string) (err error)

+ func (ci CSIIdentifier) ComposeCSIID() (string, error)

+ type CSIJournal struct

+ func NewCSISnapshotJournal() *CSIJournal

+ func NewCSIVolumeJournal() *CSIJournal

+ func (cj *CSIJournal) CheckReservation(monitors string, cr *Credentials, pool, reqName, parentName string) (string, error)

+ func (cj *CSIJournal) GetObjectUUIDData(monitors string, cr *Credentials, pool, objectUUID string, snapSource bool) (string, string, error)

+ func (cj *CSIJournal) NamingPrefix() string

+ func (cj *CSIJournal) ReserveName(monitors string, cr *Credentials, pool, reqName, parentName string) (string, error)

+ func (cj *CSIJournal) SetCSIDirectorySuffix(suffix string)

+ func (cj *CSIJournal) SetNamespace(ns string)

+ func (cj *CSIJournal) UndoReservation(monitors string, cr *Credentials, pool, volName, reqName string) error

+ 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 CreatePersistanceStorage(sPath, metaDataStore, driverName string) (CachePersister, error)

+ func NewCachePersister(metadataStore, driverName string) (CachePersister, error)

+ type Credentials struct

+ ID string

+ Key string

+ func GetAdminCredentials(secrets map[string]string) (*Credentials, error)

+ func GetUserCredentials(secrets map[string]string) (*Credentials, error)

+ type ErrKeyNotFound struct

+ func (e ErrKeyNotFound) Error() string

+ type ErrObjectExists struct

+ func (e ErrObjectExists) Error() string

+ type ErrObjectNotFound struct

+ func (e ErrObjectNotFound) Error() string

+ type ErrSnapNameConflict struct

+ func (e ErrSnapNameConflict) Error() string

+ type ForAllFunc func(identifier string) error

+ type IDLock struct

+ type IDLocker struct

+ func NewIDLocker() *IDLocker

+ func (lkr *IDLocker) Lock(identifier string) *IDLock

+ func (lkr *IDLocker) Unlock(lk *IDLock, identifier string)

+ 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 NodeCache struct

+ BasePath string

+ CacheDir string

+ func (nc *NodeCache) Create(identifier string, data interface{}) error

+ func (nc *NodeCache) Delete(identifier string) error

+ func (nc *NodeCache) EnsureCacheDirectory(cacheDir string) error

+ func (nc *NodeCache) ForAll(pattern string, destObj interface{}, f ForAllFunc) error

+ func (nc *NodeCache) Get(identifier string, data interface{}) error

Incompatible versions in this module

v2.0.1+incompatible

Mar 19, 2020

v2.0.0+incompatible

Jan 20, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL