NewTaskActionReconciler

Creates a new TaskActionReconciler. The meterProvider is the executor's OTel meter provider, and the cache is the manager's cache; the active-by-phase gauge counts TaskActions straight from its indexer to avoid deep-copying every CRD.

def NewTaskActionReconciler(
    c: client.Client,
    scheme: *runtime.Scheme,
    registry: *plugin.Registry,
    dataStore: *storage.DataStore,
    eventsClient: workflowconnect.EventsProxyServiceClient,
    cluster: string,
    meterProvider: metric.MeterProvider,
    cache: ctrlcache.Cache
) - > *TaskActionReconciler

Creates a new TaskActionReconciler. The active-by-phase gauge counts TaskActions straight from its indexer to avoid deep-copying every CRD. TaskAction CRD operations are timed inline at the call sites via metrics.recordK8sOp.

Parameters

Name	Type	Description
c	client.Client	The Kubernetes client used to interact with the cluster.
scheme	*runtime.Scheme	The Kubernetes scheme used for API object serialization and deserialization.
registry	*plugin.Registry	The plugin registry for managing and accessing plugins.
dataStore	*storage.DataStore	The data store for persistent storage operations.
eventsClient	workflowconnect.EventsProxyServiceClient	The client for interacting with the workflow events proxy service.
cluster	string	The name of the cluster this reconciler operates within.
meterProvider	metric.MeterProvider	The OpenTelemetry meter provider for metrics collection. This is the executor's OTel meter provider (otelutils.GetMeterProvider(otelServiceName) in executor/setup.go).
cache	ctrlcache.Cache	The manager's cache, used by the active-by-phase gauge to count TaskActions directly from its indexer.

Returns

Type	Description
*TaskActionReconciler	A new TaskActionReconciler instance.