csicommon

package

v0.0.0-...-66ce57e Latest Latest Go to latest Published: Aug 6, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cubefs/cubefs-csi

Links

Open Source Insights

Documentation ¶

Index ¶

func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode
func ParseEndpoint(ep string) (string, string, error)
func RunControllerandNodePublishServer(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...)
func ShortenString(str string, n int) string
type CSIDriver
- func NewCSIDriver(name string, v string, nodeID string, clientSet *kubernetes.Clientset) *CSIDriver
type DefaultControllerServer
- func NewDefaultControllerServer(d *CSIDriver) *DefaultControllerServer
type DefaultIdentityServer
- func NewDefaultIdentityServer(d *CSIDriver) *DefaultIdentityServer
type DefaultNodeServer
- func NewDefaultNodeServer(d *CSIDriver) *DefaultNodeServer
type NonBlockingGRPCServer
- func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewControllerServiceCapability ¶

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

func NewVolumeCapabilityAccessMode ¶

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

func ParseEndpoint ¶

func ParseEndpoint(ep string) (string, string, error)

func RunControllerandNodePublishServer ¶

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

func ShortenString ¶

func ShortenString(str string, n int) string

ShortenString returns the first N slice of a string.

Types ¶

type CSIDriver ¶

type CSIDriver struct {
	Name      string
	NodeID    string
	Version   string
	ClientSet *kubernetes.Clientset
	// contains filtered or unexported fields
}

func NewCSIDriver ¶

func NewCSIDriver(name string, v string, nodeID string, clientSet *kubernetes.Clientset) *CSIDriver

Creates a NewCSIDriver object. Assumes vendor version is equal to driver version & does not support optional driver plugin info manifest field. Refer to CSI spec for more details.

func (*CSIDriver) AddControllerServiceCapabilities ¶

func (d *CSIDriver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)

func (*CSIDriver) AddVolumeCapabilityAccessModes ¶

func (d *CSIDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode

func (*CSIDriver) GetVolumeCapabilityAccessModes ¶

func (d *CSIDriver) GetVolumeCapabilityAccessModes() []*csi.VolumeCapability_AccessMode

func (*CSIDriver) ValidateControllerServiceRequest ¶

func (d *CSIDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error

type DefaultControllerServer ¶

type DefaultControllerServer struct {
	Driver *CSIDriver
}

func NewDefaultControllerServer ¶

func NewDefaultControllerServer(d *CSIDriver) *DefaultControllerServer

func (*DefaultControllerServer) ControllerExpandVolume ¶

func (cs *DefaultControllerServer) ControllerExpandVolume(context.Context, *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*DefaultControllerServer) ControllerGetCapabilities ¶

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

ControllerGetCapabilities implements the default GRPC callout. Default supports all capabilities

func (*DefaultControllerServer) ControllerGetVolume ¶

func (cs *DefaultControllerServer) ControllerGetVolume(ctx context.Context, request *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

ControllerGetVolume is still an alpha feature, we do not support it now

func (*DefaultControllerServer) ControllerPublishVolume ¶

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

func (*DefaultControllerServer) ControllerUnpublishVolume ¶

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

func (*DefaultControllerServer) CreateSnapshot ¶

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

func (*DefaultControllerServer) CreateVolume ¶

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

func (*DefaultControllerServer) DeleteSnapshot ¶

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

func (*DefaultControllerServer) DeleteVolume ¶

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

func (*DefaultControllerServer) GetCapacity ¶

func (cs *DefaultControllerServer) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

func (*DefaultControllerServer) ListSnapshots ¶

func (cs *DefaultControllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*DefaultControllerServer) ListVolumes ¶

func (cs *DefaultControllerServer) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*DefaultControllerServer) ValidateVolumeCapabilities ¶

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

type DefaultIdentityServer ¶

type DefaultIdentityServer struct {
	Driver *CSIDriver
}

func NewDefaultIdentityServer ¶

func NewDefaultIdentityServer(d *CSIDriver) *DefaultIdentityServer

func (*DefaultIdentityServer) GetPluginCapabilities ¶

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

func (*DefaultIdentityServer) GetPluginInfo ¶

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

func (*DefaultIdentityServer) Probe ¶

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

type DefaultNodeServer ¶

type DefaultNodeServer struct {
	Driver *CSIDriver
}

func NewDefaultNodeServer ¶

func NewDefaultNodeServer(d *CSIDriver) *DefaultNodeServer

func (*DefaultNodeServer) NodeExpandVolume ¶

func (ns *DefaultNodeServer) NodeExpandVolume(ctx context.Context, in *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*DefaultNodeServer) NodeGetCapabilities ¶

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

func (*DefaultNodeServer) NodeGetInfo ¶

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

func (*DefaultNodeServer) NodeGetVolumeStats ¶

func (ns *DefaultNodeServer) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*DefaultNodeServer) NodePublishVolume ¶

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

func (*DefaultNodeServer) NodeStageVolume ¶

func (ns *DefaultNodeServer) NodeStageVolume(ctx context.Context, in *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*DefaultNodeServer) NodeUnpublishVolume ¶

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

func (*DefaultNodeServer) NodeUnstageVolume ¶

func (ns *DefaultNodeServer) NodeUnstageVolume(ctx context.Context, in *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

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

Source Files ¶

View all Source files

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