bucket

Documentation

Index

• func Add(mgr manager.Manager) error
• type AzureAccountHandler
  • func (h *AzureAccountHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)
  • func (h *AzureAccountHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, ...) (corev1alpha1.Resource, error)
  • func (h *AzureAccountHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error
• type AzureContainerHandler
  • func (h *AzureContainerHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)
  • func (h *AzureContainerHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, ...) (corev1alpha1.Resource, error)
  • func (h *AzureContainerHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error
• type GCSBucketHandler
  • func (h *GCSBucketHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)
  • func (h *GCSBucketHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, ...) (corev1alpha1.Resource, error)
  • func (h *GCSBucketHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error
• type Reconciler
  • func (r *Reconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type S3BucketHandler
  • func (h *S3BucketHandler) Find(name types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)
  • func (h *S3BucketHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, ...) (corev1alpha1.Resource, error)
  • func (h S3BucketHandler) SetBindStatus(name types.NamespacedName, c client.Client, bound bool) error

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new Bucket Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type AzureAccountHandler

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

AzureAccountHandler dynamically provisions Azure storage account instances given a resource class.

func (*AzureAccountHandler) Find

func (h *AzureAccountHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)

Find an account instance.

func (*AzureAccountHandler) Provision

func (h *AzureAccountHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, c client.Client) (corev1alpha1.Resource, error)

Provision a new GCS Bucket resource.

func (*AzureAccountHandler) SetBindStatus

func (h *AzureAccountHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error

SetBindStatus marks the supplied GCS Bucket as bound or unbound in the Kubernetes API.

type AzureContainerHandler

type AzureContainerHandler struct{}

AzureContainerHandler dynamically provisions Azure storage container instances given a resource class.

func (*AzureContainerHandler) Find

func (h *AzureContainerHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)

Find an account instance.

func (*AzureContainerHandler) Provision

func (h *AzureContainerHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, c client.Client) (corev1alpha1.Resource, error)

Provision a new GCS Bucket resource.

func (*AzureContainerHandler) SetBindStatus

func (h *AzureContainerHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error

SetBindStatus marks the supplied GCS Bucket as bound or unbound in the Kubernetes API.

type GCSBucketHandler

type GCSBucketHandler struct{}

GCSBucketHandler dynamically provisions GCS Bucket instances given a resource class.

func (*GCSBucketHandler) Find

func (h *GCSBucketHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)

Find a Bucket instance.

func (*GCSBucketHandler) Provision

func (h *GCSBucketHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, c client.Client) (corev1alpha1.Resource, error)

Provision a new GCS Bucket resource.

func (*GCSBucketHandler) SetBindStatus

func (h *GCSBucketHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error

SetBindStatus marks the supplied GCS Bucket as bound or unbound in the Kubernetes API.

type Reconciler

type Reconciler struct {
	*corecontroller.Reconciler
}

Reconciler is the reconciler for Bucket objects

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Instance object and makes changes based on the state read and what is in the Instance.Spec

type S3BucketHandler

type S3BucketHandler struct{}

S3BucketHandler handles S3 Instance functionality

func (*S3BucketHandler) Find

func (h *S3BucketHandler) Find(name types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)

Find an S3 bucket.

func (*S3BucketHandler) Provision

func (h *S3BucketHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, c client.Client) (corev1alpha1.Resource, error)

Provision a new S3Bucket

func (S3BucketHandler) SetBindStatus

func (h S3BucketHandler) SetBindStatus(name types.NamespacedName, c client.Client, bound bool) error

SetBindStatus updates resource state binding phase TODO: this SetBindStatus function could be refactored to 1 common implementation for all providers