wrapper

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// PublishInfoVolumeID ...
	PublishInfoVolumeID = "volume-id"

	// PublishInfoNodeID ...
	PublishInfoNodeID = "node-id"

	// PublishInfoStatus ...
	PublishInfoStatus = "attach-status"

	// PublishInfoDevicePath ...
	PublishInfoDevicePath = "device-path"

	// PublishInfoRequestID ...
	PublishInfoRequestID = "request-id"

	// Parameter key for Peer Pod from StorageClass
	PeerpodParamKey = "peerpod"
)
View Source 
const (
	DefaultKubeletLibDir  = "/var/lib/kubelet"
	DefaultKubeletDataDir = "/var/data/kubelet"
	DefaultMountInfo      = "{\"Device\": \"/dev/zero\", \"fstype\": \"ext4\"}"
)

Variables

This section is empty.

Functions

func NewNonBlockingGRPCServer 

func NewNonBlockingGRPCServer() *nonBlockingGRPCServer

func Run 

func Run(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer) error

Types

type ControllerService 

type ControllerService struct {
	TargetEndpoint      string
	Namespace           string
	PeerpodvolumeClient *peerpodvolume.Clientset
}

func NewControllerService 

func NewControllerService(targetEndpoint, namespace string, peerpodvolumeClientSet *peerpodvolume.Clientset) *ControllerService

func (*ControllerService) ControllerExpandVolume 

func (s *ControllerService) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (res *csi.ControllerExpandVolumeResponse, err error)

func (*ControllerService) ControllerGetCapabilities 

func (s *ControllerService) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (res *csi.ControllerGetCapabilitiesResponse, err error)

func (*ControllerService) ControllerGetVolume 

func (s *ControllerService) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (res *csi.ControllerGetVolumeResponse, err error)

func (*ControllerService) ControllerPublishVolume 

func (s *ControllerService) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (res *csi.ControllerPublishVolumeResponse, err error)

func (*ControllerService) ControllerUnpublishVolume 

func (s *ControllerService) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (res *csi.ControllerUnpublishVolumeResponse, err error)

func (*ControllerService) CreateSnapshot 

func (s *ControllerService) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (res *csi.CreateSnapshotResponse, err error)

func (*ControllerService) CreateVolume 

func (s *ControllerService) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (res *csi.CreateVolumeResponse, err error)

func (*ControllerService) DeleteFunction 

func (s *ControllerService) DeleteFunction(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*ControllerService) DeleteSnapshot 

func (s *ControllerService) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (res *csi.DeleteSnapshotResponse, err error)

func (*ControllerService) DeleteVolume 

func (s *ControllerService) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (res *csi.DeleteVolumeResponse, err error)

func (*ControllerService) GetCapacity 

func (s *ControllerService) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (res *csi.GetCapacityResponse, err error)

func (*ControllerService) ListSnapshots 

func (s *ControllerService) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (res *csi.ListSnapshotsResponse, err error)

func (*ControllerService) ListVolumes 

func (s *ControllerService) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (res *csi.ListVolumesResponse, err error)

func (*ControllerService) SyncHandler 

func (s *ControllerService) SyncHandler(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*ControllerService) ValidateVolumeCapabilities 

func (s *ControllerService) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (res *csi.ValidateVolumeCapabilitiesResponse, err error)

type IdentityService 

type IdentityService struct {
	TargetEndpoint string
}

func NewIdentityService 

func NewIdentityService(targetEndpoint string) *IdentityService

func (*IdentityService) GetPluginCapabilities 

func (s *IdentityService) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (res *csi.GetPluginCapabilitiesResponse, err error)

func (*IdentityService) GetPluginInfo 

func (s *IdentityService) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (res *csi.GetPluginInfoResponse, err error)

func (*IdentityService) Probe 

func (s *IdentityService) Probe(ctx context.Context, req *csi.ProbeRequest) (res *csi.ProbeResponse, err error)

type NodeService 

type NodeService struct {
	TargetEndpoint          string
	Namespace               string
	PeerpodvolumeClient     *peerpodvolume.Clientset
	VMIDInformationEndpoint string
}

func NewNodeService 

func NewNodeService(targetEndpoint, namespace string, peerpodvolumeClientSet *peerpodvolume.Clientset, vmIDInformationEndpoint string) *NodeService

func (*NodeService) DeleteFunction 

func (s *NodeService) DeleteFunction(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*NodeService) NodeExpandVolume 

func (s *NodeService) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (res *csi.NodeExpandVolumeResponse, err error)

func (*NodeService) NodeGetCapabilities 

func (s *NodeService) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (res *csi.NodeGetCapabilitiesResponse, err error)

func (*NodeService) NodeGetInfo 

func (s *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (res *csi.NodeGetInfoResponse, err error)

func (*NodeService) NodeGetVolumeStats 

func (s *NodeService) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (res *csi.NodeGetVolumeStatsResponse, err error)

func (*NodeService) NodePublishVolume 

func (s *NodeService) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (res *csi.NodePublishVolumeResponse, err error)

func (*NodeService) NodeStageVolume 

func (s *NodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (res *csi.NodeStageVolumeResponse, err error)

func (*NodeService) NodeUnpublishVolume 

func (s *NodeService) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (res *csi.NodeUnpublishVolumeResponse, err error)

func (*NodeService) NodeUnstageVolume 

func (s *NodeService) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (res *csi.NodeUnstageVolumeResponse, err error)

func (*NodeService) SyncHandler 

func (s *NodeService) SyncHandler(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

type PodVMNodeService 

type PodVMNodeService struct {
	TargetEndpoint      string
	Namespace           string
	PeerpodvolumeClient *peerpodvolume.Clientset
}

func NewPodVMNodeService 

func NewPodVMNodeService(targetEndpoint, namespace string, peerpodvolumeClientSet *peerpodvolume.Clientset) *PodVMNodeService

func (*PodVMNodeService) DeleteFunction 

func (s *PodVMNodeService) DeleteFunction(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*PodVMNodeService) NodeExpandVolume 

func (s *PodVMNodeService) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (res *csi.NodeExpandVolumeResponse, err error)

func (*PodVMNodeService) NodeGetCapabilities 

func (s *PodVMNodeService) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (res *csi.NodeGetCapabilitiesResponse, err error)

func (*PodVMNodeService) NodeGetInfo 

func (s *PodVMNodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (res *csi.NodeGetInfoResponse, err error)

func (*PodVMNodeService) NodeGetVolumeStats 

func (s *PodVMNodeService) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (res *csi.NodeGetVolumeStatsResponse, err error)

func (*PodVMNodeService) NodePublishVolume 

func (s *PodVMNodeService) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (res *csi.NodePublishVolumeResponse, err error)

func (*PodVMNodeService) NodeStageVolume 

func (s *PodVMNodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (res *csi.NodeStageVolumeResponse, err error)

func (*PodVMNodeService) NodeUnpublishVolume 

func (s *PodVMNodeService) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (res *csi.NodeUnpublishVolumeResponse, err error)

func (*PodVMNodeService) NodeUnstageVolume 

func (s *PodVMNodeService) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (res *csi.NodeUnstageVolumeResponse, err error)

func (*PodVMNodeService) ReproduceNodePublishVolume 

func (s *PodVMNodeService) ReproduceNodePublishVolume(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*PodVMNodeService) ReproduceNodeStageVolume 

func (s *PodVMNodeService) ReproduceNodeStageVolume(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*PodVMNodeService) ReproduceNodeUnpublishVolume 

func (s *PodVMNodeService) ReproduceNodeUnpublishVolume(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*PodVMNodeService) ReproduceNodeUnstageVolume 

func (s *PodVMNodeService) ReproduceNodeUnstageVolume(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

func (*PodVMNodeService) SyncHandler 

func (s *PodVMNodeService) SyncHandler(peerPodVolume *peerpodvolumeV1alpha1.PeerpodVolume)

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.