csicommon

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2019 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewControllerServiceCapability 

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

NewControllerServiceCapability returns controller capabilities

func NewVolumeCapabilityAccessMode 

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

NewVolumeCapabilityAccessMode returns volume access mode

func RunControllerPublishServer 

func RunControllerPublishServer(endpoint, hstOption string, d *CSIDriver, cs csi.ControllerServer, m bool)

RunControllerPublishServer starts controller server

func RunControllerandNodePublishServer 

func RunControllerandNodePublishServer(endpoint, hstOption string, d *CSIDriver, cs csi.ControllerServer, ns csi.NodeServer, m bool)

RunControllerandNodePublishServer starts both controller and node server

func RunNodePublishServer 

func RunNodePublishServer(endpoint, hstOption string, d *CSIDriver, ns csi.NodeServer, m bool)

RunNodePublishServer starts node server

Types

type CSIDriver 

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

CSIDriver stores driver information

func NewCSIDriver 

func NewCSIDriver(name, v, nodeID string) *CSIDriver

NewCSIDriver 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)

AddControllerServiceCapabilities stores the controller capabilities in driver object

func (*CSIDriver) AddVolumeCapabilityAccessModes 

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

AddVolumeCapabilityAccessModes stores volume access modes

func (*CSIDriver) GetVolumeCapabilityAccessModes 

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

GetVolumeCapabilityAccessModes returns access modes

func (*CSIDriver) ValidateControllerServiceRequest 

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

ValidateControllerServiceRequest validates the controller plugin capabilities

type DefaultControllerServer 

type DefaultControllerServer struct {
	Driver *CSIDriver
}

DefaultControllerServer points to default driver

func NewDefaultControllerServer 

func NewDefaultControllerServer(d *CSIDriver) *DefaultControllerServer

NewDefaultControllerServer initializes default controller server

func (*DefaultControllerServer) ControllerExpandVolume 

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

ControllerExpandVolume expand volume

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) ControllerPublishVolume 

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

ControllerPublishVolume publish volume on node

func (*DefaultControllerServer) ControllerUnpublishVolume 

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

ControllerUnpublishVolume unpublish on node

func (*DefaultControllerServer) CreateSnapshot 

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

CreateSnapshot creates snapshot

func (*DefaultControllerServer) DeleteSnapshot 

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

DeleteSnapshot deletes snapshot

func (*DefaultControllerServer) GetCapacity 

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

GetCapacity get volume capacity

func (*DefaultControllerServer) ListSnapshots 

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

ListSnapshots lists snapshosts

func (*DefaultControllerServer) ListVolumes 

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

ListVolumes lists volumes

type DefaultIdentityServer 

type DefaultIdentityServer struct {
	Driver *CSIDriver
}

DefaultIdentityServer stores driver object

func NewDefaultIdentityServer 

func NewDefaultIdentityServer(d *CSIDriver) *DefaultIdentityServer

NewDefaultIdentityServer initializes default identity servier

func (*DefaultIdentityServer) GetPluginCapabilities 

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

GetPluginCapabilities returns plugin capabilities

func (*DefaultIdentityServer) GetPluginInfo 

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

GetPluginInfo returns plugin information

func (*DefaultIdentityServer) Probe 

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

Probe returns empty response

type DefaultNodeServer 

type DefaultNodeServer struct {
	Driver *CSIDriver
	Type   string
}

DefaultNodeServer stores driver object

func NewDefaultNodeServer 

func NewDefaultNodeServer(d *CSIDriver, t string) *DefaultNodeServer

NewDefaultNodeServer initializes default node server

func (*DefaultNodeServer) NodeExpandVolume 

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

NodeExpandVolume returns unimplemented response

func (*DefaultNodeServer) NodeGetCapabilities 

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

NodeGetCapabilities returns RPC unknow capability

func (*DefaultNodeServer) NodeGetInfo 

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

NodeGetInfo returns node ID

func (*DefaultNodeServer) NodeGetVolumeStats 

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

NodeGetVolumeStats returns volume stats

func (*DefaultNodeServer) NodeStageVolume 

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

NodeStageVolume returns unimplemented response

func (*DefaultNodeServer) NodeUnstageVolume 

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

NodeUnstageVolume returns unimplemented response

type NonBlockingGRPCServer 

type NonBlockingGRPCServer interface {
	// Start services at the endpoint
	Start(endpoint, hstOptions string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer, metrics bool)
	// Waits for the service to stop
	Wait()
	// Stops the service gracefully
	Stop()
	// Stops the service forcefully
	ForceStop()
}

NonBlockingGRPCServer defines Non blocking GRPC server interfaces

func NewNonBlockingGRPCServer 

func NewNonBlockingGRPCServer() NonBlockingGRPCServer

NewNonBlockingGRPCServer return non-blocking GRPC

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.