csi

package
v1.7.0-rc3 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	DefaultCSIAttacherImage            = "longhornio/csi-attacher:v4.4.2"
	DefaultCSIProvisionerImage         = "longhornio/csi-provisioner:v3.6.2"
	DefaultCSIResizerImage             = "longhornio/csi-resizer:v1.9.2"
	DefaultCSISnapshotterImage         = "longhornio/csi-snapshotter:v6.3.2"
	DefaultCSINodeDriverRegistrarImage = "longhornio/csi-node-driver-registrar:v2.9.2"
	DefaultCSILivenessProbeImage       = "longhornio/livenessprobe:v2.12.0"

	DefaultCSIAttacherReplicaCount    = 3
	DefaultCSIProvisionerReplicaCount = 3
	DefaultCSIResizerReplicaCount     = 3
	DefaultCSISnapshotterReplicaCount = 3

	DefaultCSISocketFileName             = "csi.sock"
	DefaultCSIRegistrationDirSuffix      = "/plugins_registry"
	DefaultCSIPluginsDirSuffix           = "/plugins/"
	DefaultKubernetesCSIDirSuffix        = "/kubernetes.io/csi/"
	DefaultInContainerCSISocketDir       = "/csi/"
	DefaultInContainerCSIRegistrationDir = "/registration"
	DefaultCSILivenessProbePort          = 9808

	AnnotationCSIGitCommit = types.LonghornDriverName + "/git-commit"
	AnnotationCSIVersion   = types.LonghornDriverName + "/version"
)

Variables

View Source 
var (
	HostPathDirectoryOrCreate     = corev1.HostPathDirectoryOrCreate
	MountPropagationBidirectional = corev1.MountPropagationBidirectional
)

Functions

func CheckMountPropagationWithNode 

func CheckMountPropagationWithNode(managerURL string) error

CheckMountPropagationWithNode https://github.com/kubernetes/kubernetes/issues/66086#issuecomment-404346854

func GetCSIEndpoint added in v0.7.0 

func GetCSIEndpoint() string

func GetCSIKubernetesDir added in v1.1.2 

func GetCSIKubernetesDir(kubeletRootDir string) string

func GetCSIPluginsDir added in v1.1.2 

func GetCSIPluginsDir(kubeletRootDir string) string

func GetCSIPodsDir added in v1.1.2 

func GetCSIPodsDir(kubeletRootDir string) string

func GetCSIRegistrationDir added in v1.1.2 

func GetCSIRegistrationDir(kubeletRootDir string) string

func GetCSISocketDir added in v1.1.2 

func GetCSISocketDir(kubeletRootDir string) string

func GetCSISocketFilePath added in v1.1.2 

func GetCSISocketFilePath(kubeletRootDir string) string

func GetInContainerCSIRegistrationDir added in v0.7.0 

func GetInContainerCSIRegistrationDir() string

func GetInContainerCSISocketDir added in v0.7.0 

func GetInContainerCSISocketDir() string

func GetInContainerCSISocketFilePath added in v0.7.0 

func GetInContainerCSISocketFilePath() string

func NewForcedParamsExec added in v1.2.0 

func NewForcedParamsExec(cmdParamMapping map[string]string) utilexec.Interface

NewForcedParamsExec creates a osExecutor that allows for adding additional params to later occurring Run calls

Types

type AttacherDeployment 

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

func NewAttacherDeployment 

func NewAttacherDeployment(namespace, serviceAccount, attacherImage, rootDir string, replicaCount int, tolerations []corev1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy corev1.PullPolicy, nodeSelector map[string]string) *AttacherDeployment

func (*AttacherDeployment) Cleanup 

func (a *AttacherDeployment) Cleanup(kubeClient *clientset.Clientset)

func (*AttacherDeployment) Deploy 

func (a *AttacherDeployment) Deploy(kubeClient *clientset.Clientset) error

type ControllerServer 

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

func NewControllerServer 

func NewControllerServer(apiClient *longhornclient.RancherClient, nodeID string) *ControllerServer

func (*ControllerServer) ControllerExpandVolume added in v0.7.0 

func (cs *ControllerServer) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*ControllerServer) ControllerGetCapabilities added in v0.7.0 

func (cs *ControllerServer) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

func (*ControllerServer) ControllerGetVolume added in v1.3.0 

func (cs *ControllerServer) ControllerGetVolume(context.Context, *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

func (*ControllerServer) ControllerModifyVolume added in v1.7.0 

func (cs *ControllerServer) ControllerModifyVolume(ctx context.Context, req *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

func (*ControllerServer) ControllerPublishVolume 

func (cs *ControllerServer) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

ControllerPublishVolume will attach the volume to the specified node

func (*ControllerServer) ControllerUnpublishVolume 

func (cs *ControllerServer) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

ControllerUnpublishVolume will detach the volume

func (*ControllerServer) CreateSnapshot added in v0.7.0 

func (cs *ControllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*ControllerServer) CreateVolume 

func (cs *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

func (*ControllerServer) DeleteSnapshot added in v0.7.0 

func (cs *ControllerServer) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*ControllerServer) DeleteVolume 

func (cs *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

func (*ControllerServer) GetCapacity added in v0.7.0 

func (cs *ControllerServer) GetCapacity(context.Context, *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

func (*ControllerServer) ListSnapshots added in v0.7.0 

func (cs *ControllerServer) ListSnapshots(context.Context, *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*ControllerServer) ListVolumes 

func (cs *ControllerServer) ListVolumes(context.Context, *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*ControllerServer) ValidateVolumeCapabilities 

func (cs *ControllerServer) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type DriverObjectDeployment added in v0.7.0 

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

func NewCSIDriverObject added in v0.7.0 

func NewCSIDriverObject() *DriverObjectDeployment

func (*DriverObjectDeployment) Cleanup added in v0.7.0 

func (d *DriverObjectDeployment) Cleanup(kubeClient *clientset.Clientset)

func (*DriverObjectDeployment) Deploy added in v0.7.0 

func (d *DriverObjectDeployment) Deploy(kubeClient *clientset.Clientset) error

type IdentityServer 

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

func NewIdentityServer 

func NewIdentityServer(driverName, version string) *IdentityServer

func (*IdentityServer) GetPluginCapabilities 

func (ids *IdentityServer) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

func (*IdentityServer) GetPluginInfo 

func (ids *IdentityServer) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

func (*IdentityServer) Probe 

func (ids *IdentityServer) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

type Manager 

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

func GetCSIManager 

func GetCSIManager() *Manager

func (*Manager) Run 

func (m *Manager) Run(driverName, nodeID, endpoint, identityVersion, managerURL string) error

type NodeServer 

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

func NewNodeServer 

func NewNodeServer(apiClient *longhornclient.RancherClient, nodeID string) *NodeServer

func (*NodeServer) NodeExpandVolume added in v0.7.0 

func (ns *NodeServer) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

NodeExpandVolume is designed to expand the file system for ONLINE expansion,

func (*NodeServer) NodeGetCapabilities added in v0.7.0 

func (ns *NodeServer) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (*NodeServer) NodeGetInfo added in v0.7.0 

func (ns *NodeServer) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (*NodeServer) NodeGetVolumeStats added in v0.7.0 

func (ns *NodeServer) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*NodeServer) NodePublishVolume 

func (ns *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

NodePublishVolume will mount the volume /dev/longhorn/<volume_name> to target_path

func (*NodeServer) NodeStageVolume 

func (ns *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*NodeServer) NodeUnpublishVolume 

func (ns *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*NodeServer) NodeUnstageVolume 

func (ns *NodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

type NonBlockingGRPCServer added in v0.7.0 

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

func NewNonBlockingGRPCServer added in v0.7.0 

func NewNonBlockingGRPCServer() *NonBlockingGRPCServer

func (*NonBlockingGRPCServer) ForceStop added in v0.7.0 

func (s *NonBlockingGRPCServer) ForceStop()

func (*NonBlockingGRPCServer) Start added in v0.7.0 

func (s *NonBlockingGRPCServer) Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)

func (*NonBlockingGRPCServer) Stop added in v0.7.0 

func (s *NonBlockingGRPCServer) Stop()

func (*NonBlockingGRPCServer) Wait added in v0.7.0 

func (s *NonBlockingGRPCServer) Wait()

type PluginDeployment 

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

func NewPluginDeployment 

func NewPluginDeployment(namespace, serviceAccount, nodeDriverRegistrarImage, livenessProbeImage, managerImage, managerURL, rootDir string,
	tolerations []corev1.Toleration, tolerationsString, priorityClass, registrySecret string, imagePullPolicy corev1.PullPolicy, nodeSelector map[string]string,
	storageNetworkSetting *longhorn.Setting, isStorageNetworkForRWXVolumeEnabled bool) *PluginDeployment

func (*PluginDeployment) Cleanup 

func (p *PluginDeployment) Cleanup(kubeClient *clientset.Clientset)

func (*PluginDeployment) Deploy 

func (p *PluginDeployment) Deploy(kubeClient *clientset.Clientset) error

type ProvisionerDeployment 

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

func NewProvisionerDeployment 

func NewProvisionerDeployment(namespace, serviceAccount, provisionerImage, rootDir string, replicaCount int, tolerations []corev1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy corev1.PullPolicy, nodeSelector map[string]string) *ProvisionerDeployment

func (*ProvisionerDeployment) Cleanup 

func (p *ProvisionerDeployment) Cleanup(kubeClient *clientset.Clientset)

func (*ProvisionerDeployment) Deploy 

func (p *ProvisionerDeployment) Deploy(kubeClient *clientset.Clientset) error

type ResizerDeployment added in v0.8.0 

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

func NewResizerDeployment added in v0.8.0 

func NewResizerDeployment(namespace, serviceAccount, resizerImage, rootDir string, replicaCount int, tolerations []corev1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy corev1.PullPolicy, nodeSelector map[string]string) *ResizerDeployment

func (*ResizerDeployment) Cleanup added in v0.8.0 

func (p *ResizerDeployment) Cleanup(kubeClient *clientset.Clientset)

func (*ResizerDeployment) Deploy added in v0.8.0 

func (p *ResizerDeployment) Deploy(kubeClient *clientset.Clientset) error

type SnapshotterDeployment added in v1.1.0 

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

func NewSnapshotterDeployment added in v1.1.0 

func NewSnapshotterDeployment(namespace, serviceAccount, snapshotterImage, rootDir string, replicaCount int, tolerations []corev1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy corev1.PullPolicy, nodeSelector map[string]string) *SnapshotterDeployment

func (*SnapshotterDeployment) Cleanup added in v1.1.0 

func (p *SnapshotterDeployment) Cleanup(kubeClient *clientset.Clientset)

func (*SnapshotterDeployment) Deploy added in v1.1.0 

func (p *SnapshotterDeployment) Deploy(kubeClient *clientset.Clientset) error

Source Files

View all Source files

Directories

Path Synopsis

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.