deployment

Documentation

Index

• func Add(mgr manager.Manager, opts pmemcontroller.ControllerOptions) error
• func DeleteCRD(config *rest.Config) error
• func EnsureCRDInstalled(config *rest.Config) error
• func GetDeploymentCRD() *apiextensions.CustomResourceDefinition
• func NewReconcileDeployment(client client.Client, opts pmemcontroller.ControllerOptions) (reconcile.Reconciler, error)
• type PmemCSIDriver
  • func (d *PmemCSIDriver) Reconcile(r *ReconcileDeployment) (bool, error)
• type ReconcileDeployment
  • func (r *ReconcileDeployment) Create(obj runtime.Object) error
  • func (r *ReconcileDeployment) Delete(obj runtime.Object) error
  • func (r *ReconcileDeployment) Get(obj runtime.Object) error
  • func (r *ReconcileDeployment) Namespace() string
  • func (r *ReconcileDeployment) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *ReconcileDeployment) Update(obj runtime.Object) error
  • func (r *ReconcileDeployment) UpdateOrCreate(obj runtime.Object) error

Functions

func Add

func Add(mgr manager.Manager, opts pmemcontroller.ControllerOptions) error

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

func DeleteCRD

func DeleteCRD(config *rest.Config) error

DeleteCRD deletes the PMEM-CSI Deployment CRD. Supposed to be called while existing the operator

func EnsureCRDInstalled

func EnsureCRDInstalled(config *rest.Config) error

func GetDeploymentCRD

func GetDeploymentCRD() *apiextensions.CustomResourceDefinition

func NewReconcileDeployment

func NewReconcileDeployment(client client.Client, opts pmemcontroller.ControllerOptions) (reconcile.Reconciler, error)

NewReconcileDeployment creates new deployment reconciler

Types

type PmemCSIDriver

type PmemCSIDriver struct {
	*api.Deployment
	// contains filtered or unexported fields
}

func (*PmemCSIDriver) Reconcile

func (d *PmemCSIDriver) Reconcile(r *ReconcileDeployment) (bool, error)

Reconcile reconciles the driver deployment

type ReconcileDeployment

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

ReconcileDeployment reconciles a Deployment object

func (*ReconcileDeployment) Create

func (r *ReconcileDeployment) Create(obj runtime.Object) error

Create create new Kubernetes object

func (*ReconcileDeployment) Delete

func (r *ReconcileDeployment) Delete(obj runtime.Object) error

Delete delete existing Kubernetes object

func (*ReconcileDeployment) Get

func (r *ReconcileDeployment) Get(obj runtime.Object) error

Get tries to retrives the Kubernetes objects

func (*ReconcileDeployment) Namespace

func (r *ReconcileDeployment) Namespace() string

func (*ReconcileDeployment) Reconcile

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

Reconcile reads that state of the cluster for a Deployment object and makes changes based on the state read and what is in the Deployment.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

func (*ReconcileDeployment) Update

func (r *ReconcileDeployment) Update(obj runtime.Object) error

Update updates existing Kubernetes object. The object must be a modified copy of the existing object in the apiserver.

func (*ReconcileDeployment) UpdateOrCreate

func (r *ReconcileDeployment) UpdateOrCreate(obj runtime.Object) error

UpdateOrCreate updates the spec of an existing object or, if it does not exist yet, creates it.