driver

Nov 11, 2024

Changes in this version

type Options

+ CsiMountPointPath string

+ HTTPEndpoint string

Sep 12, 2024

Changes in this version

+ const OutpostArnKey

type MockKubernetesClient

+ func (m *MockKubernetesClient) CoordinationV1alpha1() v1alpha13.CoordinationV1alpha1Interface

+ func (m *MockKubernetesClient) ResourceV1alpha3() v1alpha3.ResourceV1alpha3Interface

type MockKubernetesClientMockRecorder

+ func (mr *MockKubernetesClientMockRecorder) CoordinationV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) ResourceV1alpha3() *gomock.Call

type Options

+ LegacyXFSProgs bool

Jul 23, 2024

Changes in this version

+ const ModificationAddTag

+ const ModificationDeleteTag

type Options

+ Kubeconfig string

May 15, 2024

Changes in this version

type Options

+ WindowsHostProcess bool

Apr 22, 2024

Changes in this version

+ type ControllerService struct

+ func NewControllerService(c cloud.Cloud, o *Options) *ControllerService

+ func (d *ControllerService) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

+ func (d *ControllerService) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (d *ControllerService) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

+ func (d *ControllerService) ControllerModifyVolume(ctx context.Context, req *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

+ func (d *ControllerService) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (d *ControllerService) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (d *ControllerService) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (d *ControllerService) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (d *ControllerService) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (d *ControllerService) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (d *ControllerService) GetCSIDriverModificationCapability(_ context.Context, _ *rpc.GetCSIDriverModificationCapabilityRequest) (*rpc.GetCSIDriverModificationCapabilityResponse, error)

+ func (d *ControllerService) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

+ func (d *ControllerService) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (d *ControllerService) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (d *ControllerService) ModifyVolumeProperties(ctx context.Context, req *rpc.ModifyVolumePropertiesRequest) (*rpc.ModifyVolumePropertiesResponse, error)

+ func (d *ControllerService) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type MockKubernetesClient

+ func (m *MockKubernetesClient) StoragemigrationV1alpha1() v1alpha18.StoragemigrationV1alpha1Interface

type MockKubernetesClientMockRecorder

+ func (mr *MockKubernetesClientMockRecorder) StoragemigrationV1alpha1() *gomock.Call

+ type NodeService struct

+ func NewNodeService(o *Options, md metadata.MetadataService, m mounter.Mounter, ...) *NodeService

+ func (d *NodeService) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

+ func (d *NodeService) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

+ func (d *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

+ func (d *NodeService) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

+ func (d *NodeService) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

+ func (d *NodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

+ func (d *NodeService) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

+ func (d *NodeService) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

+ type Options struct

+ AwsSdkDebugLog bool

+ Batching bool

+ EnableOtelTracing bool

+ Endpoint string

+ ExtraTags map[string]string

+ ExtraVolumeTags map[string]string

+ HttpEndpoint string

+ KubernetesClusterID string

+ MetricsCertFile string

+ MetricsKeyFile string

+ Mode Mode

+ ModifyVolumeRequestHandlerTimeout time.Duration

+ ReservedVolumeAttachments int

+ UserAgentExtra string

+ VolumeAttachLimit int64

+ WarnOnInvalidTag bool

+ func (o *Options) AddFlags(f *flag.FlagSet)

+ func (o *Options) Validate() error

Mar 20, 2024

Changes in this version

+ const DeprecatedModificationKeyVolumeType

+ const OSTopologyKey

+ const WellKnownZoneTopologyKey

+ const ZoneTopologyKey

+ type MockCSINodeInterface struct

+ func NewMockCSINodeInterface(ctrl *gomock.Controller) *MockCSINodeInterface

+ func (m *MockCSINodeInterface) Apply(arg0 context.Context, arg1 *v11.CSINodeApplyConfiguration, ...) (*v1.CSINode, error)

+ func (m *MockCSINodeInterface) Create(arg0 context.Context, arg1 *v1.CSINode, arg2 v10.CreateOptions) (*v1.CSINode, error)

+ func (m *MockCSINodeInterface) Delete(arg0 context.Context, arg1 string, arg2 v10.DeleteOptions) error

+ func (m *MockCSINodeInterface) DeleteCollection(arg0 context.Context, arg1 v10.DeleteOptions, arg2 v10.ListOptions) error

+ func (m *MockCSINodeInterface) EXPECT() *MockCSINodeInterfaceMockRecorder

+ func (m *MockCSINodeInterface) Get(arg0 context.Context, arg1 string, arg2 v10.GetOptions) (*v1.CSINode, error)

+ func (m *MockCSINodeInterface) List(arg0 context.Context, arg1 v10.ListOptions) (*v1.CSINodeList, error)

+ func (m *MockCSINodeInterface) Patch(arg0 context.Context, arg1 string, arg2 types.PatchType, arg3 []byte, ...) (*v1.CSINode, error)

+ func (m *MockCSINodeInterface) Update(arg0 context.Context, arg1 *v1.CSINode, arg2 v10.UpdateOptions) (*v1.CSINode, error)

+ func (m *MockCSINodeInterface) Watch(arg0 context.Context, arg1 v10.ListOptions) (watch.Interface, error)

+ type MockCSINodeInterfaceMockRecorder struct

+ func (mr *MockCSINodeInterfaceMockRecorder) Apply(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) DeleteCollection(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) Patch(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockCSINodeInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call

Feb 19, 2024

Changes in this version

+ const DefaultModifyVolumeRequestHandlerTimeout

+ func WithModifyVolumeRequestHandlerTimeout(timeout time.Duration) func(*DriverOptions)

+ func WithReservedVolumeAttachments(reservedVolumeAttachments int) func(*DriverOptions)

Jan 22, 2024

Changes in this version

type Driver

+ func (d *Driver) ControllerModifyVolume(ctx context.Context, req *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

Dec 14, 2023

Changes in this version

+ const FSTypeKey

type MockKubernetesClient

+ func (m *MockKubernetesClient) FlowcontrolV1() v110.FlowcontrolV1Interface

type MockKubernetesClientMockRecorder

+ func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1() *gomock.Call

Nov 10, 2023

Changes in this version

+ const MultiNodeMultiWriter

+ const SingleNodeWriter

+ func WithBatching(enableBatching bool) func(*DriverOptions)

Oct 13, 2023

Changes in this version

+ const BytesPerInodeKey

+ const Ext4BigAllocKey

+ const Ext4ClusterSizeKey

+ const InodeSizeKey

+ const NumberOfInodesKey

Sep 15, 2023

Changes in this version

+ func InitOtelTracing() (*otlptrace.Exporter, error)

+ func WithOtelTracing(enableOtelTracing bool) func(*DriverOptions)

+ type MockStorageV1Interface struct

+ func NewMockStorageV1Interface(ctrl *gomock.Controller) *MockStorageV1Interface

+ func (m *MockStorageV1Interface) CSIDrivers() v12.CSIDriverInterface

+ func (m *MockStorageV1Interface) CSINodes() v12.CSINodeInterface

+ func (m *MockStorageV1Interface) CSIStorageCapacities(arg0 string) v12.CSIStorageCapacityInterface

+ func (m *MockStorageV1Interface) EXPECT() *MockStorageV1InterfaceMockRecorder

+ func (m *MockStorageV1Interface) RESTClient() rest.Interface

+ func (m *MockStorageV1Interface) StorageClasses() v12.StorageClassInterface

+ func (m *MockStorageV1Interface) VolumeAttachments() v12.VolumeAttachmentInterface

+ type MockStorageV1InterfaceMockRecorder struct

+ func (mr *MockStorageV1InterfaceMockRecorder) CSIDrivers() *gomock.Call

+ func (mr *MockStorageV1InterfaceMockRecorder) CSINodes() *gomock.Call

+ func (mr *MockStorageV1InterfaceMockRecorder) CSIStorageCapacities(arg0 interface{}) *gomock.Call

+ func (mr *MockStorageV1InterfaceMockRecorder) RESTClient() *gomock.Call

+ func (mr *MockStorageV1InterfaceMockRecorder) StorageClasses() *gomock.Call

+ func (mr *MockStorageV1InterfaceMockRecorder) VolumeAttachments() *gomock.Call

+ type MockVolumeAttachmentInterface struct

+ func NewMockVolumeAttachmentInterface(ctrl *gomock.Controller) *MockVolumeAttachmentInterface

+ func (m *MockVolumeAttachmentInterface) Apply(arg0 context.Context, arg1 *v11.VolumeAttachmentApplyConfiguration, ...) (*v1.VolumeAttachment, error)

+ func (m *MockVolumeAttachmentInterface) ApplyStatus(arg0 context.Context, arg1 *v11.VolumeAttachmentApplyConfiguration, ...) (*v1.VolumeAttachment, error)

+ func (m *MockVolumeAttachmentInterface) Create(arg0 context.Context, arg1 *v1.VolumeAttachment, arg2 v10.CreateOptions) (*v1.VolumeAttachment, error)

+ func (m *MockVolumeAttachmentInterface) Delete(arg0 context.Context, arg1 string, arg2 v10.DeleteOptions) error

+ func (m *MockVolumeAttachmentInterface) DeleteCollection(arg0 context.Context, arg1 v10.DeleteOptions, arg2 v10.ListOptions) error

+ func (m *MockVolumeAttachmentInterface) EXPECT() *MockVolumeAttachmentInterfaceMockRecorder

+ func (m *MockVolumeAttachmentInterface) Get(arg0 context.Context, arg1 string, arg2 v10.GetOptions) (*v1.VolumeAttachment, error)

+ func (m *MockVolumeAttachmentInterface) List(arg0 context.Context, arg1 v10.ListOptions) (*v1.VolumeAttachmentList, error)

+ func (m *MockVolumeAttachmentInterface) Patch(arg0 context.Context, arg1 string, arg2 types.PatchType, arg3 []byte, ...) (*v1.VolumeAttachment, error)

+ func (m *MockVolumeAttachmentInterface) Update(arg0 context.Context, arg1 *v1.VolumeAttachment, arg2 v10.UpdateOptions) (*v1.VolumeAttachment, error)

+ func (m *MockVolumeAttachmentInterface) UpdateStatus(arg0 context.Context, arg1 *v1.VolumeAttachment, arg2 v10.UpdateOptions) (*v1.VolumeAttachment, error)

+ func (m *MockVolumeAttachmentInterface) Watch(arg0 context.Context, arg1 v10.ListOptions) (watch.Interface, error)

+ type MockVolumeAttachmentInterfaceMockRecorder struct

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) Apply(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) ApplyStatus(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) DeleteCollection(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) Patch(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) UpdateStatus(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockVolumeAttachmentInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call

Aug 14, 2023

Changes in this version

+ const BytesPerINodeKey

+ const INodeSizeKey

+ const NumberOfINodesKey

+ var FileSystemConfigs = map[string]fileSystemConfig

May 15, 2023

Changes in this version

+ const AgentNotReadyNodeTaintKey

+ const ModificationKeyIOPS

+ const ModificationKeyThroughput

+ const ModificationKeyVolumeType

+ func WithUserAgentExtra(userAgentExtra string) func(*DriverOptions)

type Driver

+ func (d *Driver) GetCSIDriverModificationCapability(_ context.Context, _ *rpc.GetCSIDriverModificationCapabilityRequest) (*rpc.GetCSIDriverModificationCapabilityResponse, error)

+ func (d *Driver) ModifyVolumeProperties(ctx context.Context, req *rpc.ModifyVolumePropertiesRequest) (*rpc.ModifyVolumePropertiesResponse, error)

+ type JSONPatch struct

+ OP string

+ Path string

+ Value interface{}

+ type MockCoreV1Interface struct

+ func NewMockCoreV1Interface(ctrl *gomock.Controller) *MockCoreV1Interface

+ func (m *MockCoreV1Interface) ComponentStatuses() v12.ComponentStatusInterface

+ func (m *MockCoreV1Interface) ConfigMaps(arg0 string) v12.ConfigMapInterface

+ func (m *MockCoreV1Interface) EXPECT() *MockCoreV1InterfaceMockRecorder

+ func (m *MockCoreV1Interface) Endpoints(arg0 string) v12.EndpointsInterface

+ func (m *MockCoreV1Interface) Events(arg0 string) v12.EventInterface

+ func (m *MockCoreV1Interface) LimitRanges(arg0 string) v12.LimitRangeInterface

+ func (m *MockCoreV1Interface) Namespaces() v12.NamespaceInterface

+ func (m *MockCoreV1Interface) Nodes() v12.NodeInterface

+ func (m *MockCoreV1Interface) PersistentVolumeClaims(arg0 string) v12.PersistentVolumeClaimInterface

+ func (m *MockCoreV1Interface) PersistentVolumes() v12.PersistentVolumeInterface

+ func (m *MockCoreV1Interface) PodTemplates(arg0 string) v12.PodTemplateInterface

+ func (m *MockCoreV1Interface) Pods(arg0 string) v12.PodInterface

+ func (m *MockCoreV1Interface) RESTClient() rest.Interface

+ func (m *MockCoreV1Interface) ReplicationControllers(arg0 string) v12.ReplicationControllerInterface

+ func (m *MockCoreV1Interface) ResourceQuotas(arg0 string) v12.ResourceQuotaInterface

+ func (m *MockCoreV1Interface) Secrets(arg0 string) v12.SecretInterface

+ func (m *MockCoreV1Interface) ServiceAccounts(arg0 string) v12.ServiceAccountInterface

+ func (m *MockCoreV1Interface) Services(arg0 string) v12.ServiceInterface

+ type MockCoreV1InterfaceMockRecorder struct

+ func (mr *MockCoreV1InterfaceMockRecorder) ComponentStatuses() *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) ConfigMaps(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) Endpoints(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) Events(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) LimitRanges(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) Namespaces() *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) Nodes() *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) PersistentVolumeClaims(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) PersistentVolumes() *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) PodTemplates(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) Pods(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) RESTClient() *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) ReplicationControllers(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) ResourceQuotas(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) Secrets(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) ServiceAccounts(arg0 interface{}) *gomock.Call

+ func (mr *MockCoreV1InterfaceMockRecorder) Services(arg0 interface{}) *gomock.Call

+ type MockKubernetesClient struct

+ func NewMockKubernetesClient(ctrl *gomock.Controller) *MockKubernetesClient

+ func (m *MockKubernetesClient) AdmissionregistrationV1() v1.AdmissionregistrationV1Interface

+ func (m *MockKubernetesClient) AdmissionregistrationV1alpha1() v1alpha1.AdmissionregistrationV1alpha1Interface

+ func (m *MockKubernetesClient) AdmissionregistrationV1beta1() v1beta1.AdmissionregistrationV1beta1Interface

+ func (m *MockKubernetesClient) AppsV1() v10.AppsV1Interface

+ func (m *MockKubernetesClient) AppsV1beta1() v1beta10.AppsV1beta1Interface

+ func (m *MockKubernetesClient) AppsV1beta2() v1beta2.AppsV1beta2Interface

+ func (m *MockKubernetesClient) AuthenticationV1() v11.AuthenticationV1Interface

+ func (m *MockKubernetesClient) AuthenticationV1alpha1() v1alpha11.AuthenticationV1alpha1Interface

+ func (m *MockKubernetesClient) AuthenticationV1beta1() v1beta11.AuthenticationV1beta1Interface

+ func (m *MockKubernetesClient) AuthorizationV1() v12.AuthorizationV1Interface

+ func (m *MockKubernetesClient) AuthorizationV1beta1() v1beta12.AuthorizationV1beta1Interface

+ func (m *MockKubernetesClient) AutoscalingV1() v13.AutoscalingV1Interface

+ func (m *MockKubernetesClient) AutoscalingV2() v2.AutoscalingV2Interface

+ func (m *MockKubernetesClient) AutoscalingV2beta1() v2beta1.AutoscalingV2beta1Interface

+ func (m *MockKubernetesClient) AutoscalingV2beta2() v2beta2.AutoscalingV2beta2Interface

+ func (m *MockKubernetesClient) BatchV1() v14.BatchV1Interface

+ func (m *MockKubernetesClient) BatchV1beta1() v1beta13.BatchV1beta1Interface

+ func (m *MockKubernetesClient) CertificatesV1() v15.CertificatesV1Interface

+ func (m *MockKubernetesClient) CertificatesV1alpha1() v1alpha12.CertificatesV1alpha1Interface

+ func (m *MockKubernetesClient) CertificatesV1beta1() v1beta14.CertificatesV1beta1Interface

+ func (m *MockKubernetesClient) CoordinationV1() v16.CoordinationV1Interface

+ func (m *MockKubernetesClient) CoordinationV1beta1() v1beta15.CoordinationV1beta1Interface

+ func (m *MockKubernetesClient) CoreV1() v17.CoreV1Interface

+ func (m *MockKubernetesClient) Discovery() discovery.DiscoveryInterface

+ func (m *MockKubernetesClient) DiscoveryV1() v18.DiscoveryV1Interface

+ func (m *MockKubernetesClient) DiscoveryV1beta1() v1beta16.DiscoveryV1beta1Interface

+ func (m *MockKubernetesClient) EXPECT() *MockKubernetesClientMockRecorder

+ func (m *MockKubernetesClient) EventsV1() v19.EventsV1Interface

+ func (m *MockKubernetesClient) EventsV1beta1() v1beta17.EventsV1beta1Interface

+ func (m *MockKubernetesClient) ExtensionsV1beta1() v1beta18.ExtensionsV1beta1Interface

+ func (m *MockKubernetesClient) FlowcontrolV1alpha1() v1alpha13.FlowcontrolV1alpha1Interface

+ func (m *MockKubernetesClient) FlowcontrolV1beta1() v1beta19.FlowcontrolV1beta1Interface

+ func (m *MockKubernetesClient) FlowcontrolV1beta2() v1beta20.FlowcontrolV1beta2Interface

+ func (m *MockKubernetesClient) FlowcontrolV1beta3() v1beta3.FlowcontrolV1beta3Interface

+ func (m *MockKubernetesClient) InternalV1alpha1() v1alpha10.InternalV1alpha1Interface

+ func (m *MockKubernetesClient) NetworkingV1() v110.NetworkingV1Interface

+ func (m *MockKubernetesClient) NetworkingV1alpha1() v1alpha14.NetworkingV1alpha1Interface

+ func (m *MockKubernetesClient) NetworkingV1beta1() v1beta110.NetworkingV1beta1Interface

+ func (m *MockKubernetesClient) NodeV1() v111.NodeV1Interface

+ func (m *MockKubernetesClient) NodeV1alpha1() v1alpha15.NodeV1alpha1Interface

+ func (m *MockKubernetesClient) NodeV1beta1() v1beta111.NodeV1beta1Interface

+ func (m *MockKubernetesClient) PolicyV1() v112.PolicyV1Interface

+ func (m *MockKubernetesClient) PolicyV1beta1() v1beta112.PolicyV1beta1Interface

+ func (m *MockKubernetesClient) RbacV1() v113.RbacV1Interface

+ func (m *MockKubernetesClient) RbacV1alpha1() v1alpha16.RbacV1alpha1Interface

+ func (m *MockKubernetesClient) RbacV1beta1() v1beta113.RbacV1beta1Interface

+ func (m *MockKubernetesClient) ResourceV1alpha2() v1alpha2.ResourceV1alpha2Interface

+ func (m *MockKubernetesClient) SchedulingV1() v114.SchedulingV1Interface

+ func (m *MockKubernetesClient) SchedulingV1alpha1() v1alpha17.SchedulingV1alpha1Interface

+ func (m *MockKubernetesClient) SchedulingV1beta1() v1beta114.SchedulingV1beta1Interface

+ func (m *MockKubernetesClient) StorageV1() v115.StorageV1Interface

+ func (m *MockKubernetesClient) StorageV1alpha1() v1alpha18.StorageV1alpha1Interface

+ func (m *MockKubernetesClient) StorageV1beta1() v1beta115.StorageV1beta1Interface

+ type MockKubernetesClientMockRecorder struct

+ func (mr *MockKubernetesClientMockRecorder) AdmissionregistrationV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AdmissionregistrationV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AdmissionregistrationV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AppsV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AppsV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AppsV1beta2() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AuthenticationV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AuthenticationV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AuthenticationV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AuthorizationV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AuthorizationV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AutoscalingV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AutoscalingV2() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AutoscalingV2beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) AutoscalingV2beta2() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) BatchV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) BatchV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) CertificatesV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) CertificatesV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) CertificatesV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) CoordinationV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) CoordinationV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) CoreV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) Discovery() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) DiscoveryV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) DiscoveryV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) EventsV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) EventsV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) ExtensionsV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1beta2() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1beta3() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) InternalV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) NetworkingV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) NetworkingV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) NetworkingV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) NodeV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) NodeV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) NodeV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) PolicyV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) PolicyV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) RbacV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) RbacV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) RbacV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) ResourceV1alpha2() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) SchedulingV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) SchedulingV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) SchedulingV1beta1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) StorageV1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) StorageV1alpha1() *gomock.Call

+ func (mr *MockKubernetesClientMockRecorder) StorageV1beta1() *gomock.Call

type MockMounter

+ func (m *MockMounter) CanSafelySkipMountPointCheck() bool

type MockMounterMockRecorder

+ func (mr *MockMounterMockRecorder) CanSafelySkipMountPointCheck() *gomock.Call

+ type MockNodeInterface struct

+ func NewMockNodeInterface(ctrl *gomock.Controller) *MockNodeInterface

+ func (m *MockNodeInterface) Apply(arg0 context.Context, arg1 *v11.NodeApplyConfiguration, arg2 v10.ApplyOptions) (*v1.Node, error)

+ func (m *MockNodeInterface) ApplyStatus(arg0 context.Context, arg1 *v11.NodeApplyConfiguration, arg2 v10.ApplyOptions) (*v1.Node, error)

+ func (m *MockNodeInterface) Create(arg0 context.Context, arg1 *v1.Node, arg2 v10.CreateOptions) (*v1.Node, error)

+ func (m *MockNodeInterface) Delete(arg0 context.Context, arg1 string, arg2 v10.DeleteOptions) error

+ func (m *MockNodeInterface) DeleteCollection(arg0 context.Context, arg1 v10.DeleteOptions, arg2 v10.ListOptions) error

+ func (m *MockNodeInterface) EXPECT() *MockNodeInterfaceMockRecorder

+ func (m *MockNodeInterface) Get(arg0 context.Context, arg1 string, arg2 v10.GetOptions) (*v1.Node, error)

+ func (m *MockNodeInterface) List(arg0 context.Context, arg1 v10.ListOptions) (*v1.NodeList, error)

+ func (m *MockNodeInterface) Patch(arg0 context.Context, arg1 string, arg2 types.PatchType, arg3 []byte, ...) (*v1.Node, error)

+ func (m *MockNodeInterface) PatchStatus(arg0 context.Context, arg1 string, arg2 []byte) (*v1.Node, error)

+ func (m *MockNodeInterface) Update(arg0 context.Context, arg1 *v1.Node, arg2 v10.UpdateOptions) (*v1.Node, error)

+ func (m *MockNodeInterface) UpdateStatus(arg0 context.Context, arg1 *v1.Node, arg2 v10.UpdateOptions) (*v1.Node, error)

+ func (m *MockNodeInterface) Watch(arg0 context.Context, arg1 v10.ListOptions) (watch.Interface, error)

+ type MockNodeInterfaceMockRecorder struct

+ func (mr *MockNodeInterfaceMockRecorder) Apply(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) ApplyStatus(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) DeleteCollection(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) Patch(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) PatchStatus(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) UpdateStatus(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockNodeInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call

Apr 17, 2023

Changes in this version

+ const FastSnapshotRestoreAvailabilityZones

+ const VolumeSnapshotContentNameKey

+ const VolumeSnapshotNameKey

+ const VolumeSnapshotNamespaceKey

Jan 12, 2023

Changes in this version

+ const BlockSizeKey

+ var BlockSizeExcludedFSTypes = map[string]struct

type MockMounter

+ func (m *MockMounter) FormatAndMountSensitiveWithFormatOptions(source, target, fstype string, ...) error

type MockMounterMockRecorder

+ func (mr *MockMounterMockRecorder) FormatAndMountSensitiveWithFormatOptions(source, target, fstype, options, sensitiveOptions, formatOptions interface{}) *gomock.Call

type Mounter

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

type NodeMounter — windows/amd64

+ func (m NodeMounter) FormatAndMountSensitiveWithFormatOptions(source string, target string, fstype string, options []string, ...) error

Nov 2, 2022

Changes in this version

type MockMounter

+ func (m *MockMounter) IsMountPoint(file string) (bool, error)

type MockMounterMockRecorder

+ func (mr *MockMounterMockRecorder) IsMountPoint(file interface{}) *gomock.Call

Oct 4, 2022

Changes in this version

+ const BlockExpressKey

Jul 26, 2022

Changes in this version

+ const FSTypeNtfs

Apr 21, 2022

Changes in this version

+ const DefaultBlockSize

+ const TagKeyPrefix

+ func WithWarnOnInvalidTag(warnOnInvalidTag bool) func(*DriverOptions)

type MockMounter

+ func (m *MockMounter) NewResizeFs() (Resizefs, error)

+ func (m *MockMounter) Unpublish(path string) error

+ func (m *MockMounter) Unstage(path string) error

type MockMounterMockRecorder

+ func (mr *MockMounterMockRecorder) NewResizeFs() *gomock.Call

+ func (mr *MockMounterMockRecorder) Unpublish(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Unstage(path interface{}) *gomock.Call

+ type MockResizefs struct

+ func NewMockResizefs(ctrl *gomock.Controller) *MockResizefs

+ func (m *MockResizefs) EXPECT() *MockResizefsMockRecorder

+ func (m *MockResizefs) Resize(devicePath, deviceMountPath string) (bool, error)

+ type MockResizefsMockRecorder struct

+ func (mr *MockResizefsMockRecorder) Resize(devicePath, deviceMountPath interface{}) *gomock.Call

type Mounter

+ NewResizeFs func() (Resizefs, error)

+ Unpublish func(path string) error

+ Unstage func(path string) error

type NodeMounter — linux/amd64, windows/amd64

+ func (m *NodeMounter) NewResizeFs() (Resizefs, error)

+ func (m *NodeMounter) Unpublish(path string) error

+ func (m *NodeMounter) Unpublish(target string) error

+ func (m *NodeMounter) Unstage(path string) error

+ func (m *NodeMounter) Unstage(target string) error

+ type Resizefs interface

+ Resize func(devicePath, deviceMountPath string) (bool, error)

Apr 13, 2022

Changes in this version

type MockMounter

+ func (m *MockMounter) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype string, options, sensitiveOptions, mountFlags []string) error

type MockMounterMockRecorder

+ func (mr *MockMounterMockRecorder) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype, options, sensitiveOptions, mountFlags interface{}) *gomock.Call

Oct 12, 2021

Changes in this version

+ type DeviceIdentifier interface

+ EvalSymlinks func(path string) (string, error)

+ Lstat func(name string) (os.FileInfo, error)

+ type MockDeviceIdentifier struct

+ func NewMockDeviceIdentifier(ctrl *gomock.Controller) *MockDeviceIdentifier

+ func (m *MockDeviceIdentifier) EXPECT() *MockDeviceIdentifierMockRecorder

+ func (m *MockDeviceIdentifier) EvalSymlinks(path string) (string, error)

+ func (m *MockDeviceIdentifier) Lstat(name string) (os.FileInfo, error)

+ type MockDeviceIdentifierMockRecorder struct

+ func (mr *MockDeviceIdentifierMockRecorder) EvalSymlinks(path interface{}) *gomock.Call

+ func (mr *MockDeviceIdentifierMockRecorder) Lstat(name interface{}) *gomock.Call

+ type MockMounter struct

+ func NewMockMounter(ctrl *gomock.Controller) *MockMounter

+ func (m *MockMounter) EXPECT() *MockMounterMockRecorder

+ func (m *MockMounter) FormatAndMount(source, target, fstype string, options []string) error

+ func (m *MockMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

+ func (m *MockMounter) GetMountRefs(pathname string) ([]string, error)

+ func (m *MockMounter) IsCorruptedMnt(err error) bool

+ func (m *MockMounter) IsLikelyNotMountPoint(file string) (bool, error)

+ func (m *MockMounter) List() ([]mount.MountPoint, error)

+ func (m *MockMounter) MakeDir(path string) error

+ func (m *MockMounter) MakeFile(path string) error

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

+ func (m *MockMounter) MountSensitive(source, target, fstype string, options, sensitiveOptions []string) error

+ func (m *MockMounter) MountSensitiveWithoutSystemd(source, target, fstype string, options, sensitiveOptions []string) error

+ func (m *MockMounter) NeedResize(devicePath, deviceMountPath string) (bool, error)

+ func (m *MockMounter) PathExists(path string) (bool, error)

+ func (m *MockMounter) Unmount(target string) error

+ type MockMounterMockRecorder struct

+ func (mr *MockMounterMockRecorder) FormatAndMount(source, target, fstype, options interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) GetDeviceNameFromMount(mountPath interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) GetMountRefs(pathname interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) IsCorruptedMnt(err interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) IsLikelyNotMountPoint(file interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) List() *gomock.Call

+ func (mr *MockMounterMockRecorder) MakeDir(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) MakeFile(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Mount(source, target, fstype, options interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) MountSensitive(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) MountSensitiveWithoutSystemd(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) NeedResize(devicePath, deviceMountPath interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) PathExists(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Unmount(target interface{}) *gomock.Call

Jul 28, 2021

Changes in this version

+ const KubernetesClusterTag

type NodeMounter — windows/amd64

+ func (m NodeMounter) FormatAndMount(source string, target string, fstype string, options []string) error

Sep 3, 2021

Changes in this version

type Mounter

+ IsCorruptedMnt func(err error) bool

type NodeMounter

+ func (m NodeMounter) IsCorruptedMnt(err error) bool

Apr 29, 2021

Changes in this version

+ const AllowAutoIOPSPerGBIncreaseKey

+ func WithAwsSdkDebugLog(enableSdkDebugLog bool) func(*DriverOptions)

type Driver

+ func (d *Driver) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

type Mounter

+ NeedResize func(devicePath string, deviceMountPath string) (bool, error)

type NodeMounter

+ func (m *NodeMounter) NeedResize(devicePath string, deviceMountPath string) (bool, error)

Apr 12, 2021

Changes in this version

+ const VolumeAttributePartition

Mar 29, 2021

Changes in this version

+ const VolumeOperationAlreadyExists

+ const WellKnownTopologyKey

type Mounter

+ GetDeviceNameFromMount func(mountPath string) (string, int, error)

+ PathExists func(path string) (bool, error)

type NodeMounter

+ func (m *NodeMounter) PathExists(path string) (bool, error)

+ func (m NodeMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

Feb 3, 2021

Changes in this version

type Driver

+ func (d *Driver) IsBlockDevice(fullPath string) (bool, error)

Dec 9, 2020

Changes in this version

+ const IopsKey

+ const ThroughputKey

+ func WithExtraTags(extraTags map[string]string) func(*DriverOptions)

Oct 2, 2020

Changes in this version

+ const AwsAccountIDKey

+ const AwsOutpostIDKey

+ const AwsPartitionKey

+ const AwsRegionKey

+ func BuildOutpostArn(segments map[string]string) string

Aug 9, 2020

Changes in this version

+ const NameTag

+ const PVCNameKey

+ const PVCNameTag

+ const PVCNamespaceKey

+ const PVCNamespaceTag

+ const PVNameKey

+ const PVNameTag

+ const ResourceLifecycleOwned

+ const ResourceLifecycleTagPrefix

+ func WithKubernetesClusterID(clusterID string) func(*DriverOptions)

+ func WithVolumeAttachLimit(volumeAttachLimit int64) func(*DriverOptions)

Mar 1, 2020

Changes in this version

+ const DefaultCSIEndpoint

+ const KmsKeyIDKey

+ var NewCloudFunc = cloud.NewCloud

+ var NewMetadataFunc = cloud.NewMetadata

+ func ValidateDriverOptions(options *DriverOptions) error

+ func WithEndpoint(endpoint string) func(*DriverOptions)

+ func WithExtraVolumeTags(extraVolumeTags map[string]string) func(*DriverOptions)

+ func WithMode(mode Mode) func(*DriverOptions)

+ type DriverOptions struct

+ type Mode string

+ const AllMode

+ const ControllerMode

+ const NodeMode

type Mounter

+ ExistsPath func(filename string) (bool, error)

+ MakeDir func(pathname string) error

+ MakeFile func(pathname string) error

type NodeMounter

+ func (m *NodeMounter) ExistsPath(filename string) (bool, error)

+ func (m *NodeMounter) MakeDir(pathname string) error

+ func (m *NodeMounter) MakeFile(pathname string) error

Aug 26, 2019

Changes in this version

+ const FSTypeXfs

type Driver

+ func (d *Driver) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

+ func (d *Driver) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

+ type Mounter interface

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

+ GetDeviceName func(mountPath string) (string, int, error)

+ type NodeMounter struct

+ func (m *NodeMounter) GetDeviceName(mountPath string) (string, int, error)

Mar 20, 2019

Changes in this version

+ const DevicePathKey

+ const EncryptedKey

+ const FsTypeKey

+ const IopsPerGBKey

+ const KmsKeyIdKey

+ const VolumeTypeKey

Jan 31, 2019

Changes in this version

+ const DriverName

+ const FSTypeExt2

+ const FSTypeExt3

+ const FSTypeExt4

+ const TopologyKey

+ var ValidFSTypes = []string

+ func GetVersionJSON() (string, error)

+ func NewFakeSafeFormatAndMounter(fakeMounter *mount.FakeMounter) *mount.SafeFormatAndMount

type Driver

+ func NewFakeDriver(endpoint string, fakeMounter *mount.FakeMounter) *Driver

+ func (d *Driver) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

+ type VersionInfo struct

+ BuildDate string

+ Compiler string

+ DriverVersion string

+ GitCommit string

+ GoVersion string

+ Platform string

+ func GetVersion() VersionInfo

Nov 28, 2018

Changes in this version

+ func NewFakeMounter() *mount.SafeFormatAndMount

+ type Driver struct

+ func NewDriver(cloud cloud.Cloud, mounter *mount.SafeFormatAndMount, endpoint string) *Driver

+ func (d *Driver) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (d *Driver) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (d *Driver) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (d *Driver) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (d *Driver) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (d *Driver) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (d *Driver) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

+ func (d *Driver) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

+ func (d *Driver) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

+ func (d *Driver) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (d *Driver) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (d *Driver) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

+ func (d *Driver) NodeGetId(ctx context.Context, req *csi.NodeGetIdRequest) (*csi.NodeGetIdResponse, error)

+ func (d *Driver) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

+ func (d *Driver) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

+ func (d *Driver) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

+ func (d *Driver) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

+ func (d *Driver) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

+ func (d *Driver) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

+ func (d *Driver) Run() error

+ func (d *Driver) Stop()

+ func (d *Driver) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)