const Name … const VendorVersion … const TopologyKey … const TopologyValue … var Manifest … type Config … type DirIO … type OSDirIO … func (o OSDirIO) DirExists(path string) (bool, error) { … } func (o OSDirIO) Mkdir(path string) error { … } func (o OSDirIO) RemoveAll(path string) error { … } func (o OSDirIO) Rename(oldPath, newPath string) error { … } type Service … type service … type Volume … var MockVolumes … // New returns a new Service. func New(config Config) Service { … } const kib … const mib … const gib … const gib100 … const tib … func (s *service) newVolume(name string, capcity int64) csi.Volume { … } func (s *service) newVolumeFromSnapshot(name string, capacity int64, snapshotID int) csi.Volume { … } func (s *service) newVolumeFromVolume(name string, capacity int64, volumeID int) csi.Volume { … } func (s *service) setTopology(vol *csi.Volume) { … } func (s *service) findVol(k, v string) (volIdx int, volInfo csi.Volume) { … } func (s *service) findVolNoLock(k, v string) (volIdx int, volInfo csi.Volume) { … } func (s *service) findVolByName( ctx context.Context, name string) (int, csi.Volume) { … } func (s *service) findVolByID( ctx context.Context, id string) (int, csi.Volume) { … } func (s *service) newSnapshot(name, sourceVolumeId string, parameters map[string]string) cache.Snapshot { … } // getAttachCount returns the number of attached volumes on the node. func (s *service) getAttachCount(devPathKey string) int64 { … } func (s *service) execHook(hookName string) (codes.Code, string) { … }
Codebase Browser
kubernetes