controllers

Documentation

Index

• func VolumeRunsInVolumePool(volume *storagev1alpha1.Volume, volumePoolName string) bool
• func VolumeRunsInVolumePoolPredicate(volumePoolName string) predicate.Predicate
• type VolumeAnnotatorReconciler
  • func (r *VolumeAnnotatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VolumeAnnotatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VolumePoolAnnotatorReconciler
  • func (r *VolumePoolAnnotatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VolumePoolAnnotatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VolumePoolInit
  • func (i *VolumePoolInit) SetupWithManager(mgr ctrl.Manager) error
  • func (i *VolumePoolInit) Start(ctx context.Context) error
• type VolumePoolReconciler
  • func (r *VolumePoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VolumePoolReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VolumeReconciler
  • func (r *VolumeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VolumeReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func VolumeRunsInVolumePool

func VolumeRunsInVolumePool(volume *storagev1alpha1.Volume, volumePoolName string) bool

func VolumeRunsInVolumePoolPredicate

func VolumeRunsInVolumePoolPredicate(volumePoolName string) predicate.Predicate

Types

type VolumeAnnotatorReconciler

type VolumeAnnotatorReconciler struct {
	client.Client

	VolumeEvents irievent.Source[*iri.Volume]
}

func (*VolumeAnnotatorReconciler) Reconcile

func (r *VolumeAnnotatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*VolumeAnnotatorReconciler) SetupWithManager

func (r *VolumeAnnotatorReconciler) SetupWithManager(mgr ctrl.Manager) error

type VolumePoolAnnotatorReconciler

type VolumePoolAnnotatorReconciler struct {
	client.Client

	VolumePoolName    string
	VolumeClassMapper vcm.VolumeClassMapper
}

func (*VolumePoolAnnotatorReconciler) Reconcile

func (r *VolumePoolAnnotatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*VolumePoolAnnotatorReconciler) SetupWithManager

func (r *VolumePoolAnnotatorReconciler) SetupWithManager(mgr ctrl.Manager) error

type VolumePoolInit

type VolumePoolInit struct {
	client.Client

	VolumePoolName string
	ProviderID     string

	OnInitialized func(ctx context.Context) error
	OnFailed      func(ctx context.Context, reason error) error
}

func (*VolumePoolInit) SetupWithManager

func (i *VolumePoolInit) SetupWithManager(mgr ctrl.Manager) error

func (*VolumePoolInit) Start

func (i *VolumePoolInit) Start(ctx context.Context) error

type VolumePoolReconciler

type VolumePoolReconciler struct {
	client.Client
	VolumePoolName    string
	VolumeRuntime     volume.RuntimeService
	VolumeClassMapper vcm.VolumeClassMapper
}

func (*VolumePoolReconciler) Reconcile

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

func (*VolumePoolReconciler) SetupWithManager

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

type VolumeReconciler

type VolumeReconciler struct {
	record.EventRecorder
	client.Client
	Scheme *runtime.Scheme

	VolumeRuntime iriVolume.RuntimeService

	VolumeClassMapper vcm.VolumeClassMapper

	VolumePoolName   string
	WatchFilterValue string

	MaxConcurrentReconciles int
}

func (*VolumeReconciler) Reconcile

func (r *VolumeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*VolumeReconciler) SetupWithManager

func (r *VolumeReconciler) SetupWithManager(mgr ctrl.Manager) error