driver

package
v1.29.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 2, 2024 License: Apache-2.0 Imports: 58 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OkeSystemTagNamesapce  = "orcl-containerengine"
	MaxDefinedTagPerVolume = 64
)
View Source 
const (
	// BlockVolumeDriverName defines the driver name to be used in Kubernetes
	BlockVolumeDriverName = "blockvolume.csi.oraclecloud.com"

	// BlockVolumeDriverVersion is the version of the CSI driver
	BlockVolumeDriverVersion = "0.1.0"

	// FSSDriverName defines the driver name to be used in Kubernetes
	FSSDriverName = "fss.csi.oraclecloud.com"

	// FSSDriverVersion is the version of the CSI driver
	FSSDriverVersion = "0.1.0"

	// LustreDriverName defines the driver name to be used in Kubernetes
	LustreDriverName = "lustre.csi.oraclecloud.com"

	// LustreDriverVersion is the version of the CSI driver
	LustreDriverVersion = "0.1.0"
)
View Source 
const (
	SetupLnet        = "setupLnet"
	LustreSubnetCidr = "lustreSubnetCidr"
)
View Source 
const (
	FSTypeXfs = "xfs"
)
View Source 
const (
	FipsEnabled = "1"
)

Variables

View Source 
var ServiceAccountTokenExpiry = int64(serviceAccountTokenExpiry)

Functions

func GetControllerDriver added in v1.24.1 

func GetControllerDriver(name string, kubeClientSet kubernetes.Interface, logger *zap.SugaredLogger, config *providercfg.Config, c client.Interface, clusterIpFamily string) csi.ControllerServer

func GetNodeDriver 

func GetNodeDriver(name string, nodeID string, nodeIpFamily *csi_util.NodeIpFamily, kubeClientSet kubernetes.Interface, logger *zap.SugaredLogger) csi.NodeServer

Types

type BlockVolumeControllerDriver added in v1.24.1 

type BlockVolumeControllerDriver struct {
	ControllerDriver
}

BlockVolumeControllerDriver extends ControllerDriver

func (*BlockVolumeControllerDriver) ControllerExpandVolume added in v1.24.1 

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

ControllerExpandVolume returns ControllerExpandVolume request

func (*BlockVolumeControllerDriver) ControllerGetCapabilities added in v1.24.1 

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

ControllerGetCapabilities returns the capabilities of the controller service.

func (*BlockVolumeControllerDriver) ControllerGetVolume added in v1.24.1 

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

ControllerGetVolume returns ControllerGetVolumeResponse response

func (*BlockVolumeControllerDriver) ControllerModifyVolume added in v1.29.0 

func (d *BlockVolumeControllerDriver) ControllerModifyVolume(ctx context.Context, request *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

func (*BlockVolumeControllerDriver) ControllerPublishVolume added in v1.24.1 

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

ControllerPublishVolume attaches the given volume to the node

func (*BlockVolumeControllerDriver) ControllerUnpublishVolume added in v1.24.1 

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

ControllerUnpublishVolume detaches the given volume from the node

func (*BlockVolumeControllerDriver) CreateSnapshot added in v1.24.1 

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

CreateSnapshot will be called by the CO to create a new snapshot from a source volume on behalf of a user.

func (*BlockVolumeControllerDriver) CreateVolume added in v1.24.1 

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

CreateVolume creates a new volume from the given request. The function is idempotent.

func (*BlockVolumeControllerDriver) DeleteSnapshot added in v1.24.1 

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

DeleteSnapshot will be called by the CO to delete a snapshot.

func (*BlockVolumeControllerDriver) DeleteVolume added in v1.24.1 

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

DeleteVolume deletes the given volume. The function is idempotent.

func (*BlockVolumeControllerDriver) GetCapacity added in v1.24.1 

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

GetCapacity returns the capacity of the storage pool

func (*BlockVolumeControllerDriver) ListSnapshots added in v1.24.1 

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

ListSnapshots returns all the matched snapshots

func (*BlockVolumeControllerDriver) ListVolumes added in v1.24.1 

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

ListVolumes returns a list of all requested volumes

func (*BlockVolumeControllerDriver) ValidateVolumeCapabilities added in v1.24.1 

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

ValidateVolumeCapabilities checks whether the volume capabilities requested are supported.

type BlockVolumeNodeDriver 

type BlockVolumeNodeDriver struct {
	NodeDriver
}

BlockVolumeNodeDriver extends NodeDriver

func (BlockVolumeNodeDriver) NodeExpandVolume 

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

NodeExpandVolume returns the expand of the volume

func (BlockVolumeNodeDriver) NodeGetCapabilities 

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

NodeGetCapabilities returns the supported capabilities of the node server

func (BlockVolumeNodeDriver) NodeGetInfo 

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

NodeGetInfo returns the supported capabilities of the node server. The result of this function will be used by the CO in ControllerPublishVolume.

func (BlockVolumeNodeDriver) NodeGetVolumeStats 

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

NodeGetVolumeStats return the stats of the volume

func (BlockVolumeNodeDriver) NodePublishVolume 

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

NodePublishVolume mounts the volume to the target path

func (BlockVolumeNodeDriver) NodeStageVolume 

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

NodeStageVolume mounts the volume to a staging path on the node.

func (BlockVolumeNodeDriver) NodeUnpublishVolume 

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

NodeUnpublishVolume unmounts the volume from the target path

func (BlockVolumeNodeDriver) NodeUnstageVolume 

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

NodeUnstageVolume unstage the volume from the staging path

type CSIDriver added in v1.24.1 

type CSIDriver string
const (
	BV  CSIDriver = "BV"
	FSS CSIDriver = "FSS"

	Lustre CSIDriver = "Lustre"
)

type Clientset added in v1.28.2 

type Clientset struct {
	*fake.Clientset
	// contains filtered or unexported fields
}

Clientset implements clientset.Interface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func NewSimpleClientset added in v1.28.2 

func NewSimpleClientset(objects ...runtime.Object) *Clientset

NewSimpleClientset returns a clientset that will respond with the provided objects. It's backed by a very simple object tracker that processes creates, updates and deletions as-is, without applying any validations and/or defaults. It shouldn't be considered a replacement for a real clientset and is mostly useful in simple unit tests.

func (*Clientset) CoreV1 added in v1.28.2 

func (c *Clientset) CoreV1() corev1.CoreV1Interface

CoreV1 retrieves the CoreV1Client

type ControllerDriver 

type ControllerDriver struct {
	KubeClient kubernetes.Interface
	// contains filtered or unexported fields
}

ControllerDriver implements CSI Controller interfaces

type ControllerDriverConfig added in v1.24.1 

type ControllerDriverConfig struct {
	CsiEndpoint            string
	CsiKubeConfig          string
	CsiMaster              string
	EnableControllerServer bool
	DriverName             string
	DriverVersion          string
	ClusterIpFamily        string
}

type Driver 

type Driver struct {
	// contains filtered or unexported fields
}

Driver implements only Identity interface and embed Controller and Node interface.

func NewControllerDriver 

func NewControllerDriver(logger *zap.SugaredLogger, driverConfig ControllerDriverConfig) (*Driver, error)

NewControllerDriver creates a new CSI driver

func NewNodeDriver 

func NewNodeDriver(logger *zap.SugaredLogger, nodeOptions nodedriveroptions.NodeOptions) (*Driver, error)

NewNodeDriver creates a new CSI node driver for OCI blockvolume

func (*Driver) GetControllerDriver added in v1.24.1 

func (d *Driver) GetControllerDriver() csi.ControllerServer

func (*Driver) GetNodeDriver 

func (d *Driver) GetNodeDriver() csi.NodeServer

func (*Driver) GetPluginCapabilities 

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

GetPluginCapabilities returns available capabilities of the plugin

func (*Driver) GetPluginInfo 

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

GetPluginInfo returns metadata of the plugin

func (*Driver) Probe 

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

Probe returns the health and readiness of the plugin

func (*Driver) Run 

func (d *Driver) Run() error

Run starts a gRPC server on the given endpoint

func (*Driver) Stop 

func (d *Driver) Stop()

Stop stops the plugin

type FSSControllerDriver added in v1.24.1 

type FSSControllerDriver struct {
	ControllerDriver
	// contains filtered or unexported fields
}

FSSControllerDriver extends ControllerDriver

func (*FSSControllerDriver) ControllerExpandVolume added in v1.24.1 

func (d *FSSControllerDriver) ControllerExpandVolume(ctx context.Context, request *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*FSSControllerDriver) ControllerGetCapabilities added in v1.24.1 

func (d *FSSControllerDriver) ControllerGetCapabilities(ctx context.Context, request *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

func (*FSSControllerDriver) ControllerGetVolume added in v1.24.1 

func (d *FSSControllerDriver) ControllerGetVolume(ctx context.Context, request *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

func (*FSSControllerDriver) ControllerModifyVolume added in v1.29.0 

func (d *FSSControllerDriver) ControllerModifyVolume(ctx context.Context, request *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

func (*FSSControllerDriver) ControllerPublishVolume added in v1.24.1 

func (d *FSSControllerDriver) ControllerPublishVolume(ctx context.Context, request *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

func (*FSSControllerDriver) ControllerUnpublishVolume added in v1.24.1 

func (d *FSSControllerDriver) ControllerUnpublishVolume(ctx context.Context, request *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

func (*FSSControllerDriver) CreateSnapshot added in v1.24.1 

func (d *FSSControllerDriver) CreateSnapshot(ctx context.Context, request *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*FSSControllerDriver) CreateVolume added in v1.24.1 

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

func (*FSSControllerDriver) DeleteSnapshot added in v1.24.1 

func (d *FSSControllerDriver) DeleteSnapshot(ctx context.Context, request *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*FSSControllerDriver) DeleteVolume added in v1.24.1 

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

func (*FSSControllerDriver) GetCapacity added in v1.24.1 

func (d *FSSControllerDriver) GetCapacity(ctx context.Context, request *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

func (*FSSControllerDriver) ListSnapshots added in v1.24.1 

func (d *FSSControllerDriver) ListSnapshots(ctx context.Context, request *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*FSSControllerDriver) ListVolumes added in v1.24.1 

func (d *FSSControllerDriver) ListVolumes(ctx context.Context, request *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*FSSControllerDriver) ValidateVolumeCapabilities added in v1.24.1 

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

type FSSNodeDriver 

type FSSNodeDriver struct {
	NodeDriver
}

FSSNodeDriver extends NodeDriver

func (FSSNodeDriver) NodeExpandVolume 

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

NodeExpandVolume returns the expand of the volume

func (FSSNodeDriver) NodeGetCapabilities 

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

NodeGetCapabilities returns the supported capabilities of the node server

func (FSSNodeDriver) NodeGetInfo 

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

NodeGetInfo returns the supported capabilities of the node server. The result of this function will be used by the CO in ControllerPublishVolume.

func (FSSNodeDriver) NodeGetVolumeStats 

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

NodeGetVolumeStats return the stats of the volume

func (FSSNodeDriver) NodePublishVolume 

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

NodePublishVolume mounts the volume to the target path

func (FSSNodeDriver) NodeStageVolume 

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

NodeStageVolume mounts the volume to a staging path on the node.

func (FSSNodeDriver) NodeUnpublishVolume 

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

NodeUnpublishVolume unmounts the volume from the target path

func (FSSNodeDriver) NodeUnstageVolume 

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

NodeUnstageVolume unstage the volume from the staging path

type FakeCoreV1 added in v1.28.2 

type FakeCoreV1 struct {
	*fakecorev1.FakeCoreV1
	*testing.Fake
}

func (*FakeCoreV1) ServiceAccounts added in v1.28.2 

func (c *FakeCoreV1) ServiceAccounts(namespace string) corev1.ServiceAccountInterface

type FakeServiceAccounts added in v1.28.2 

type FakeServiceAccounts struct {
	Fake *FakeCoreV1
	// contains filtered or unexported fields
}

FakeServiceAccounts implements ServiceAccountInterface

func (*FakeServiceAccounts) Apply added in v1.28.2 

func (c *FakeServiceAccounts) Apply(ctx context.Context, serviceAccount *applyconfigurationscorev1.ServiceAccountApplyConfiguration, opts v1.ApplyOptions) (result *apicorev1.ServiceAccount, err error)

Apply takes the given apply declarative configuration, applies it and returns the applied serviceAccount.

func (*FakeServiceAccounts) Create added in v1.28.2 

func (c *FakeServiceAccounts) Create(ctx context.Context, serviceAccount *apicorev1.ServiceAccount, opts v1.CreateOptions) (result *apicorev1.ServiceAccount, err error)

Create takes the representation of a serviceAccount and creates it. Returns the server's representation of the serviceAccount, and an error, if there is any.

func (*FakeServiceAccounts) CreateToken added in v1.28.2 

func (c *FakeServiceAccounts) CreateToken(ctx context.Context, serviceAccountName string, tokenRequest *apiauthenticationv1.TokenRequest, opts v1.CreateOptions) (result *apiauthenticationv1.TokenRequest, err error)

CreateToken takes the representation of a tokenRequest and creates it. Returns the server's representation of the tokenRequest, and an error, if there is any.

func (*FakeServiceAccounts) Delete added in v1.28.2 

func (c *FakeServiceAccounts) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error

Delete takes name of the serviceAccount and deletes it. Returns an error if one occurs.

func (*FakeServiceAccounts) DeleteCollection added in v1.28.2 

func (c *FakeServiceAccounts) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error

DeleteCollection deletes a collection of objects.

func (*FakeServiceAccounts) Get added in v1.28.2 

func (c *FakeServiceAccounts) Get(ctx context.Context, name string, options v1.GetOptions) (result *apicorev1.ServiceAccount, err error)

Get takes name of the serviceAccount, and returns the corresponding serviceAccount object, and an error if there is any.

func (*FakeServiceAccounts) List added in v1.28.2 

func (c *FakeServiceAccounts) List(ctx context.Context, opts v1.ListOptions) (result *apicorev1.ServiceAccountList, err error)

List takes label and field selectors, and returns the list of ServiceAccounts that match those selectors.

func (*FakeServiceAccounts) Patch added in v1.28.2 

func (c *FakeServiceAccounts) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *apicorev1.ServiceAccount, err error)

Patch applies the patch and returns the patched serviceAccount.

func (*FakeServiceAccounts) Update added in v1.28.2 

func (c *FakeServiceAccounts) Update(ctx context.Context, serviceAccount *apicorev1.ServiceAccount, opts v1.UpdateOptions) (result *apicorev1.ServiceAccount, err error)

Update takes the representation of a serviceAccount and updates it. Returns the server's representation of the serviceAccount, and an error, if there is any.

func (*FakeServiceAccounts) Watch added in v1.28.2 

func (c *FakeServiceAccounts) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)

Watch returns a watch.Interface that watches the requested serviceAccounts.

type LustreNodeDriver added in v1.28.2 

type LustreNodeDriver struct {
	NodeDriver
}

func (LustreNodeDriver) NodeExpandVolume added in v1.28.2 

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

NodeExpandVolume returns the expand of the volume

func (LustreNodeDriver) NodeGetCapabilities added in v1.28.2 

func (d LustreNodeDriver) NodeGetCapabilities(ctx context.Context, request *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (LustreNodeDriver) NodeGetInfo added in v1.28.2 

func (d LustreNodeDriver) NodeGetInfo(ctx context.Context, request *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (LustreNodeDriver) NodeGetVolumeStats added in v1.28.2 

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

NodeGetVolumeStats return the stats of the volume

func (LustreNodeDriver) NodePublishVolume added in v1.28.2 

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

func (LustreNodeDriver) NodeStageVolume added in v1.28.2 

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

func (LustreNodeDriver) NodeUnpublishVolume added in v1.28.2 

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

func (LustreNodeDriver) NodeUnstageVolume added in v1.28.2 

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

type MetricPusherGetter added in v1.24.1 

type MetricPusherGetter func(logger *zap.SugaredLogger) (*metrics.MetricPusher, error)

type NodeDriver 

type NodeDriver struct {
	KubeClient kubernetes.Interface
	// contains filtered or unexported fields
}

NodeDriver implements CSI Node interfaces

type SecretParameters added in v1.28.2 

type SecretParameters struct {
	// contains filtered or unexported fields
}

type SnapshotParameters added in v1.24.2 

type SnapshotParameters struct {
	// contains filtered or unexported fields
}

type StorageClassParameters added in v1.24.1 

type StorageClassParameters struct {
	// contains filtered or unexported fields
}

StorageClassParameters holds configuration

type VolumeAttachmentOption 

type VolumeAttachmentOption struct {
	// contains filtered or unexported fields
}

VolumeAttachmentOption holds config for attachments

type VolumeParameters 

type VolumeParameters struct {
	// contains filtered or unexported fields
}

VolumeParameters holds configuration

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.