driver

package
v1.25.0 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2023 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

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"
)
View Source 
const (
	FipsEnabled = "1"
)

Variables

This section is empty.

Functions

func GetControllerDriver added in v1.24.1 

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

func GetNodeDriver 

func GetNodeDriver(name string, nodeID string, 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) 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"
)

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
}

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
}

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) 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 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 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.