controllers

Documentation

Index

• func ClearLastApplied(annotations map[string]string) map[string]string
• func ConfigMapDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func ConfigMapUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func CsrDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func CsrUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func DaemonSetDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func DaemonSetUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func DeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name, namespace string, ...) (bool, error)
• func DeleteResourceStatusCR(cr *k8spluginv1alpha1.ResourceBundleState, name, namespace string, ...) (bool, error)
• func DeploymentDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func DeploymentUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func GetCRForResource(cli client.Client, item *unstructured.Unstructured, namespace string) (*k8spluginv1alpha1.ResourceBundleState, error)
• func GetServerResources(client *discovery.DiscoveryClient) ([]*schema.GroupVersionKind, error)
• func JobDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func JobUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func PodDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func PodUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func ServiceDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func ServiceUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func SetupControllerForType(mgr ctrl.Manager, resourceGVK *schema.GroupVersionKind, mutex *sync.Mutex) error
• func SetupControllers(mgr ctrl.Manager, controllersMutex *sync.Mutex) error
• func SetupGitClient() error
• func StatefulSetDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)
• func StatefulSetUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)
• func UpdateResourceStatusCR(cr *k8spluginv1alpha1.ResourceBundleState, item *unstructured.Unstructured, ...) (bool, error)
• func UpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, item *unstructured.Unstructured, ...) (bool, error)
• type ControllerListReconciler
  • func (r *ControllerListReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ControllerListReconciler) SetupWithManager(mgr ctrl.Manager) error
• type CustomResourceDefinitionReconciler
  • func (r *CustomResourceDefinitionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CustomResourceDefinitionReconciler) SetupWithManager(mgr ctrl.Manager, controllersMutex *sync.Mutex) error
• type DeleteStatusClient
  • func (u *DeleteStatusClient) Delete() error
  • func (u *DeleteStatusClient) DeleteOne(rbState *k8spluginv1alpha1.ResourceBundleState) error
• type GitAccessClient
  • func NewGitClient() (GitAccessClient, error)
  • func (c *GitAccessClient) CommitCRToGit(cr *k8spluginv1alpha1.ResourceBundleState, l map[string]string) error
  • func (c *GitAccessClient) DeleteStatusFromGit(appName string) error
• type ResourceBundleStateReconciler
  • func (r *ResourceBundleStateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ResourceBundleStateReconciler) SetupWithManager(mgr ctrl.Manager) error
• type UpdateStatusClient
  • func (u *UpdateStatusClient) Update() error

Functions

func ClearLastApplied

func ClearLastApplied(annotations map[string]string) map[string]string

func ConfigMapDeleteObj

func ConfigMapDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func ConfigMapUpdateStatus

func ConfigMapUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func CsrDeleteObj

func CsrDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func CsrUpdateStatus

func CsrUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func DaemonSetDeleteObj

func DaemonSetDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func DaemonSetUpdateStatus

func DaemonSetUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func DeleteObj

func DeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name, namespace string, gvk schema.GroupVersionKind) (bool, error)

func DeleteResourceStatusCR

func DeleteResourceStatusCR(cr *k8spluginv1alpha1.ResourceBundleState, name, namespace string, gvk schema.GroupVersionKind) (bool, error)

func DeploymentDeleteObj

func DeploymentDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func DeploymentUpdateStatus

func DeploymentUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func GetCRForResource

func GetCRForResource(cli client.Client, item *unstructured.Unstructured, namespace string) (*k8spluginv1alpha1.ResourceBundleState, error)

func GetServerResources

func GetServerResources(client *discovery.DiscoveryClient) ([]*schema.GroupVersionKind, error)

GetServerResources returns a GVK list of all cluster defined resources

func JobDeleteObj

func JobDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func JobUpdateStatus

func JobUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func PodDeleteObj

func PodDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func PodUpdateStatus

func PodUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func ServiceDeleteObj

func ServiceDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func ServiceUpdateStatus

func ServiceUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func SetupControllerForType

func SetupControllerForType(mgr ctrl.Manager, resourceGVK *schema.GroupVersionKind, mutex *sync.Mutex) error

func SetupControllers

func SetupControllers(mgr ctrl.Manager, controllersMutex *sync.Mutex) error

func SetupGitClient

func SetupGitClient() error

func StatefulSetDeleteObj

func StatefulSetDeleteObj(cr *k8spluginv1alpha1.ResourceBundleState, name string) (bool, error)

func StatefulSetUpdateStatus

func StatefulSetUpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, obj *unstructured.Unstructured) (bool, error)

func UpdateResourceStatusCR

func UpdateResourceStatusCR(cr *k8spluginv1alpha1.ResourceBundleState, item *unstructured.Unstructured, name, namespace string) (bool, error)

func UpdateStatus

func UpdateStatus(cr *k8spluginv1alpha1.ResourceBundleState, item *unstructured.Unstructured, name, namespace string) (bool, error)

Types

type ControllerListReconciler

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

ResourceBundleStateReconciler reconciles a ResourceBundleState object

func (*ControllerListReconciler) Reconcile

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

func (*ControllerListReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type CustomResourceDefinitionReconciler

type CustomResourceDefinitionReconciler struct {
	client.Client
	Scheme       *runtime.Scheme
	ResourcesMap map[schema.GroupVersionKind]bool
	// contains filtered or unexported fields
}

CustomResourceDefinitionReconciler reconciles a CustomResourceDefinition object

func (*CustomResourceDefinitionReconciler) Reconcile

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

func (*CustomResourceDefinitionReconciler) SetupWithManager

func (r *CustomResourceDefinitionReconciler) SetupWithManager(mgr ctrl.Manager, controllersMutex *sync.Mutex) error

SetupWithManager sets up the controller with the Manager.

type DeleteStatusClient

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

func (*DeleteStatusClient) Delete

func (u *DeleteStatusClient) Delete() error

func (*DeleteStatusClient) DeleteOne

func (u *DeleteStatusClient) DeleteOne(rbState *k8spluginv1alpha1.ResourceBundleState) error

type GitAccessClient

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

var GitClient GitAccessClient

func NewGitClient

func NewGitClient() (GitAccessClient, error)

func (*GitAccessClient) CommitCRToGit

func (c *GitAccessClient) CommitCRToGit(cr *k8spluginv1alpha1.ResourceBundleState, l map[string]string) error

func (*GitAccessClient) DeleteStatusFromGit

func (c *GitAccessClient) DeleteStatusFromGit(appName string) error

function to delete status folder for git

type ResourceBundleStateReconciler

type ResourceBundleStateReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ResourceBundleStateReconciler reconciles a ResourceBundleState object

func (*ResourceBundleStateReconciler) Reconcile

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

func (*ResourceBundleStateReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type UpdateStatusClient

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

func (*UpdateStatusClient) Update

func (u *UpdateStatusClient) Update() error