pov

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MetadataURL = "http://100.100.100.200/latest/meta-data/"
	DocumentURL = "http://100.100.100.200/latest/dynamic/instance-identity/document"
)
View Source 
const (
	ZONEID                       = "zoneid"
	DATAREDUNDANCYTYPE           = "dataredundancytype"
	PROTOCOLTYPE                 = "protocoltype"
	STORAGETYPE                  = "storagetype"
	FILESYSTEMNAME               = "filesystemname"
	SPACECAPACITY                = "spacecapacity"
	THROUGHPUTMODE               = "throughputmode"
	PROVISIONEDTHROUGHPUTINMIBPS = "provisionedthroughputinmibps"
	FILESYSTEMID                 = "filesystemid"
	// PVCNameKey contains name of the PVC for which is a volume provisioned.
	PVCNameKey = "csi.storage.k8s.io/pvc/name"
	// PVCNamespaceKey contains namespace of the PVC for which is a volume provisioned.
	PVCNamespaceKey = "csi.storage.k8s.io/pvc/namespace"
	// PVNameKey contains name of the final PV that will be used for the dynamically
	// provisioned volume
	PVNameKey   = "csi.storage.k8s.io/pv/name"
	TopologyKey = "topology.kubernetes.io/region"
)
View Source 
const (
	DriverName = "povplugin.csi.alibabacloud.com"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Cloud 

type Cloud interface {
	CreateVolume(ctx context.Context, volumeName string, diskOptions *PovOptions) (fsId, requestID string, err error)
	DeleteVolume(ctx context.Context, volumeName string) (reuqestID string, err error)
	CreateVolumeMountPoint(ctx context.Context, filesystemID string) (mpId string, err error)
	AttachVscMountPoint(ctx context.Context, mpId, fsId, instanceID string) (requestID string, err error)
	DescribeVscMountPoints(ctx context.Context, fsId, mpId string) (dvmpr *dfs.DescribeVscMountPointsResponse, err error)
	DetachVscMountPoint(ctx context.Context, mpId, filesystemID, instanceID string) (requestID string, err error)
}

type GlobalConfig 

type GlobalConfig struct {
	// contains filtered or unexported fields
}
var GlobalConfigVar GlobalConfig

type InstanceDocument 

type InstanceDocument struct {
	RegionID   string `json:"region-id"`
	InstanceID string `json:"instance-id"`
	ZoneID     string `json:"zone-id"`
}

type MPInstance 

type MPInstance struct {
	InstanceId string
	Status     PovStatus
	Vscs       []*Vsc
}

type MetadataService 

type MetadataService interface {
	GetDoc() (*InstanceDocument, error)
}

func NewMetadataService 

func NewMetadataService() MetadataService

type PoV 

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

Pangu Over Virtio

func NewDriver 

func NewDriver(nodeID, endpoint string, runAsController bool) *PoV

func (*PoV) ControllerExpandVolume 

func (d *PoV) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*PoV) ControllerGetCapabilities 

func (d *PoV) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

func (*PoV) ControllerPublishVolume 

func (d *PoV) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

func (*PoV) ControllerUnpublishVolume 

func (d *PoV) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

func (*PoV) CreateSnapshot 

func (d *PoV) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*PoV) CreateVolume 

func (d *PoV) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

func (*PoV) DeleteSnapshot 

func (d *PoV) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*PoV) DeleteVolume 

func (d *PoV) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

func (*PoV) GetCapacity 

func (d *PoV) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

func (*PoV) GetPluginCapabilities 

func (p *PoV) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

func (*PoV) GetPluginInfo 

func (p *PoV) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

func (*PoV) ListSnapshots 

func (d *PoV) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*PoV) ListVolumes 

func (d *PoV) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*PoV) NodeExpandVolume 

func (d *PoV) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*PoV) NodeGetCapabilities 

func (d *PoV) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (*PoV) NodeGetInfo 

func (d *PoV) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (*PoV) NodeGetVolumeStats 

func (d *PoV) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*PoV) NodePublishVolume 

func (d *PoV) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*PoV) NodeStageVolume 

func (d *PoV) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*PoV) NodeUnpublishVolume 

func (d *PoV) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*PoV) NodeUnstageVolume 

func (d *PoV) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

func (*PoV) Probe 

func (p *PoV) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

func (*PoV) Run 

func (p *PoV) Run()

Run start pov driver service

func (*PoV) ValidateVolumeCapabilities 

func (d *PoV) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type PovOptions 

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

type PovStatus 

type PovStatus int
const (
	NORMAL   PovStatus = iota // NORMAL = 0
	CREATING                  // CREATING = 1
	INVALID                   // INVALID = 2
)

func (PovStatus) String 

func (vs PovStatus) String() string

type Vsc 

type Vsc struct {
	Id     string
	Status PovStatus
	Type   string
}

type VscMountPoint 

type VscMountPoint struct {
	MountPointId       string
	InstanceTotalCount int
	MountPointInstance []*MPInstance
}

type VscMountPointResp 

type VscMountPointResp struct {
	RequestID   string
	TotalCount  string
	MountPoints []*VscMountPoint
}

Source Files

View all Source files

Directories

Path Synopsis

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.