controllers

package

v0.0.0-...-bb2f907 Latest Latest Go to latest Published: Jul 24, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitlab.com/project-emco/core/emco-base/src/monitor

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

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