controller

package
v0.0.0-...-25714eb Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 18, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AccessKeyReady string = "AccessKeyReady"
	KeySecretReady string = "KeySecretReady"
)
View Source
const (
	PolicyAssignmentReady string = "PolicyReady"

	PolicyBucketReady    string = "PolicyBucketReady"
	PolicyAccessKeyReady string = "PolicyAccessKeyReady"
)

PolicyAssignment conditions

View Source
const (
	ReasonAccessKeyMissing string = "AccessKeyMissing"
	ReasonBucketMissing    string = "BucketMissing"

	// Will not recover without spec change
	ReasonDependencyFailed string = "DependencyFailed"
	// Not ready, waiting
	ReasonDependenciesNotReady string = "DependenciesNotReady"
	// Transient errors
	ReasonDegraded string = "DependencyDegraded"
)
View Source
const (
	BucketReady string = "BucketReady"
)
View Source
const Ready string = "Ready"

Ready is the top-level ready condition for a resource.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessKey

type AccessKey struct {
	Object *garagev1alpha1.AccessKey
}

func (*AccessKey) AccessKeyCondition

func (k *AccessKey) AccessKeyCondition() metav1.Condition

func (*AccessKey) InitializeConditions

func (k *AccessKey) InitializeConditions()

func (*AccessKey) MarkNotReady

func (k *AccessKey) MarkNotReady(condType string,
	reason,
	message string,
	args ...any)

func (*AccessKey) MarkSecretReady

func (k *AccessKey) MarkSecretReady()

type AccessKeyManager

type AccessKeyManager interface {
	Create(ctx context.Context, keyName string) (s3.AccessKey, error)
	Get(ctx context.Context, id string) (s3.AccessKey, error)
	Lookup(ctx context.Context, search string) (s3.AccessKey, error)
	Delete(ctx context.Context, id string) error
}

type AccessKeyReconciler

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

AccessKeyReconciler reconciles an AccessKey object

func NewAccessKeyReconciler

func NewAccessKeyReconciler(c client.Client, s *runtime.Scheme, keyMgr AccessKeyManager) *AccessKeyReconciler

func (*AccessKeyReconciler) Reconcile

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

func (*AccessKeyReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type AccessPolicy

type AccessPolicy struct {
	Object *garagev1alpha1.AccessPolicy
}

type AccessPolicyReconciler

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

AccessPolicyReconciler reconciles a AccessPolicy object

func NewAccessPolicyReconciler

func NewAccessPolicyReconciler(c client.Client,
	scheme *runtime.Scheme,
	ac PermissionClient,
) *AccessPolicyReconciler

func (*AccessPolicyReconciler) Reconcile

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

func (*AccessPolicyReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type BucketClient

type BucketClient interface {
	Create(ctx context.Context, globalAlias string) (s3.Bucket, error)
	Get(ctx context.Context, globalAlias string) (s3.Bucket, error)
	Update(ctx context.Context, id string, quotas s3.Quotas) error
}

type BucketReconciler

type BucketReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

BucketReconciler reconciles a Bucket object

func NewBucketReconciler

func NewBucketReconciler(apiClient client.Client, scheme *runtime.Scheme, s3Client BucketClient) *BucketReconciler

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

SetupWithManager sets up the controller with the Manager.

type PermissionClient

type PermissionClient interface {
	// SetPermissions ensures that an access key has the target r/w/owner permissions on a bucket.
	SetPermissions(ctx context.Context, keyID, bucketID string, permissions s3.Permissions) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL