controller

package
v0.4.25 Latest Latest
Warning

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

Go to latest
Published: May 6, 2026 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetAllClient

func GetAllClient(config *rest.Config, scheme *runtime.Scheme) (client.Client, error)

GetAllClient creates a client that can query across all workspaces using the wildcard cluster

Types

type APIBindingReconciler

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

APIBindingReconciler watches APIBinding resources across all workspaces

func NewAPIBindingReconciler

func NewAPIBindingReconciler(log *logger.Logger, mcMgr mcmanager.Manager, indexPrefix string) (*APIBindingReconciler, error)

NewAPIBindingReconciler creates a new APIBinding reconciler.

func (*APIBindingReconciler) Reconcile

Reconcile handles APIBinding reconciliation

func (*APIBindingReconciler) SetupWithManager

func (r *APIBindingReconciler) SetupWithManager(mgr mcmanager.Manager, maxConcurrentReconciles int, evp ...predicate.Predicate) error

SetupWithManager sets up the controller with the multicluster Manager.

type IndexableResourceReconciler

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

func NewIndexableResource

func NewIndexableResource(log *logger.Logger, cfg config.Config, mcMgr mcmanager.Manager, osClient *opensearch.Client, apiExportName string, resources *unstructured.Unstructured) (*IndexableResourceReconciler, error)

NewIndexableResourceReconciler creates a new IndexableResource reconciler If osClient is nil, only the IndexableResourceWatcher subroutine is used (no indexing)

func (*IndexableResourceReconciler) Reconcile

Reconcile handles IndexableResource reconciliation

func (*IndexableResourceReconciler) SetupWithManager

func (r *IndexableResourceReconciler) SetupWithManager(mgr mcmanager.Manager, maxConcurrentReconciles int, obj *unstructured.Unstructured, evp ...predicate.Predicate) error

SetupWithManager sets up the controller with the multicluster Manager.

type SearchIndexReconciler

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

SearchIndexReconciler reconciles a SearchIndex object

func NewSearchIndexReconciler

func NewSearchIndexReconciler(
	log *logger.Logger,
	mcMgr mcmanager.Manager,
	osClient *opensearch.Client,
	staticIndexPrefix string,
	semanticModelID string,
) *SearchIndexReconciler

NewSearchIndexReconciler creates a new SearchIndex reconciler

func (*SearchIndexReconciler) Reconcile

Reconcile handles SearchIndex reconciliation

func (*SearchIndexReconciler) SetupWithManager

func (r *SearchIndexReconciler) SetupWithManager(mgr mcmanager.Manager, maxConcurrentReconciles int, evp ...predicate.Predicate) error

SetupWithManager sets up the controller with the multicluster Manager.

Jump to

Keyboard shortcuts

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