controllers

Documentation

Index

• func BucketRunsInBucketPool(bucket *storagev1alpha1.Bucket, bucketPoolName string) bool
• func BucketRunsInBucketPoolPredicate(bucketPoolName string) predicate.Predicate
• type BucketAnnotatorReconciler
  • func (r *BucketAnnotatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BucketAnnotatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BucketPoolInit
  • func (i *BucketPoolInit) SetupWithManager(mgr ctrl.Manager) error
  • func (i *BucketPoolInit) Start(ctx context.Context) error
• type BucketPoolReconciler
  • func (r *BucketPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BucketPoolReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BucketReconciler
  • func (r *BucketReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BucketReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func BucketRunsInBucketPool

func BucketRunsInBucketPool(bucket *storagev1alpha1.Bucket, bucketPoolName string) bool

func BucketRunsInBucketPoolPredicate

func BucketRunsInBucketPoolPredicate(bucketPoolName string) predicate.Predicate

Types

type BucketAnnotatorReconciler

type BucketAnnotatorReconciler struct {
	client.Client

	BucketEvents orievent.Source[*ori.Bucket]
}

func (*BucketAnnotatorReconciler) Reconcile

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

func (*BucketAnnotatorReconciler) SetupWithManager

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

type BucketPoolInit

type BucketPoolInit struct {
	client.Client

	BucketPoolName string
	ProviderID     string

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

func (*BucketPoolInit) SetupWithManager

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

func (*BucketPoolInit) Start

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

type BucketPoolReconciler

type BucketPoolReconciler struct {
	client.Client
	BucketPoolName    string
	BucketRuntime     ori.BucketRuntimeClient
	BucketClassMapper bcm.BucketClassMapper
}

func (*BucketPoolReconciler) Reconcile

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

func (*BucketPoolReconciler) SetupWithManager

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

type BucketReconciler

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

	BucketRuntime ori.BucketRuntimeClient

	BucketClassMapper bcm.BucketClassMapper

	BucketPoolName   string
	WatchFilterValue string
}

func (*BucketReconciler) Reconcile

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

func (*BucketReconciler) SetupWithManager

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