services

package
v0.1.0-alpha.8 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2022 License: BSD-3-Clause Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PluginName    = "truenas.csi.choffmeister.de"
	PluginVersion = "0.1.0"

	// TODO move these to backend?
	DefaultVolumeSize int64 = 1024 * 1024 * 1024 // 1 GB
	MinVolumeSize     int64 = 1024 * 1024        // 1 MB
)

Variables

This section is empty.

Functions

func CreateCSIListener 

func CreateCSIListener() (net.Listener, error)

func CreateGRPCServer 

func CreateGRPCServer() *grpc.Server

func NewBackend 

func NewBackend() (backends.Backend, error)

func NewBackendForControllerExpandVolume 

func NewBackendForControllerExpandVolume(secrets map[string]string) (backends.Backend, error)

func NewBackendForCreateVolume 

func NewBackendForCreateVolume(parameters map[string]string, secrets map[string]string) (backends.Backend, error)

func NewBackendForDeleteVolume 

func NewBackendForDeleteVolume(secrets map[string]string) (backends.Backend, error)

func NewBackendForNodeExpandVolume 

func NewBackendForNodeExpandVolume() (backends.Backend, error)

func NewBackendForNodePublish 

func NewBackendForNodePublish(context map[string]string, secrets map[string]string) (backends.Backend, error)

func NewBackendForNodeUnpublish 

func NewBackendForNodeUnpublish() (backends.Backend, error)

Types

type ControllerService 

type ControllerService struct{}

func NewControllerService 

func NewControllerService() *ControllerService

func (*ControllerService) ControllerExpandVolume 

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

func (*ControllerService) ControllerGetCapabilities 

func (s *ControllerService) ControllerGetCapabilities(ctx context.Context, req *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(ctx context.Context, req *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(ctx context.Context, req *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(ctx context.Context, req *proto.GetCapacityRequest) (*proto.GetCapacityResponse, error)

func (*ControllerService) ListSnapshots 

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

func (*ControllerService) ListVolumes 

func (s *ControllerService) ListVolumes(ctx context.Context, req *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() *IdentityService

func (*IdentityService) GetPluginCapabilities 

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

func (*IdentityService) GetPluginInfo 

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

func (*IdentityService) Probe 

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

func (*IdentityService) SetReady 

func (s *IdentityService) SetReady(ready bool)

type NodeService 

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

func NewNodeService 

func NewNodeService(nodeId string) *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(ctx context.Context, req *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.