controller

Documentation

Index

• Constants
• type Option
  • func WithDatacenter(v string) Option
  • func WithServer(v string) Option
  • func WithVolume(v *volume.Service) Option
• type Options
• type Service
  • func NewService(opts ...Option) *Service
  • func (s *Service) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)
  • func (s *Service) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)
  • func (s *Service) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, 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) 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)

Constants

const (
	// MinVolumeSize defines the minimum volume size.
	MinVolumeSize int64 = 1073741824

	// MaxVolumeSize defines the maximum volume size.
	MaxVolumeSize int64 = 10995116277760

	// DefaultVolumeSize defines the default volume size.
	DefaultVolumeSize int64 = 5368709120

	// TopologyKey defines the topology key for kubernetes.
	TopologyKey = "failure-domain.beta.kubernetes.io/zone"
)

Types

type Option

type Option func(o *Options)

Option defines a single option function.

func WithDatacenter

func WithDatacenter(v string) Option

WithDatacenter provides a function to set the datacenter option.

func WithServer

func WithServer(v string) Option

WithServer provides a function to set the server option.

func WithVolume

func WithVolume(v *volume.Service) Option

WithVolume provides a function to set the volume option.

type Options

type Options struct {
	Server     string
	Datacenter string
	Volume     *volume.Service
}

Options defines the available options for this package.

type Service

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

Service defines the service for the controller component.

func NewService

func NewService(opts ...Option) *Service

NewService simply initializes a new controller service.

func (*Service) ControllerExpandVolume

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

ControllerExpandVolume implements the CSI standard definition.

func (*Service) ControllerGetCapabilities

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

ControllerGetCapabilities implements the CSI standard definition.

func (*Service) ControllerGetVolume

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

ControllerGetVolume implements the CSI standard definition.

func (*Service) ControllerPublishVolume

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

ControllerPublishVolume implements the CSI standard definition.

func (*Service) ControllerUnpublishVolume

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

ControllerUnpublishVolume implements the CSI standard definition.

func (*Service) CreateSnapshot

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

CreateSnapshot implements the CSI standard definition.

func (*Service) CreateVolume

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

CreateVolume implements the CSI standard definition.

func (*Service) DeleteSnapshot

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

DeleteSnapshot implements the CSI standard definition.

func (*Service) DeleteVolume

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

DeleteVolume implements the CSI standard definition.

func (*Service) GetCapacity

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

GetCapacity implements the CSI standard definition.

func (*Service) ListSnapshots

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

ListSnapshots implements the CSI standard definition.

func (*Service) ListVolumes

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

ListVolumes implements the CSI standard definition.

func (*Service) ValidateVolumeCapabilities

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

ValidateVolumeCapabilities implements the CSI standard definition.