storage

Documentation

Index

• func PatchVolumeStatus(ctx context.Context, c client.Client, volume *storagev1alpha1.Volume, ...) error
• type AccessApplier
  • func (r *AccessApplier) ApplyAccess(ctx context.Context, log logr.Logger, ...) (*storagev1alpha1.VolumeAccess, error)
• type ProxyVolumeApplier
  • func (r *ProxyVolumeApplier) ApplyTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, bool, error)
  • func (r *ProxyVolumeApplier) DeleteTarget(ctx context.Context, volume *storagev1alpha1.Volume) (done bool, err error)
  • func (r *ProxyVolumeApplier) GetTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, error)
• type SyncVolumeApplier
  • func (r *SyncVolumeApplier) ApplyTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, bool, error)
  • func (r *SyncVolumeApplier) DeleteTarget(ctx context.Context, volume *storagev1alpha1.Volume) (done bool, err error)
  • func (r *SyncVolumeApplier) GetTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, error)
• type VolumeApplier
• type VolumePoolReconciler
  • func (r *VolumePoolReconciler) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)
  • func (r *VolumePoolReconciler) SetupWithManager(mgr broker.Manager) error

Functions

func PatchVolumeStatus

func PatchVolumeStatus(ctx context.Context, c client.Client, volume *storagev1alpha1.Volume, state storagev1alpha1.VolumeState, access *storagev1alpha1.VolumeAccess) error

Types

type AccessApplier

type AccessApplier struct {
	Domain domain.Domain

	APIReader    client.Reader
	Client       client.Client
	TargetClient client.Client
}

func (*AccessApplier) ApplyAccess

func (r *AccessApplier) ApplyAccess(ctx context.Context, log logr.Logger, volume, targetVolume *storagev1alpha1.Volume) (*storagev1alpha1.VolumeAccess, error)

type ProxyVolumeApplier

type ProxyVolumeApplier struct {
	TargetClient client.Client
	ClusterName  string
	Scheme       *runtime.Scheme
}

func (*ProxyVolumeApplier) ApplyTarget

func (r *ProxyVolumeApplier) ApplyTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, bool, error)

func (*ProxyVolumeApplier) DeleteTarget

func (r *ProxyVolumeApplier) DeleteTarget(ctx context.Context, volume *storagev1alpha1.Volume) (done bool, err error)

func (*ProxyVolumeApplier) GetTarget

func (r *ProxyVolumeApplier) GetTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, error)

type SyncVolumeApplier

type SyncVolumeApplier struct {
	Provider         provider.Provider
	TargetPoolName   string
	TargetPoolLabels map[string]string
	ClusterName      string

	Unclaimable bool

	TargetClient client.Client
}

func (*SyncVolumeApplier) ApplyTarget

func (r *SyncVolumeApplier) ApplyTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, bool, error)

func (*SyncVolumeApplier) DeleteTarget

func (r *SyncVolumeApplier) DeleteTarget(ctx context.Context, volume *storagev1alpha1.Volume) (done bool, err error)

func (*SyncVolumeApplier) GetTarget

func (r *SyncVolumeApplier) GetTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, error)

type VolumeApplier

type VolumeApplier interface {
	ApplyTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, bool, error)
	GetTarget(ctx context.Context, volume *storagev1alpha1.Volume) (*storagev1alpha1.Volume, error)
	DeleteTarget(ctx context.Context, volume *storagev1alpha1.Volume) (done bool, err error)
}

type VolumePoolReconciler

type VolumePoolReconciler struct {
	client.Client

	Target client.Client

	PoolName            string
	ProviderID          string
	InitPoolLabels      map[string]string
	InitPoolAnnotations map[string]string

	TargetPoolLabels map[string]string
	TargetPoolName   string

	ClusterName string
	Domain      domain.Domain
}

func (*VolumePoolReconciler) Reconcile

func (r *VolumePoolReconciler) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)

func (*VolumePoolReconciler) SetupWithManager

func (r *VolumePoolReconciler) SetupWithManager(mgr broker.Manager) error