redis

Documentation

Index

• func AddCluster(mgr manager.Manager) error
• type CloudMemorystoreInstanceHandler
  • func (h *CloudMemorystoreInstanceHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)
  • func (h *CloudMemorystoreInstanceHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, ...) (corev1alpha1.Resource, error)
  • func (h *CloudMemorystoreInstanceHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error
• type Reconciler
  • func (r *Reconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type RedisHandler
  • func (h *RedisHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)
  • func (h *RedisHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, ...) (corev1alpha1.Resource, error)
  • func (h *RedisHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error
• type ReplicationGroupHandler
  • func (h *ReplicationGroupHandler) Find(n types.NamespacedName, c client.Client) (corev1alpha1.Resource, error)
  • func (h *ReplicationGroupHandler) Provision(class *corev1alpha1.ResourceClass, claim corev1alpha1.ResourceClaim, ...) (corev1alpha1.Resource, error)
  • func (h *ReplicationGroupHandler) SetBindStatus(n types.NamespacedName, c client.Client, bound bool) error

Functions

func AddCluster

func AddCluster(mgr manager.Manager) error

AddCluster creates a new RedisCluster Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type CloudMemorystoreInstanceHandler

type CloudMemorystoreInstanceHandler struct{}

CloudMemorystoreInstanceHandler dynamically provisions Cloud Memorystore instances given a resource class.

func (*CloudMemorystoreInstanceHandler) Find

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

Find a CloudMemorystoreInstance instance.

func (*CloudMemorystoreInstanceHandler) Provision

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

Provision a new CloudMemorystoreInstance resource.

func (*CloudMemorystoreInstanceHandler) SetBindStatus

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

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

type Reconciler

type Reconciler struct {
	*corecontroller.Reconciler
}

Reconciler is the reconciler for RedisCluster objects

func (*Reconciler) Reconcile

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

Reconcile the desired with the actual state of a RedisCluster.

type RedisHandler

type RedisHandler struct{} // nolint:golint

RedisHandler dynamically provisions Redis resources given a resource class.

func (*RedisHandler) Find

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

Find a Redis resource.

func (*RedisHandler) Provision

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

Provision a new Redis resource.

func (*RedisHandler) SetBindStatus

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

SetBindStatus marks the supplied Redis resource as bound or unbound in the Kubernetes API.

type ReplicationGroupHandler

type ReplicationGroupHandler struct{}

ReplicationGroupHandler dynamically provisions ReplicationGroup resources given a resource class.

func (*ReplicationGroupHandler) Find

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

Find a ReplicationGroup resource.

func (*ReplicationGroupHandler) Provision

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

Provision a new ReplicationGroup resource.

func (*ReplicationGroupHandler) SetBindStatus

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

SetBindStatus marks the supplied ReplicationGroup resource as bound or unbound in the Kubernetes API.