webdav

package
v0.0.0-...-ff95639 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultDriverName = "webdav.csi.io"
)

Variables

This section is empty.

Functions

func GetVersionYAML 

func GetVersionYAML(driverName string) (string, error)

GetVersionYAML returns the version information of the driver

func MakeVolumeId 

func MakeVolumeId(webdavSharePath, volumeName string) string

func NewControllerServiceCapability 

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

func NewNodeServiceCapability 

func NewNodeServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability

func ParseEndpoint 

func ParseEndpoint(ep string) (string, string, error)

func ParseVolumeId 

func ParseVolumeId(volumeId string) (webdavSharePath, subDir string, err error)

Types

type ControllerServer 

type ControllerServer struct {
	*Driver
	// contains filtered or unexported fields
}

func NewControllerServer 

func NewControllerServer(d *Driver, mounter mount.Interface) *ControllerServer

func (*ControllerServer) ControllerExpandVolume 

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

ControllerExpandVolume implements csi.ControllerServer.

func (*ControllerServer) ControllerGetCapabilities 

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

ControllerGetCapabilities implements csi.ControllerServer.

func (*ControllerServer) ControllerGetVolume 

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

ControllerGetVolume implements csi.ControllerServer.

func (*ControllerServer) ControllerModifyVolume 

func (*ControllerServer) ControllerModifyVolume(context.Context, *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

ControllerModifyVolume implements csi.ControllerServer.

func (*ControllerServer) ControllerPublishVolume 

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

ControllerPublishVolume implements csi.ControllerServer.

func (*ControllerServer) ControllerUnpublishVolume 

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

ControllerUnpublishVolume implements csi.ControllerServer.

func (*ControllerServer) CreateSnapshot 

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

CreateSnapshot implements csi.ControllerServer.

func (*ControllerServer) CreateVolume 

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

CreateVolume implements csi.ControllerServer.

func (*ControllerServer) DeleteSnapshot 

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

DeleteSnapshot implements csi.ControllerServer.

func (*ControllerServer) DeleteVolume 

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

DeleteVolume implements csi.ControllerServer.

func (*ControllerServer) GetCapacity 

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

GetCapacity implements csi.ControllerServer.

func (*ControllerServer) ListSnapshots 

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

ListSnapshots implements csi.ControllerServer.

func (*ControllerServer) ListVolumes 

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

ListVolumes implements csi.ControllerServer.

func (*ControllerServer) ValidateVolumeCapabilities 

func (c *ControllerServer) ValidateVolumeCapabilities(_ context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

ValidateVolumeCapabilities implements csi.ControllerServer.

type Driver 

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

func NewDriver 

func NewDriver(opt *DriverOpt) *Driver

func (*Driver) AddControllerServiceCapabilities 

func (d *Driver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)

func (*Driver) AddNodeServiceCapabilities 

func (d *Driver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type)

func (*Driver) Run 

func (d *Driver) Run()

type DriverOpt 

type DriverOpt struct {
	Name                  string
	NodeID                string
	Endpoint              string
	MountPermissions      uint64
	WorkingMountDir       string
	DefaultOnDeletePolicy string
}

type IdentityServer 

type IdentityServer struct {
	Driver *Driver
}

func NewIdentityServer 

func NewIdentityServer(d *Driver) *IdentityServer

func (*IdentityServer) GetPluginCapabilities 

func (ids *IdentityServer) GetPluginCapabilities(_ context.Context, _ *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

func (*IdentityServer) GetPluginInfo 

func (ids *IdentityServer) GetPluginInfo(_ context.Context, _ *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

func (*IdentityServer) Probe 

func (ids *IdentityServer) Probe(_ context.Context, _ *csi.ProbeRequest) (*csi.ProbeResponse, error)

type NodeServer 

type NodeServer struct {
	Driver *Driver
	// contains filtered or unexported fields
}

func NewNodeServer 

func NewNodeServer(d *Driver, mounter mount.Interface) *NodeServer

func (*NodeServer) NodeExpandVolume 

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

NodeExpandVolume implements csi.NodeServer.

func (*NodeServer) NodeGetCapabilities 

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

NodeGetCapabilities implements csi.NodeServer.

func (*NodeServer) NodeGetInfo 

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

NodeGetInfo implements csi.NodeServer.

func (*NodeServer) NodeGetVolumeStats 

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

NodeGetVolumeStats implements csi.NodeServer.

func (*NodeServer) NodePublishVolume 

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

NodePublishVolume implements csi.NodeServer.

func (*NodeServer) NodeStageVolume 

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

NodeStageVolume implements csi.NodeServer.

func (*NodeServer) NodeUnpublishVolume 

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

NodeUnpublishVolume implements csi.NodeServer.

func (*NodeServer) NodeUnstageVolume 

func (*NodeServer) NodeUnstageVolume(context.Context, *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

NodeUnstageVolume implements csi.NodeServer.

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 VersionInfo 

type VersionInfo struct {
	DriverName    string `json:"Driver Name"`
	DriverVersion string `json:"Driver Version"`
	GitCommit     string `json:"Git Commit"`
	BuildDate     string `json:"Build Date"`
	GoVersion     string `json:"Go Version"`
	Compiler      string `json:"Compiler"`
	Platform      string `json:"Platform"`
}

VersionInfo holds the version information of the driver

func GetVersion 

func GetVersion(driverName string) VersionInfo

GetVersion returns the version information of the driver

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.