controller

package

Go to main page

Versions in this module

v1

v1.4.1

Jul 9, 2021

v1.4.0

Jun 18, 2021

Changes in this version

+ const KeyNasName

+ const KeyReplicationEnabled

+ const KeyReplicationRPO

+ const KeyReplicationRemoteSystem

+ func EnsureProtectionPolicyExists(ctx context.Context, arr *array.PowerStoreArray, vgName string, ...) (string, error)

+ func EnsureReplicationRuleExists(ctx context.Context, arr *array.PowerStoreArray, vgName string, ...) (string, error)

type FilesystemSnapshot

+ func (f FilesystemSnapshot) GetType() SnapshotType

type GeneralSnapshot

+ GetType func() SnapshotType

type Service

+ func (s *Service) ControllerGetVolume(ctx context.Context, request *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

+ func (s *Service) CreateRemoteVolume(ctx context.Context, req *csiext.CreateRemoteVolumeRequest) (*csiext.CreateRemoteVolumeResponse, error)

+ func (s *Service) CreateStorageProtectionGroup(ctx context.Context, req *csiext.CreateStorageProtectionGroupRequest) (*csiext.CreateStorageProtectionGroupResponse, error)

+ func (s *Service) DeleteStorageProtectionGroup(ctx context.Context, req *csiext.DeleteStorageProtectionGroupRequest) (*csiext.DeleteStorageProtectionGroupResponse, error)

+ func (s *Service) ExecuteAction(ctx context.Context, req *csiext.ExecuteActionRequest) (*csiext.ExecuteActionResponse, error)

+ func (s *Service) GetReplicationCapabilities(ctx context.Context, req *csiext.GetReplicationCapabilityRequest) (*csiext.GetReplicationCapabilityResponse, error)

+ func (s *Service) GetStorageProtectionGroupStatus(ctx context.Context, req *csiext.GetStorageProtectionGroupStatusRequest) (*csiext.GetStorageProtectionGroupStatusResponse, error)

+ func (s *Service) ProbeController(ctx context.Context, req *csiext.ProbeControllerRequest) (*csiext.ProbeControllerResponse, error)

+ func (s *Service) RegisterAdditionalServers(server *grpc.Server)

+ type SnapshotType string

+ const BlockSnapshotType

+ const FilesystemSnapshotType

type VolumeSnapshot

+ func (v VolumeSnapshot) GetType() SnapshotType

v1.3.0

Mar 19, 2021

Changes in this version

+ const CSIPersistentVolumeClaimName

+ const CSIPersistentVolumeClaimNamespace

+ const CSIPersistentVolumeName

+ const ErrNoMultiNodeWriter

+ const ErrUnknownAccessMode

+ const ErrUnknownAccessType

+ const HeaderPersistentVolumeClaimName

+ const HeaderPersistentVolumeClaimNamespace

+ const HeaderPersistentVolumeName

+ const KeyFsType

+ const KeyFsTypeOld

+ const MaxVolumeNameLength

+ const MaxVolumeSizeBytes

+ const MinVolumeSizeBytes

+ const ReservedSize

+ const VolumeSizeMultiple

+ type ControllerInterface interface

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

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

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

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

+ type FilesystemSnapshot gopowerstore.FileSystem

+ func (f FilesystemSnapshot) GetID() string

+ func (f FilesystemSnapshot) GetSize() int64

+ func (f FilesystemSnapshot) GetSourceID() string

+ type GeneralSnapshot interface

+ GetID func() string

+ GetSize func() int64

+ GetSourceID func() string

+ type NfsCreator struct

+ func (*NfsCreator) CheckIfAlreadyExists(ctx context.Context, name string, sizeInBytes int64, ...) (*csi.Volume, error)

+ func (*NfsCreator) CheckName(ctx context.Context, name string) error

+ func (*NfsCreator) CheckSize(ctx context.Context, cr *csi.CapacityRange) (int64, error)

+ func (*NfsCreator) Clone(ctx context.Context, volumeSource *csi.VolumeContentSource_VolumeSource, ...) (*csi.Volume, error)

+ func (*NfsCreator) CreateVolumeFromSnapshot(ctx context.Context, snapshotSource *csi.VolumeContentSource_SnapshotSource, ...) (*csi.Volume, error)

+ func (c *NfsCreator) Create(ctx context.Context, req *csi.CreateVolumeRequest, sizeInBytes int64, ...) (gopowerstore.CreateResponse, error)

+ type NfsPublisher struct

+ ExternalAccess string

+ func (n *NfsPublisher) CheckIfVolumeExists(ctx context.Context, client gopowerstore.Client, volID string) error

+ func (n *NfsPublisher) Publish(ctx context.Context, req *csi.ControllerPublishVolumeRequest, ...) (*csi.ControllerPublishVolumeResponse, error)

+ type NfsSnapshotter struct

+ func (*NfsSnapshotter) Create(ctx context.Context, snapName string, sourceID string, ...) (gopowerstore.CreateResponse, error)

+ func (*NfsSnapshotter) GetExistingSnapshot(ctx context.Context, snapName string, client gopowerstore.Client) (GeneralSnapshot, error)

+ type SCSICreator struct

+ func (*SCSICreator) CheckIfAlreadyExists(ctx context.Context, name string, sizeInBytes int64, ...) (*csi.Volume, error)

+ func (*SCSICreator) CheckName(ctx context.Context, name string) error

+ func (*SCSICreator) CheckSize(ctx context.Context, cr *csi.CapacityRange) (int64, error)

+ func (*SCSICreator) Clone(ctx context.Context, volumeSource *csi.VolumeContentSource_VolumeSource, ...) (*csi.Volume, error)

+ func (*SCSICreator) Create(ctx context.Context, req *csi.CreateVolumeRequest, sizeInBytes int64, ...) (gopowerstore.CreateResponse, error)

+ func (*SCSICreator) CreateVolumeFromSnapshot(ctx context.Context, snapshotSource *csi.VolumeContentSource_SnapshotSource, ...) (*csi.Volume, error)

+ type SCSIPublisher struct

+ func (s *SCSIPublisher) CheckIfVolumeExists(ctx context.Context, client gopowerstore.Client, volID string) error

+ func (s *SCSIPublisher) Publish(ctx context.Context, req *csi.ControllerPublishVolumeRequest, ...) (*csi.ControllerPublishVolumeResponse, error)

+ type SCSISnapshotter struct

+ func (*SCSISnapshotter) Create(ctx context.Context, snapName string, sourceID string, ...) (gopowerstore.CreateResponse, error)

+ func (*SCSISnapshotter) GetExistingSnapshot(ctx context.Context, snapName string, client gopowerstore.Client) (GeneralSnapshot, error)

+ type Service struct

+ Fs fs.FsInterface

+ func (s *Service) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

+ func (s *Service) ControllerGetCapabilities(ctx context.Context, request *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (s *Service) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (s *Service) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (s *Service) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (s *Service) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (s *Service) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (s *Service) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (s *Service) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

+ func (s *Service) Init() error

+ func (s *Service) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (s *Service) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (s *Service) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

+ type VolumeCreator interface

+ CheckIfAlreadyExists func(ctx context.Context, name string, sizeInBytes int64, ...) (*csi.Volume, error)

+ CheckName func(ctx context.Context, name string) error

+ CheckSize func(ctx context.Context, cr *csi.CapacityRange) (int64, error)

+ Clone func(ctx context.Context, volumeSource *csi.VolumeContentSource_VolumeSource, ...) (*csi.Volume, error)

+ Create func(ctx context.Context, req *csi.CreateVolumeRequest, sizeInBytes int64, ...) (gopowerstore.CreateResponse, error)

+ CreateVolumeFromSnapshot func(ctx context.Context, snapshotSource *csi.VolumeContentSource_SnapshotSource, ...) (*csi.Volume, error)

+ type VolumePublisher interface

+ CheckIfVolumeExists func(ctx context.Context, client gopowerstore.Client, volID string) error

+ Publish func(ctx context.Context, req *csi.ControllerPublishVolumeRequest, ...) (*csi.ControllerPublishVolumeResponse, error)

+ type VolumeSnapshot gopowerstore.Volume

+ func (v VolumeSnapshot) GetID() string

+ func (v VolumeSnapshot) GetSize() int64

+ func (v VolumeSnapshot) GetSourceID() string

+ type VolumeSnapshotter interface

+ Create func(context.Context, string, string, gopowerstore.Client) (gopowerstore.CreateResponse, error)

+ GetExistingSnapshot func(context.Context, string, gopowerstore.Client) (GeneralSnapshot, error)

Other modules containing this package

github.com/dell/csi-powerstore/v2

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