driver

Documentation

Index

• Constants
• func NewControllerServiceCapability(c csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
• func NewNodeServiceCapability(c csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability
• func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode
• type GCSDriver
  • func NewGCSDriver(config *GCSDriverConfig) (*GCSDriver, error)
  • func (driver *GCSDriver) Run(endpoint string)
  • func (driver *GCSDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error
• type GCSDriverConfig
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants

const (
	// Keys for PV and PVC parameters as reported by external-provisioner.
	ParameterKeyPVCName      = "csi.storage.k8s.io/pvc/name"
	ParameterKeyPVCNamespace = "csi.storage.k8s.io/pvc/namespace"
	ParameterKeyPVName       = "csi.storage.k8s.io/pv/name"

	// User provided labels.
	ParameterKeyLabels = "labels"
)

CreateVolume parameters.

const (
	VolumeContextKeyServiceAccountName = "csi.storage.k8s.io/serviceAccount.name"
	//nolint:gosec
	VolumeContextKeyServiceAccountToken = "csi.storage.k8s.io/serviceAccount.tokens"
	VolumeContextKeyPodName             = "csi.storage.k8s.io/pod.name"
	VolumeContextKeyPodNamespace        = "csi.storage.k8s.io/pod.namespace"
	VolumeContextKeyEphemeral           = "csi.storage.k8s.io/ephemeral"
	VolumeContextKeyBucketName          = "bucketName"

	UmountTimeout = time.Second * 5

	FuseMountType = "fuse"
	TrueStr       = "true"
	FalseStr      = "false"
)

NodePublishVolume VolumeContext parameters.

const (
	CreateVolumeCSIFullMethod      = "/csi.v1.Controller/CreateVolume"
	DeleteVolumeCSIFullMethod      = "/csi.v1.Controller/DeleteVolume"
	NodePublishVolumeCSIFullMethod = "/csi.v1.Node/NodePublishVolume"

	VolumeContextKeyMountOptions              = "mountOptions"
	VolumeContextKeyFileCacheCapacity         = "fileCacheCapacity"
	VolumeContextKeyFileCacheForRangeRead     = "fileCacheForRangeRead"
	VolumeContextKeyMetadataStatCacheCapacity = "metadataStatCacheCapacity"
	VolumeContextKeyMetadataTypeCacheCapacity = "metadataTypeCacheCapacity"
	VolumeContextKeyMetadataCacheTTLSeconds   = "metadataCacheTTLSeconds"
	VolumeContextKeyGcsfuseLoggingSeverity    = "gcsfuseLoggingSeverity"
)

const DefaultName = "gcsfuse.csi.storage.gke.io"

const (
	MinimumVolumeSizeInBytes int64 = 1 * util.Mb
)

Functions

func NewControllerServiceCapability

func NewControllerServiceCapability(c csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability

func NewNodeServiceCapability

func NewNodeServiceCapability(c csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability

func NewVolumeCapabilityAccessMode

func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode

Types

type GCSDriver

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

func NewGCSDriver

func NewGCSDriver(config *GCSDriverConfig) (*GCSDriver, error)

func (*GCSDriver) Run

func (driver *GCSDriver) Run(endpoint string)

func (*GCSDriver) ValidateControllerServiceRequest

func (driver *GCSDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error

type GCSDriverConfig

type GCSDriverConfig struct {
	Name                  string // Driver name
	Version               string // Driver version
	NodeID                string // Node name
	RunController         bool   // Run CSI controller service
	RunNode               bool   // Run CSI node service
	StorageServiceManager storage.ServiceManager
	TokenManager          auth.TokenManager
	Mounter               mount.Interface
	K8sClients            clientset.Interface
}

type NonBlockingGRPCServer

type NonBlockingGRPCServer interface {
	// Start services at the endpoint
	Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)
	// Waits for the service to stop
	Wait()
	// Stops the service gracefully
	Stop()
	// Stops the service forcefully
	ForceStop()
}

Defines Non blocking GRPC server interfaces.

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() NonBlockingGRPCServer