driver

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2021 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PluginName    = "csi.hetzner.cloud"
	PluginVersion = "1.6.0"

	MaxVolumesPerNode = 16
	MinVolumeSize     = 10 // GB
	DefaultVolumeSize = MinVolumeSize

	TopologySegmentLocation = PluginName + "/location"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ControllerService 

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

func NewControllerService 

func NewControllerService(
	logger log.Logger,
	volumeService volumes.Service,
	location string,
) *ControllerService

func (*ControllerService) ControllerExpandVolume 

func (s *ControllerService) ControllerExpandVolume(ctx context.Context, req *proto.ControllerExpandVolumeRequest) (*proto.ControllerExpandVolumeResponse, error)

func (*ControllerService) ControllerGetCapabilities 

func (s *ControllerService) ControllerGetCapabilities(context.Context, *proto.ControllerGetCapabilitiesRequest) (*proto.ControllerGetCapabilitiesResponse, error)

func (*ControllerService) ControllerGetVolume 

func (s *ControllerService) ControllerGetVolume(ctx context.Context, req *proto.ControllerGetVolumeRequest) (*proto.ControllerGetVolumeResponse, error)

func (*ControllerService) ControllerPublishVolume 

func (s *ControllerService) ControllerPublishVolume(ctx context.Context, req *proto.ControllerPublishVolumeRequest) (*proto.ControllerPublishVolumeResponse, error)

func (*ControllerService) ControllerUnpublishVolume 

func (s *ControllerService) ControllerUnpublishVolume(ctx context.Context, req *proto.ControllerUnpublishVolumeRequest) (*proto.ControllerUnpublishVolumeResponse, error)

func (*ControllerService) CreateSnapshot 

func (s *ControllerService) CreateSnapshot(context.Context, *proto.CreateSnapshotRequest) (*proto.CreateSnapshotResponse, error)

func (*ControllerService) CreateVolume 

func (s *ControllerService) CreateVolume(ctx context.Context, req *proto.CreateVolumeRequest) (*proto.CreateVolumeResponse, error)

func (*ControllerService) DeleteSnapshot 

func (s *ControllerService) DeleteSnapshot(context.Context, *proto.DeleteSnapshotRequest) (*proto.DeleteSnapshotResponse, error)

func (*ControllerService) DeleteVolume 

func (s *ControllerService) DeleteVolume(ctx context.Context, req *proto.DeleteVolumeRequest) (*proto.DeleteVolumeResponse, error)

func (*ControllerService) GetCapacity 

func (s *ControllerService) GetCapacity(context.Context, *proto.GetCapacityRequest) (*proto.GetCapacityResponse, error)

func (*ControllerService) ListSnapshots 

func (s *ControllerService) ListSnapshots(context.Context, *proto.ListSnapshotsRequest) (*proto.ListSnapshotsResponse, error)

func (*ControllerService) ListVolumes 

func (s *ControllerService) ListVolumes(context.Context, *proto.ListVolumesRequest) (*proto.ListVolumesResponse, error)

func (*ControllerService) ValidateVolumeCapabilities 

func (s *ControllerService) ValidateVolumeCapabilities(ctx context.Context, req *proto.ValidateVolumeCapabilitiesRequest) (*proto.ValidateVolumeCapabilitiesResponse, error)

type IdentityService 

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

func NewIdentityService 

func NewIdentityService(logger log.Logger) *IdentityService

func (*IdentityService) GetPluginCapabilities 

func (s *IdentityService) GetPluginCapabilities(context.Context, *proto.GetPluginCapabilitiesRequest) (*proto.GetPluginCapabilitiesResponse, error)

func (*IdentityService) GetPluginInfo 

func (s *IdentityService) GetPluginInfo(context.Context, *proto.GetPluginInfoRequest) (*proto.GetPluginInfoResponse, error)

func (*IdentityService) Probe 

func (s *IdentityService) Probe(context.Context, *proto.ProbeRequest) (*proto.ProbeResponse, error)

func (*IdentityService) SetReady 

func (s *IdentityService) SetReady(ready bool)

type NodeService 

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

func NewNodeService 

func NewNodeService(
	logger log.Logger,
	server *hcloud.Server,
	volumeService volumes.Service,
	volumeMountService volumes.MountService,
	volumeResizeService volumes.ResizeService,
	volumeStatsService volumes.StatsService,
) *NodeService

func (*NodeService) NodeExpandVolume 

func (s *NodeService) NodeExpandVolume(ctx context.Context, req *proto.NodeExpandVolumeRequest) (*proto.NodeExpandVolumeResponse, error)

func (*NodeService) NodeGetCapabilities 

func (s *NodeService) NodeGetCapabilities(ctx context.Context, req *proto.NodeGetCapabilitiesRequest) (*proto.NodeGetCapabilitiesResponse, error)

func (*NodeService) NodeGetInfo 

func (s *NodeService) NodeGetInfo(context.Context, *proto.NodeGetInfoRequest) (*proto.NodeGetInfoResponse, error)

func (*NodeService) NodeGetVolumeStats 

func (s *NodeService) NodeGetVolumeStats(ctx context.Context, req *proto.NodeGetVolumeStatsRequest) (*proto.NodeGetVolumeStatsResponse, error)

func (*NodeService) NodePublishVolume 

func (s *NodeService) NodePublishVolume(ctx context.Context, req *proto.NodePublishVolumeRequest) (*proto.NodePublishVolumeResponse, error)

func (*NodeService) NodeStageVolume 

func (s *NodeService) NodeStageVolume(ctx context.Context, req *proto.NodeStageVolumeRequest) (*proto.NodeStageVolumeResponse, error)

func (*NodeService) NodeUnpublishVolume 

func (s *NodeService) NodeUnpublishVolume(ctx context.Context, req *proto.NodeUnpublishVolumeRequest) (*proto.NodeUnpublishVolumeResponse, error)

func (*NodeService) NodeUnstageVolume 

func (s *NodeService) NodeUnstageVolume(ctx context.Context, req *proto.NodeUnstageVolumeRequest) (*proto.NodeUnstageVolumeResponse, error)

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.