const osdMgmtDefaultPort … const osdDriverVersion … const pxdDriverName … const pvcClaimLabel … const pvcNamespaceLabel … const pxServiceName … const pxDriverName … type portworxVolumeUtil … // CreateVolume creates a Portworx volume. func (util *portworxVolumeUtil) CreateVolume(p *portworxVolumeProvisioner) (string, int64, map[string]string, error) { … } // DeleteVolume deletes a Portworx volume func (util *portworxVolumeUtil) DeleteVolume(d *portworxVolumeDeleter) error { … } // AttachVolume attaches a Portworx Volume func (util *portworxVolumeUtil) AttachVolume(m *portworxVolumeMounter, attachOptions map[string]string) (string, error) { … } // DetachVolume detaches a Portworx Volume func (util *portworxVolumeUtil) DetachVolume(u *portworxVolumeUnmounter) error { … } // MountVolume mounts a Portworx Volume on the specified mountPath func (util *portworxVolumeUtil) MountVolume(m *portworxVolumeMounter, mountPath string) error { … } // UnmountVolume unmounts a Portworx Volume func (util *portworxVolumeUtil) UnmountVolume(u *portworxVolumeUnmounter, mountPath string) error { … } func (util *portworxVolumeUtil) ResizeVolume(spec *volume.Spec, newSize resource.Quantity, volumeHost volume.VolumeHost) error { … } func isClientValid(client *osdclient.Client) (bool, error) { … } func createDriverClient(hostname string, port int32) (*osdclient.Client, error) { … } // getPortworxDriver returns a Portworx volume driver which can be used for cluster wide operations. // // Operations like create and delete volume don't need to be restricted to local volume host since // any node in the Portworx cluster can coordinate the create/delete request and forward the operations to // the Portworx node that will own/owns the data. func (util *portworxVolumeUtil) getPortworxDriver(volumeHost volume.VolumeHost) (volumeapi.VolumeDriver, error) { … } // getLocalPortworxDriver returns driver connected to Portworx API server on volume host. // // This is required to force certain operations (mount, unmount, detach, attach) to // go to the volume host instead of the k8s service which might route it to any host. This pertains to how // Portworx mounts and attaches a volume to the running container. The node getting these requests needs to // see the pod container mounts (specifically /var/lib/kubelet/pods/<pod_id>) func (util *portworxVolumeUtil) getLocalPortworxDriver(volumeHost volume.VolumeHost) (volumeapi.VolumeDriver, error) { … } // lookupPXAPIPortFromService goes over all the ports in the given service and returns the target // port for osdMgmtDefaultPort func lookupPXAPIPortFromService(svc *v1.Service) int32 { … } // getPortworxService returns the portworx cluster service from the API server func getPortworxService(host volume.VolumeHost) (*v1.Service, error) { … }
Codebase Browser
kubernetes