driver

package

Go to main page

Versions in this module

v1

v1.1.0

Jan 21, 2020

Changes in this version

+ const AttachMaxRetries

+ const AttachRetryInterval

+ const DetachMaxRetries

+ const DetachRetryInterval

+ const DriverName

v1.0.0

Oct 17, 2019

Changes in this version

+ const VolumeMaxRetries

+ const VolumeRetryInterval

+ type Attacher interface

+ Discover func(ip, initiator string) error

+ GetDevice func(portal, target string) (string, error)

+ GetScsiID func(devicePath string) (string, error)

+ HasSession func(ip, targe string) (bool, error)

+ Login func(ip, target string) error

+ Logout func(ip, target string) error

+ MultipathReadBindings func() (map[string]string, map[string]string, error)

+ MultipathWriteBindings func(map[string]string) error

+ type AttacherImpl struct

+ func (i *AttacherImpl) Discover(ip, initiator string) error

+ func (i *AttacherImpl) GetDevice(portal, target string) (string, error)

+ func (i *AttacherImpl) GetScsiID(devicePath string) (string, error)

+ func (i *AttacherImpl) HasSession(ip, target string) (bool, error)

+ func (i *AttacherImpl) Login(ip, target string) error

+ func (i *AttacherImpl) Logout(ip, target string) error

+ func (i *AttacherImpl) MultipathReadBindings() (map[string]string, map[string]string, error)

+ func (i *AttacherImpl) MultipathWriteBindings(bindings map[string]string) error

+ type BlockInfo struct

+ FsType string

+ Label string

+ Mountpoint string

+ Name string

+ UUID string

+ type Deviceset struct

+ BlockDevices []BlockInfo

+ type Initializer interface

+ NodeInit func(string) error

+ type InitializerImpl struct

+ func (n *InitializerImpl) ConfigureMultipath() error

+ func (n *InitializerImpl) NodeInit(initiatorName string) error

+ func (n *InitializerImpl) RestartServices() error

+ func (n *InitializerImpl) SetIscsiInitiator(initiatorName string) error

+ type Mounter interface

+ Bindmount func(string, string) error

+ FormatMappedDevice func(string) error

+ GetMappedDevice func(string) (BlockInfo, error)

+ MountMappedDevice func(string, string) error

+ Unmount func(string) error

+ type MounterImpl struct

+ func (m *MounterImpl) Bindmount(src, target string) error

+ func (m *MounterImpl) FormatMappedDevice(device string) error

+ func (m *MounterImpl) GetMappedDevice(device string) (BlockInfo, error)

+ func (m *MounterImpl) MountMappedDevice(device, target string) error

+ func (m *MounterImpl) Unmount(path string) error

type PacketControllerServer

+ func (controller *PacketControllerServer) ControllerExpandVolume(context.Context, *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

type PacketDriver

+ Attacher Attacher

+ Initializer Initializer

+ Mounter Mounter

+ func (d *PacketDriver) Stop()

type PacketNodeServer

+ Initialized bool

+ MetadataDriver *packet.MetadataDriver

+ func (nodeServer *PacketNodeServer) NodeExpandVolume(context.Context, *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

+ func (nodeServer *PacketNodeServer) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

v0

v0.0.1

Oct 16, 2018

Changes in this version

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

+ type NonBlockingGRPCServer interface

+ ForceStop func()

+ Start func(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...)

+ Stop func()

+ Wait func()

+ func NewNonBlockingGRPCServer() NonBlockingGRPCServer

+ type PacketControllerServer struct

+ Provider packet.VolumeProvider

+ func NewPacketControllerServer(provider packet.VolumeProvider) *PacketControllerServer

+ func (controller *PacketControllerServer) ControllerGetCapabilities(ctx context.Context, in *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (controller *PacketControllerServer) ControllerPublishVolume(ctx context.Context, in *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (controller *PacketControllerServer) ControllerUnpublishVolume(ctx context.Context, in *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (controller *PacketControllerServer) CreateSnapshot(context.Context, *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (controller *PacketControllerServer) CreateVolume(ctx context.Context, in *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (controller *PacketControllerServer) DeleteSnapshot(context.Context, *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (controller *PacketControllerServer) DeleteVolume(ctx context.Context, in *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (controller *PacketControllerServer) GetCapacity(ctx context.Context, in *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

+ func (controller *PacketControllerServer) ListSnapshots(context.Context, *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (controller *PacketControllerServer) ListVolumes(ctx context.Context, in *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (controller *PacketControllerServer) ValidateVolumeCapabilities(ctx context.Context, in *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

+ type PacketDriver struct

+ Logger *log.Entry

+ func NewPacketDriver(endpoint, nodeID, configurationPath string) (*PacketDriver, error)

+ func (d *PacketDriver) Run()

+ type PacketIdentityServer struct

+ Driver *PacketDriver

+ func NewPacketIdentityServer(driver *PacketDriver) *PacketIdentityServer

+ func (packetIdentity *PacketIdentityServer) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

+ func (packetIdentity *PacketIdentityServer) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

+ func (packetIdentity *PacketIdentityServer) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

+ type PacketNodeServer struct

+ Driver *PacketDriver

+ func NewPacketNodeServer(driver *PacketDriver) *PacketNodeServer

+ func (nodeServer *PacketNodeServer) NodeGetCapabilities(ctx context.Context, in *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

+ func (nodeServer *PacketNodeServer) NodeGetId(ctx context.Context, in *csi.NodeGetIdRequest) (*csi.NodeGetIdResponse, error)

+ func (nodeServer *PacketNodeServer) NodeGetInfo(context.Context, *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

+ func (nodeServer *PacketNodeServer) NodePublishVolume(ctx context.Context, in *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

+ func (nodeServer *PacketNodeServer) NodeStageVolume(ctx context.Context, in *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

+ func (nodeServer *PacketNodeServer) NodeUnpublishVolume(ctx context.Context, in *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

+ func (nodeServer *PacketNodeServer) NodeUnstageVolume(ctx context.Context, in *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL