azure

Documentation

Index

• func NewAzureDiskModifier() delegation.VolumeModifier
• type AzureDiskModifier
  • func (m *AzureDiskModifier) MinWaitDuration() time.Duration
  • func (m *AzureDiskModifier) ModifyVolume(ctx context.Context, pvc *corev1.PersistentVolumeClaim, ...) (bool, error)
  • func (m *AzureDiskModifier) Name() string
  • func (m *AzureDiskModifier) Validate(spvc, dpvc *corev1.PersistentVolumeClaim, ssc, dsc *storagev1.StorageClass) error
• type DiskClient
• type Volume

Functions

func NewAzureDiskModifier

func NewAzureDiskModifier() delegation.VolumeModifier

Types

type AzureDiskModifier

type AzureDiskModifier struct {
	// for unit test, add switch for fake client
	// because we need to get subscription id from volume ID, so we cannot initialize it in constructor
	DiskClient DiskClient
}

func (*AzureDiskModifier) MinWaitDuration

func (m *AzureDiskModifier) MinWaitDuration() time.Duration

func (*AzureDiskModifier) ModifyVolume

func (m *AzureDiskModifier) ModifyVolume(ctx context.Context, pvc *corev1.PersistentVolumeClaim, pv *corev1.PersistentVolume, sc *storagev1.StorageClass) (bool, error)

func (*AzureDiskModifier) Name

func (m *AzureDiskModifier) Name() string

func (*AzureDiskModifier) Validate

func (m *AzureDiskModifier) Validate(spvc, dpvc *corev1.PersistentVolumeClaim, ssc, dsc *storagev1.StorageClass) error

type DiskClient

type DiskClient interface {
	Get(ctx context.Context, resourceGroupName string, diskName string, options *armcompute.DisksClientGetOptions) (armcompute.DisksClientGetResponse, error)
	BeginUpdate(ctx context.Context, resourceGroupName string, diskName string, parameters armcompute.DiskUpdate, options *armcompute.DisksClientBeginUpdateOptions) (*azruntime.Poller[armcompute.DisksClientUpdateResponse], error)
}

type Volume

type Volume struct {
	VolumeId   string
	Size       *int32
	IOPS       *int64
	Throughput *int64
	Type       string
}