nvmf

package
v0.0.0-...-18f1d04 Latest Latest
Warning

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

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

Documentation

Overview

Copyright 2021 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	NVMF_NQN_SIZE = 223
	SYS_NVMF      = "/sys/class/nvme"
	RUN_NVMF      = "/run/nvmf"
)
View Source 
const (
	ENOENT = 1 /* No such file or directory */
	EINVAL = 2 /* Invalid argument */
)

Here erron

View Source 
const (
	DefaultDriverName        = "csi.nvmf.com"
	DefaultDriverServicePort = "12230"
	DefaultDriverVersion     = "v1.0.0"

	DefaultVolumeMapPath = "/var/lib/nvmf/volumes"
)

Variables

This section is empty.

Functions

func AttachDisk 

func AttachDisk(req *csi.NodePublishVolumeRequest, nm nvmfDiskMounter) (string, error)

func DetachDisk 

func DetachDisk(volumeID string, num *nvmfDiskUnMounter, targetPath string) error

func GetDeviceNameByVolumeID 

func GetDeviceNameByVolumeID(volumeID string) (deviceName string, err error)

func NewDriver 

func NewDriver(conf *GlobalConfig) *driver

NewDriver create the identity/node

Types

type Connector 

type Connector struct {
	VolumeID      string
	DeviceUUID    string
	TargetNqn     string
	TargetAddr    string
	TargetPort    string
	Transport     string
	HostNqn       string
	RetryCount    int32
	CheckInterval int32
}

func GetConnectorFromFile 

func GetConnectorFromFile(filePath string) (*Connector, error)

func (*Connector) Connect 

func (c *Connector) Connect() (string, error)

connect to volume to this node and return devicePath

func (*Connector) Disconnect 

func (c *Connector) Disconnect() error

we disconnect only by nqn

type ControllerServer 

type ControllerServer struct {
	Driver *driver
}

func NewControllerServer 

func NewControllerServer(d *driver) *ControllerServer

create controller server

func (*ControllerServer) ControllerExpandVolume 

func (c *ControllerServer) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*ControllerServer) ControllerGetCapabilities 

func (c *ControllerServer) ControllerGetCapabilities(ctx context.Context, request *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

func (*ControllerServer) ControllerGetVolume 

func (c *ControllerServer) ControllerGetVolume(ctx context.Context, request *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

func (*ControllerServer) ControllerPublishVolume 

func (c *ControllerServer) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

func (*ControllerServer) ControllerUnpublishVolume 

func (c *ControllerServer) ControllerUnpublishVolume(ctx context.Context, request *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

func (*ControllerServer) CreateSnapshot 

func (c *ControllerServer) CreateSnapshot(ctx context.Context, request *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*ControllerServer) CreateVolume 

func (c *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

You should realize your volume provider here, such as requesting the Cloud to create an NVMf block and returning specific information to you

func (*ControllerServer) DeleteSnapshot 

func (c *ControllerServer) DeleteSnapshot(ctx context.Context, request *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*ControllerServer) DeleteVolume 

func (c *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

func (*ControllerServer) GetCapacity 

func (c *ControllerServer) GetCapacity(ctx context.Context, request *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

func (*ControllerServer) ListSnapshots 

func (c *ControllerServer) ListSnapshots(ctx context.Context, request *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*ControllerServer) ListVolumes 

func (c *ControllerServer) ListVolumes(ctx context.Context, request *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*ControllerServer) ValidateVolumeCapabilities 

func (c *ControllerServer) ValidateVolumeCapabilities(ctx context.Context, request *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type GlobalConfig 

type GlobalConfig struct {
	NVMfVolumeMapDir   string
	DriverName         string
	Region             string
	NodeID             string
	Endpoint           string // CSI endpoint
	Version            string
	IsControllerServer bool
	LogLevel           string
}

type IdentityServer 

type IdentityServer struct {
	Driver *driver
}

func NewIdentityServer 

func NewIdentityServer(d *driver) *IdentityServer

Create 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 NoControllerError 

type NoControllerError struct {
	Nqn     string
	Hostnqn string
}

func (*NoControllerError) Error 

func (e *NoControllerError) Error() string

type NodeServer 

type NodeServer struct {
	Driver *driver
}

func NewNodeServer 

func NewNodeServer(d *driver) *NodeServer

func (*NodeServer) NodeExpandVolume 

func (n *NodeServer) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*NodeServer) NodeGetCapabilities 

func (n *NodeServer) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (*NodeServer) NodeGetInfo 

func (n *NodeServer) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (*NodeServer) NodeGetVolumeStats 

func (n *NodeServer) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*NodeServer) NodePublishVolume 

func (n *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*NodeServer) NodeStageVolume 

func (n *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*NodeServer) NodeUnpublishVolume 

func (n *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*NodeServer) NodeUnstageVolume 

func (n *NodeServer) NodeUnstageVolume(ctx context.Context, req *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

type UnsupportedHostnqnError 

type UnsupportedHostnqnError struct {
	Target string
}

func (*UnsupportedHostnqnError) Error 

func (e *UnsupportedHostnqnError) Error() string

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.