eventloop

package
v0.0.0-...-2fe1b59 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 7, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterReconciler

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

In normal circumstances, when an Argo CD `Application` is deleted, Argo CD will automatically delete all the child resource of that `Application`.

However, in some exceptional circumstances, some cluster resources may be missed. This is a significant problem in a closed system, where users do not necessarily have permissions to modify/delete all of the API resources within their Namespace.

To handle this case, every X hours, the GitOps Service scans the `*-tenant` namespaces of the clusters for any orphaned Argo-CD-deployed resources, and deletes those resources.

See 'docs/self-healing-mechanism.md' for more details.

func NewClusterReconciler

func NewClusterReconciler(client client.Client, discoveryClient discovery.DiscoveryInterface) *ClusterReconciler

func (*ClusterReconciler) Start

func (c *ClusterReconciler) Start()

type ControllerEventLoop

type ControllerEventLoop struct {
	EventLoopInputChannel chan eventlooptypes.EventLoopEvent
}

func NewControllerEventLoop

func NewControllerEventLoop() *ControllerEventLoop

type DatabaseReconciler

type DatabaseReconciler struct {
	client.Client
	DB               db.DatabaseQueries
	K8sClientFactory sharedresourceloop.SRLK8sClientFactory
}

DatabaseReconciler reconciles Database entries

func (*DatabaseReconciler) StartDatabaseReconciler

func (r *DatabaseReconciler) StartDatabaseReconciler()

This function iterates through each entry of DTAM and ACTDM tables in DB and ensures that the required CRs is present in cluster.

type MetricsReconciler

type MetricsReconciler struct {
	client.Client
	DB db.DatabaseQueries
}

MetricsReconciler reconciles metrics of Database entries

func (*MetricsReconciler) StartDBMetricsReconcilerForMetrics

func (r *MetricsReconciler) StartDBMetricsReconcilerForMetrics()

type RepoCredReconciler

type RepoCredReconciler struct {
	client.Client
	DB db.DatabaseQueries
}

RepoCredReconciler reconciles RepositoryCredential entries

func (*RepoCredReconciler) StartRepoCredReconciler

func (r *RepoCredReconciler) StartRepoCredReconciler()

This function iterates through each entry of RepositoryCredential table in DB and updates the status of the CR.

type WorkspaceEventLoopRouterStruct

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

func (*WorkspaceEventLoopRouterStruct) SendMessage

Jump to

Keyboard shortcuts

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