csi

package
v1.1.1-rc2 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2021 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultCSIAttacherImage            = "longhornio/csi-attacher:v2.2.1-lh1"
	DefaultCSIProvisionerImage         = "longhornio/csi-provisioner:v1.6.0-lh1"
	DefaultCSIResizerImage             = "longhornio/csi-resizer:v0.5.1-lh1"
	DefaultCSISnapshotterImage         = "longhornio/csi-snapshotter:v2.1.1-lh1"
	DefaultCSINodeDriverRegistrarImage = "longhornio/csi-node-driver-registrar:v1.2.0-lh1"

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

	DefaultInContainerKubeletRootDir       = "/var/lib/kubelet/"
	DefaultCSISocketFileName               = "csi.sock"
	DefaultOnHostCSIRegistrationDirSuffix  = "/plugins_registry"
	DefaultOnHostObseletedPluginsDirSuffix = "/obsoleted-longhorn-plugins/"
	DefaultOnHostPluginsDirSuffix          = "/plugins/"
	DefaultInContainerCSISocketDir         = "/csi/"
	DefaultInContainerCSIRegistrationDir   = "/registration"
	DefaultInContainerPluginsDirSuffix     = "/plugins/"
	DefaultKubernetesCSIDirSuffix          = "/kubernetes.io/csi/"

	AnnotationCSIVersion        = types.LonghornDriverName + "/version"
	AnnotationKubernetesVersion = types.LonghornDriverName + "/kubernetes-version"
)

Variables

View Source 
var (
	HostPathDirectory             = v1.HostPathDirectory
	HostPathDirectoryOrCreate     = v1.HostPathDirectoryOrCreate
	MountPropagationBidirectional = v1.MountPropagationBidirectional
)
View Source 
var VERSION = "v1.1.0"

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 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 GetInContainerKubernetesCSIDir added in v0.8.0 

func GetInContainerKubernetesCSIDir() string

func GetInContainerPluginsDir added in v0.7.0 

func GetInContainerPluginsDir() string

func GetOnHostCSIRegistrationDir added in v0.7.0 

func GetOnHostCSIRegistrationDir(kubeletRootDir string) string

func GetOnHostCSISocketDir added in v0.7.0 

func GetOnHostCSISocketDir(kubeletRootDir string) string

func GetOnHostCSISocketFilePath added in v0.7.0 

func GetOnHostCSISocketFilePath(kubeletRootDir string) string

func GetOnHostKubernetesCSIDir added in v0.8.0 

func GetOnHostKubernetesCSIDir(kubeletRootDir string) string

func GetOnHostObseletedPluginsDir added in v0.8.0 

func GetOnHostObseletedPluginsDir(kubeletRootDir string) string

func GetOnHostPluginsDir added in v0.7.0 

func GetOnHostPluginsDir(kubeletRootDir string) string

func NewForcedParamsOsExec added in v1.0.0 

func NewForcedParamsOsExec(cmdParamMapping map[string]string) mount.Exec

NewForcedParamsOsExec 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 []v1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy v1.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) 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, csiVersion, 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, But Longhorn supports OFFLINE expansion only.

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, managerImage, managerURL, rootDir string,
	tolerations []v1.Toleration, tolerationsString, priorityClass, registrySecret string, imagePullPolicy v1.PullPolicy, nodeSelector map[string]string) *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 []v1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy v1.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 []v1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy v1.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 []v1.Toleration,
	tolerationsString, priorityClass, registrySecret string, imagePullPolicy v1.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.