Documentation
¶
Index ¶
- func GetAllClient(config *rest.Config, scheme *runtime.Scheme) (client.Client, error)
- func GetScopedClient(cfg *rest.Config, scheme *runtime.Scheme, clusterPath string) (client.Client, error)
- type APIBindingReconciler
- type IndexableResourceReconciler
- type LogicalClusterReconciler
- type SearchIndexReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAllClient ¶
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, osClient *opensearch.Client, apiExportName string) (*APIBindingReconciler, error)
NewAPIBindingReconciler creates a new APIBinding reconciler If osClient is nil, only the APIBindingWatcher subroutine is used (no indexing)
func (*APIBindingReconciler) Reconcile ¶
func (r *APIBindingReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (ctrl.Result, error)
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 ¶
func (r *IndexableResourceReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (ctrl.Result, error)
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 LogicalClusterReconciler ¶
type LogicalClusterReconciler struct {
// contains filtered or unexported fields
}
func (*LogicalClusterReconciler) Reconcile ¶
func (r *LogicalClusterReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (ctrl.Result, error)
func (*LogicalClusterReconciler) SetupWithManager ¶
func (r *LogicalClusterReconciler) SetupWithManager(mgr mcmanager.Manager, cfg *platformeshconfig.CommonServiceConfig, evp ...predicate.Predicate) error
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) *SearchIndexReconciler
NewSearchIndexReconciler creates a new SearchIndex reconciler
func (*SearchIndexReconciler) Reconcile ¶
func (r *SearchIndexReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (ctrl.Result, error)
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.
Source Files