wrapper

package
v0.7.0 Latest Latest
Warning

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

Go to latest
Published: Jul 25, 2023 License: Apache-2.0 Imports: 22 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 (*ControllerService) ControllerGetCapabilities

func (*ControllerService) ControllerGetVolume

func (*ControllerService) ControllerPublishVolume

func (*ControllerService) ControllerUnpublishVolume

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

type IdentityService

type IdentityService struct {
	TargetEndpoint string
}

func NewIdentityService

func NewIdentityService(targetEndpoint string) *IdentityService

func (*IdentityService) GetPluginCapabilities

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 (*PodVMNodeService) NodeGetInfo

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

func (*PodVMNodeService) NodeGetVolumeStats

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 (*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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL