Documentation
¶
Index ¶
- func SetupThirdPartyCrdReconcilerWithManager(ctx context.Context, k8sClient client.Client, ...) error
- func StartProcessingThirdPartySynchronizationQueue(...)
- func StopProcessingThirdPartySynchronizationQueue(resourceReconcileQueue *workqueue.Typed[ThirdPartyResourceSyncJob], ...)
- type ApiClient
- type ApiConfig
- type ApiSyncReconciler
- type CheckRule
- type Dash0ApiObjectWithOrigin
- type HttpRequestWithItemName
- type MonitoringReconciler
- func (r *MonitoringReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *MonitoringReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *MonitoringReconciler) SetupWithManager(mgr ctrl.Manager) error
- type OperatorConfigurationReconciler
- func (r *OperatorConfigurationReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *OperatorConfigurationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *OperatorConfigurationReconciler) SetAuthTokenClients(authTokenClients []selfmonitoringapiaccess.AuthTokenClient)
- func (r *OperatorConfigurationReconciler) SetupWithManager(mgr ctrl.Manager) error
- type OwnedResourceReconciler
- type PersesDashboardCrdReconciler
- func (r *PersesDashboardCrdReconciler) ControllerName() string
- func (r *PersesDashboardCrdReconciler) Create(ctx context.Context, _ event.TypedCreateEvent[client.Object], ...)
- func (r *PersesDashboardCrdReconciler) CreateThirdPartyResourceReconciler(pseudoClusterUid types.UID)
- func (r *PersesDashboardCrdReconciler) Delete(ctx context.Context, _ event.TypedDeleteEvent[client.Object], ...)
- func (r *PersesDashboardCrdReconciler) DoesCrdExist() *atomic.Bool
- func (r *PersesDashboardCrdReconciler) Generic(context.Context, event.TypedGenericEvent[client.Object], ...)
- func (r *PersesDashboardCrdReconciler) Group() string
- func (r *PersesDashboardCrdReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *PersesDashboardCrdReconciler) Kind() string
- func (r *PersesDashboardCrdReconciler) KindDisplayName() string
- func (r *PersesDashboardCrdReconciler) Manager() ctrl.Manager
- func (r *PersesDashboardCrdReconciler) OperatorManagerIsLeader() bool
- func (r *PersesDashboardCrdReconciler) QualifiedKind() string
- func (r *PersesDashboardCrdReconciler) Reconcile(_ context.Context, _ reconcile.Request) (reconcile.Result, error)
- func (r *PersesDashboardCrdReconciler) RemoveApiEndpointAndDataset(ctx context.Context, logger *logr.Logger)
- func (r *PersesDashboardCrdReconciler) RemoveAuthToken(ctx context.Context, logger *logr.Logger)
- func (r *PersesDashboardCrdReconciler) SetApiEndpointAndDataset(ctx context.Context, apiConfig *ApiConfig, logger *logr.Logger)
- func (r *PersesDashboardCrdReconciler) SetAuthToken(ctx context.Context, authToken string, logger *logr.Logger)
- func (r *PersesDashboardCrdReconciler) SetCrdExists(exists bool)
- func (r *PersesDashboardCrdReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, startupK8sClient client.Client, ...) error
- func (r *PersesDashboardCrdReconciler) SkipNameValidation() bool
- func (r *PersesDashboardCrdReconciler) ThirdPartyResourceReconciler() ThirdPartyResourceReconciler
- func (r *PersesDashboardCrdReconciler) Update(context.Context, event.TypedUpdateEvent[client.Object], ...)
- func (r *PersesDashboardCrdReconciler) Version() string
- type PersesDashboardReconciler
- func (r *PersesDashboardReconciler) ControllerName() string
- func (r *PersesDashboardReconciler) ControllerStopFunctionLock() *sync.Mutex
- func (r *PersesDashboardReconciler) Create(ctx context.Context, e event.TypedCreateEvent[*unstructured.Unstructured], ...)
- func (r *PersesDashboardReconciler) CreateDeleteRequests(_ *preconditionValidationResult, _ []string, _ []string, _ *logr.Logger) ([]HttpRequestWithItemName, map[string]string)
- func (r *PersesDashboardReconciler) Delete(ctx context.Context, e event.TypedDeleteEvent[*unstructured.Unstructured], ...)
- func (r *PersesDashboardReconciler) FetchExistingResourceOriginsRequest(_ *preconditionValidationResult) (*http.Request, error)
- func (r *PersesDashboardReconciler) Generic(_ context.Context, _ event.TypedGenericEvent[*unstructured.Unstructured], ...)
- func (r *PersesDashboardReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
- func (r *PersesDashboardReconciler) GetAuthToken() string
- func (r *PersesDashboardReconciler) GetControllerStopFunction() *context.CancelFunc
- func (r *PersesDashboardReconciler) GetHttpRetryDelay() time.Duration
- func (r *PersesDashboardReconciler) HttpClient() *http.Client
- func (r *PersesDashboardReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *PersesDashboardReconciler) IsSynchronizationEnabled(monitoringResource *dash0v1beta1.Dash0Monitoring) bool
- func (r *PersesDashboardReconciler) IsWatching() bool
- func (r *PersesDashboardReconciler) K8sClient() client.Client
- func (r *PersesDashboardReconciler) KindDisplayName() string
- func (r *PersesDashboardReconciler) MapResourceToHttpRequests(preconditionChecksResult *preconditionValidationResult, action apiAction, ...) (int, []HttpRequestWithItemName, []string, map[string][]string, ...)
- func (r *PersesDashboardReconciler) Queue() *workqueue.Typed[ThirdPartyResourceSyncJob]
- func (r *PersesDashboardReconciler) Reconcile(context.Context, reconcile.Request) (reconcile.Result, error)
- func (r *PersesDashboardReconciler) SetControllerStopFunction(controllerStopFunction *context.CancelFunc)
- func (r *PersesDashboardReconciler) ShortName() string
- func (r *PersesDashboardReconciler) Update(ctx context.Context, e event.TypedUpdateEvent[*unstructured.Unstructured], ...)
- func (_ *PersesDashboardReconciler) UpdateSynchronizationResultsInDash0MonitoringStatus(monitoringResource *dash0v1beta1.Dash0Monitoring, qualifiedName string, ...) interface{}
- type PrometheusRuleCrdReconciler
- func (r *PrometheusRuleCrdReconciler) ControllerName() string
- func (r *PrometheusRuleCrdReconciler) Create(ctx context.Context, _ event.TypedCreateEvent[client.Object], ...)
- func (r *PrometheusRuleCrdReconciler) CreateThirdPartyResourceReconciler(pseudoClusterUid types.UID)
- func (r *PrometheusRuleCrdReconciler) Delete(ctx context.Context, _ event.TypedDeleteEvent[client.Object], ...)
- func (r *PrometheusRuleCrdReconciler) DoesCrdExist() *atomic.Bool
- func (r *PrometheusRuleCrdReconciler) Generic(context.Context, event.TypedGenericEvent[client.Object], ...)
- func (r *PrometheusRuleCrdReconciler) Group() string
- func (r *PrometheusRuleCrdReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *PrometheusRuleCrdReconciler) Kind() string
- func (r *PrometheusRuleCrdReconciler) KindDisplayName() string
- func (r *PrometheusRuleCrdReconciler) Manager() ctrl.Manager
- func (r *PrometheusRuleCrdReconciler) OperatorManagerIsLeader() bool
- func (r *PrometheusRuleCrdReconciler) QualifiedKind() string
- func (r *PrometheusRuleCrdReconciler) Reconcile(_ context.Context, _ reconcile.Request) (reconcile.Result, error)
- func (r *PrometheusRuleCrdReconciler) RemoveApiEndpointAndDataset(ctx context.Context, logger *logr.Logger)
- func (r *PrometheusRuleCrdReconciler) RemoveAuthToken(ctx context.Context, logger *logr.Logger)
- func (r *PrometheusRuleCrdReconciler) SetApiEndpointAndDataset(ctx context.Context, apiConfig *ApiConfig, logger *logr.Logger)
- func (r *PrometheusRuleCrdReconciler) SetAuthToken(ctx context.Context, authToken string, logger *logr.Logger)
- func (r *PrometheusRuleCrdReconciler) SetCrdExists(exists bool)
- func (r *PrometheusRuleCrdReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, startupK8sClient client.Client, ...) error
- func (r *PrometheusRuleCrdReconciler) SkipNameValidation() bool
- func (r *PrometheusRuleCrdReconciler) ThirdPartyResourceReconciler() ThirdPartyResourceReconciler
- func (r *PrometheusRuleCrdReconciler) Update(context.Context, event.TypedUpdateEvent[client.Object], ...)
- func (r *PrometheusRuleCrdReconciler) Version() string
- type PrometheusRuleReconciler
- func (r *PrometheusRuleReconciler) ControllerName() string
- func (r *PrometheusRuleReconciler) ControllerStopFunctionLock() *sync.Mutex
- func (r *PrometheusRuleReconciler) Create(ctx context.Context, e event.TypedCreateEvent[*unstructured.Unstructured], ...)
- func (r *PrometheusRuleReconciler) CreateDeleteRequests(preconditionChecksResult *preconditionValidationResult, ...) ([]HttpRequestWithItemName, map[string]string)
- func (r *PrometheusRuleReconciler) Delete(ctx context.Context, e event.TypedDeleteEvent[*unstructured.Unstructured], ...)
- func (r *PrometheusRuleReconciler) FetchExistingResourceOriginsRequest(preconditionChecksResult *preconditionValidationResult) (*http.Request, error)
- func (r *PrometheusRuleReconciler) Generic(_ context.Context, _ event.TypedGenericEvent[*unstructured.Unstructured], ...)
- func (r *PrometheusRuleReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
- func (r *PrometheusRuleReconciler) GetAuthToken() string
- func (r *PrometheusRuleReconciler) GetControllerStopFunction() *context.CancelFunc
- func (r *PrometheusRuleReconciler) GetHttpRetryDelay() time.Duration
- func (r *PrometheusRuleReconciler) HttpClient() *http.Client
- func (r *PrometheusRuleReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *PrometheusRuleReconciler) IsSynchronizationEnabled(monitoringResource *dash0v1beta1.Dash0Monitoring) bool
- func (r *PrometheusRuleReconciler) IsWatching() bool
- func (r *PrometheusRuleReconciler) K8sClient() client.Client
- func (r *PrometheusRuleReconciler) KindDisplayName() string
- func (r *PrometheusRuleReconciler) MapResourceToHttpRequests(preconditionChecksResult *preconditionValidationResult, action apiAction, ...) (int, []HttpRequestWithItemName, []string, map[string][]string, ...)
- func (r *PrometheusRuleReconciler) Queue() *workqueue.Typed[ThirdPartyResourceSyncJob]
- func (r *PrometheusRuleReconciler) Reconcile(context.Context, reconcile.Request) (reconcile.Result, error)
- func (r *PrometheusRuleReconciler) SetControllerStopFunction(controllerStopFunction *context.CancelFunc)
- func (r *PrometheusRuleReconciler) ShortName() string
- func (r *PrometheusRuleReconciler) Update(ctx context.Context, e event.TypedUpdateEvent[*unstructured.Unstructured], ...)
- func (_ *PrometheusRuleReconciler) UpdateSynchronizationResultsInDash0MonitoringStatus(monitoringResource *dash0v1beta1.Dash0Monitoring, qualifiedName string, ...) interface{}
- type SyntheticCheckReconciler
- func (r *SyntheticCheckReconciler) ControllerName() string
- func (r *SyntheticCheckReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
- func (r *SyntheticCheckReconciler) GetAuthToken() string
- func (r *SyntheticCheckReconciler) GetHttpRetryDelay() time.Duration
- func (r *SyntheticCheckReconciler) HttpClient() *http.Client
- func (r *SyntheticCheckReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *SyntheticCheckReconciler) K8sClient() client.Client
- func (r *SyntheticCheckReconciler) KindDisplayName() string
- func (r *SyntheticCheckReconciler) MapResourceToHttpRequests(preconditionChecksResult *preconditionValidationResult, action apiAction, ...) (int, []HttpRequestWithItemName, []string, map[string][]string, ...)
- func (r *SyntheticCheckReconciler) NotifiyOperatorManagerJustBecameLeader(ctx context.Context, logger *logr.Logger)
- func (r *SyntheticCheckReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
- func (r *SyntheticCheckReconciler) RemoveApiEndpointAndDataset(_ context.Context, _ *logr.Logger)
- func (r *SyntheticCheckReconciler) RemoveAuthToken(_ context.Context, _ *logr.Logger)
- func (r *SyntheticCheckReconciler) SetApiEndpointAndDataset(ctx context.Context, apiConfig *ApiConfig, logger *logr.Logger)
- func (r *SyntheticCheckReconciler) SetAuthToken(ctx context.Context, authToken string, logger *logr.Logger)
- func (r *SyntheticCheckReconciler) SetupWithManager(mgr manager.Manager) error
- func (r *SyntheticCheckReconciler) ShortName() string
- func (r *SyntheticCheckReconciler) WriteSynchronizationResultToSynchronizedResource(ctx context.Context, synchronizedResource client.Object, ...)
- type ThirdPartyCrdReconciler
- type ThirdPartyResourceReconciler
- type ThirdPartyResourceSyncJob
- type ViewReconciler
- func (r *ViewReconciler) ControllerName() string
- func (r *ViewReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
- func (r *ViewReconciler) GetAuthToken() string
- func (r *ViewReconciler) GetHttpRetryDelay() time.Duration
- func (r *ViewReconciler) HttpClient() *http.Client
- func (r *ViewReconciler) InitializeSelfMonitoringMetrics(meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger)
- func (r *ViewReconciler) K8sClient() client.Client
- func (r *ViewReconciler) KindDisplayName() string
- func (r *ViewReconciler) MapResourceToHttpRequests(preconditionChecksResult *preconditionValidationResult, action apiAction, ...) (int, []HttpRequestWithItemName, []string, map[string][]string, ...)
- func (r *ViewReconciler) NotifiyOperatorManagerJustBecameLeader(ctx context.Context, logger *logr.Logger)
- func (r *ViewReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
- func (r *ViewReconciler) RemoveApiEndpointAndDataset(_ context.Context, _ *logr.Logger)
- func (r *ViewReconciler) RemoveAuthToken(_ context.Context, _ *logr.Logger)
- func (r *ViewReconciler) SetApiEndpointAndDataset(ctx context.Context, apiConfig *ApiConfig, logger *logr.Logger)
- func (r *ViewReconciler) SetAuthToken(ctx context.Context, authToken string, logger *logr.Logger)
- func (r *ViewReconciler) SetupWithManager(mgr manager.Manager) error
- func (r *ViewReconciler) ShortName() string
- func (r *ViewReconciler) WriteSynchronizationResultToSynchronizedResource(ctx context.Context, synchronizedResource client.Object, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetupThirdPartyCrdReconcilerWithManager ¶
func SetupThirdPartyCrdReconcilerWithManager( ctx context.Context, k8sClient client.Client, crdReconciler ThirdPartyCrdReconciler, logger *logr.Logger, ) error
SetupThirdPartyCrdReconcilerWithManager sets up a ThirdPartyCrdReconciler with the provided manager. It establishes watches for the relevant CRD and starts/stops watching for the corresponding third-party resources as needed. In particular, it
- creates an ThirdPartyResourceReconciler for the respective third-party resource type,
- checks if the relevant third-party CRD already exists in the cluster, and if so, calls maybeStartWatchingThirdPartyResources,
- otherwise, maybeStartWatchingThirdPartyResources will be called later on different trigger points, for example when the third-party CRD is created in the cluster, or when a Dash0 API token is provided to the ThirdPartyCrdReconciler.
See function maybeStartWatchingThirdPartyResources for further details on the startup process.
func StartProcessingThirdPartySynchronizationQueue ¶
func StartProcessingThirdPartySynchronizationQueue( thirdPartyResourceSynchronizationQueue *workqueue.Typed[ThirdPartyResourceSyncJob], setupLog *logr.Logger, )
func StopProcessingThirdPartySynchronizationQueue ¶
func StopProcessingThirdPartySynchronizationQueue( resourceReconcileQueue *workqueue.Typed[ThirdPartyResourceSyncJob], logger *logr.Logger, )
Types ¶
type ApiSyncReconciler ¶
type ApiSyncReconciler interface { KindDisplayName() string ShortName() string GetAuthToken() string GetApiConfig() *atomic.Pointer[ApiConfig] ControllerName() string K8sClient() client.Client HttpClient() *http.Client GetHttpRetryDelay() time.Duration // MapResourceToHttpRequests converts a Kubernetes resource object to a list of HTTP requests that can be sent to // the Dash0 API. It returns: // - the total number of eligible items in the Kubernetes resource, // - the request objects for which the conversion was successful, // - validation issues for items that were invalid and // - synchronization errors that occurred during the conversion. MapResourceToHttpRequests( *preconditionValidationResult, apiAction, *logr.Logger, ) ( int, []HttpRequestWithItemName, []string, map[string][]string, map[string]string, ) }
ApiSyncReconciler is the common interface for reconcilers that synchonize their Kubernetes resources to the Dash0 API. This can either be resource types owned by the Dash0 operator (like Dash0SyntheticCheck), which then also implement the OwnedResourceReconciler interface, or third-party resource types (like PrometheusRule or PersesDashboard), which implement the ThirdPartyResourceReconciler interface.
type CheckRule ¶
type CheckRule struct { Name string `json:"name"` Expression string `json:"expression"` For string `json:"for,omitempty"` Interval string `json:"interval,omitempty"` KeepFiringFor string `json:"keepFiringFor,omitempty"` Annotations map[string]string `json:"annotations"` Labels map[string]string `json:"labels"` }
type Dash0ApiObjectWithOrigin ¶
type Dash0ApiObjectWithOrigin struct {
Origin string `json:"origin"`
}
type HttpRequestWithItemName ¶
type MonitoringReconciler ¶
func NewMonitoringReconciler ¶
func NewMonitoringReconciler( k8sClient client.Client, clientset *kubernetes.Clientset, instrumenter *instrumentation.Instrumenter, collectorManager *collectors.CollectorManager, danglingEventsTimeouts *util.DanglingEventsTimeouts, ) *MonitoringReconciler
func (*MonitoringReconciler) InitializeSelfMonitoringMetrics ¶
func (r *MonitoringReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*MonitoringReconciler) Reconcile ¶
func (r *MonitoringReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. It is essential for the controller's reconciliation loop to be idempotent. By following the Operator pattern you will create Controllers which provide a reconcile function responsible for synchronizing resources until the desired state is reached on the cluster. Breaking this recommendation goes against the design principles of controller-runtime. and may lead to unforeseen consequences such as resources becoming stuck and requiring manual intervention. For further info: - About Operator Pattern: https://kubernetes.io/docs/concepts/extend-kubernetes/operator/ - About Controllers: https://kubernetes.io/docs/concepts/architecture/controller/ - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.3/pkg/reconcile
func (*MonitoringReconciler) SetupWithManager ¶
func (r *MonitoringReconciler) SetupWithManager(mgr ctrl.Manager) error
type OperatorConfigurationReconciler ¶
type OperatorConfigurationReconciler struct { client.Client OperatorManagerPodName string DanglingEventsTimeouts *util.DanglingEventsTimeouts // contains filtered or unexported fields }
func NewOperatorConfigurationReconciler ¶
func NewOperatorConfigurationReconciler( k8sClient client.Client, clientset *kubernetes.Clientset, apiClients []ApiClient, collectorManager *collectors.CollectorManager, pseudoClusterUid types.UID, operatorDeploymentNamespace string, operatorDeploymentUID types.UID, operatorDeploymentName string, oTelSdkStarter *selfmonitoringapiaccess.OTelSdkStarter, images util.Images, operatorNamespace string, developmentMode bool, ) *OperatorConfigurationReconciler
func (*OperatorConfigurationReconciler) InitializeSelfMonitoringMetrics ¶
func (r *OperatorConfigurationReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*OperatorConfigurationReconciler) Reconcile ¶
func (r *OperatorConfigurationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. It is essential for the controller's reconciliation loop to be idempotent. By following the Operator pattern you will create Controllers which provide a reconcile function responsible for synchronizing resources until the desired state is reached on the cluster. Breaking this recommendation goes against the design principles of controller-runtime. and may lead to unforeseen consequences such as resources becoming stuck and requiring manual intervention. For further info: - About Operator Pattern: https://kubernetes.io/docs/concepts/extend-kubernetes/operator/ - About Controllers: https://kubernetes.io/docs/concepts/architecture/controller/ - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.3/pkg/reconcile
func (*OperatorConfigurationReconciler) SetAuthTokenClients ¶
func (r *OperatorConfigurationReconciler) SetAuthTokenClients(authTokenClients []selfmonitoringapiaccess.AuthTokenClient)
func (*OperatorConfigurationReconciler) SetupWithManager ¶
func (r *OperatorConfigurationReconciler) SetupWithManager(mgr ctrl.Manager) error
type OwnedResourceReconciler ¶
type OwnedResourceReconciler interface { ApiSyncReconciler // WriteSynchronizationResultToSynchronizedResource writes the result of a synchronization attempt to the status // of the Kubernetes resource that has been synchronized. This is only supported for resource types owned by the // Dash0 operator, not for third-party resource types. WriteSynchronizationResultToSynchronizedResource( context.Context, client.Object, dash0common.Dash0ApiResourceSynchronizationStatus, []string, string, *logr.Logger, ) }
OwnedResourceReconciler extends the ApiSyncReconciler interface with methods that are specific to resource types owned by the Dash0 operator (like Dash0SyntheticCheck, Dash0View).
type PersesDashboardCrdReconciler ¶
type PersesDashboardCrdReconciler struct { client.Client // contains filtered or unexported fields }
func NewPersesDashboardCrdReconciler ¶
func NewPersesDashboardCrdReconciler( k8sClient client.Client, queue *workqueue.Typed[ThirdPartyResourceSyncJob], leaderElectionAware util.LeaderElectionAware, httpClient *http.Client, ) *PersesDashboardCrdReconciler
func (*PersesDashboardCrdReconciler) ControllerName ¶
func (r *PersesDashboardCrdReconciler) ControllerName() string
func (*PersesDashboardCrdReconciler) Create ¶
func (r *PersesDashboardCrdReconciler) Create( ctx context.Context, _ event.TypedCreateEvent[client.Object], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardCrdReconciler) CreateThirdPartyResourceReconciler ¶
func (r *PersesDashboardCrdReconciler) CreateThirdPartyResourceReconciler(pseudoClusterUid types.UID)
func (*PersesDashboardCrdReconciler) Delete ¶
func (r *PersesDashboardCrdReconciler) Delete( ctx context.Context, _ event.TypedDeleteEvent[client.Object], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardCrdReconciler) DoesCrdExist ¶
func (r *PersesDashboardCrdReconciler) DoesCrdExist() *atomic.Bool
func (*PersesDashboardCrdReconciler) Generic ¶
func (r *PersesDashboardCrdReconciler) Generic( context.Context, event.TypedGenericEvent[client.Object], workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardCrdReconciler) Group ¶
func (r *PersesDashboardCrdReconciler) Group() string
func (*PersesDashboardCrdReconciler) InitializeSelfMonitoringMetrics ¶
func (r *PersesDashboardCrdReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*PersesDashboardCrdReconciler) Kind ¶
func (r *PersesDashboardCrdReconciler) Kind() string
func (*PersesDashboardCrdReconciler) KindDisplayName ¶
func (r *PersesDashboardCrdReconciler) KindDisplayName() string
func (*PersesDashboardCrdReconciler) Manager ¶
func (r *PersesDashboardCrdReconciler) Manager() ctrl.Manager
func (*PersesDashboardCrdReconciler) OperatorManagerIsLeader ¶
func (r *PersesDashboardCrdReconciler) OperatorManagerIsLeader() bool
func (*PersesDashboardCrdReconciler) QualifiedKind ¶
func (r *PersesDashboardCrdReconciler) QualifiedKind() string
func (*PersesDashboardCrdReconciler) RemoveApiEndpointAndDataset ¶
func (r *PersesDashboardCrdReconciler) RemoveApiEndpointAndDataset(ctx context.Context, logger *logr.Logger)
func (*PersesDashboardCrdReconciler) RemoveAuthToken ¶
func (r *PersesDashboardCrdReconciler) RemoveAuthToken(ctx context.Context, logger *logr.Logger)
func (*PersesDashboardCrdReconciler) SetApiEndpointAndDataset ¶
func (*PersesDashboardCrdReconciler) SetAuthToken ¶
func (*PersesDashboardCrdReconciler) SetCrdExists ¶
func (r *PersesDashboardCrdReconciler) SetCrdExists(exists bool)
func (*PersesDashboardCrdReconciler) SetupWithManager ¶
func (*PersesDashboardCrdReconciler) SkipNameValidation ¶
func (r *PersesDashboardCrdReconciler) SkipNameValidation() bool
func (*PersesDashboardCrdReconciler) ThirdPartyResourceReconciler ¶
func (r *PersesDashboardCrdReconciler) ThirdPartyResourceReconciler() ThirdPartyResourceReconciler
func (*PersesDashboardCrdReconciler) Update ¶
func (r *PersesDashboardCrdReconciler) Update( context.Context, event.TypedUpdateEvent[client.Object], workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardCrdReconciler) Version ¶
func (r *PersesDashboardCrdReconciler) Version() string
type PersesDashboardReconciler ¶
func (*PersesDashboardReconciler) ControllerName ¶
func (r *PersesDashboardReconciler) ControllerName() string
func (*PersesDashboardReconciler) ControllerStopFunctionLock ¶
func (r *PersesDashboardReconciler) ControllerStopFunctionLock() *sync.Mutex
func (*PersesDashboardReconciler) Create ¶
func (r *PersesDashboardReconciler) Create( ctx context.Context, e event.TypedCreateEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardReconciler) CreateDeleteRequests ¶
func (r *PersesDashboardReconciler) CreateDeleteRequests( _ *preconditionValidationResult, _ []string, _ []string, _ *logr.Logger, ) ([]HttpRequestWithItemName, map[string]string)
func (*PersesDashboardReconciler) Delete ¶
func (r *PersesDashboardReconciler) Delete( ctx context.Context, e event.TypedDeleteEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardReconciler) FetchExistingResourceOriginsRequest ¶
func (r *PersesDashboardReconciler) FetchExistingResourceOriginsRequest( _ *preconditionValidationResult, ) (*http.Request, error)
func (*PersesDashboardReconciler) Generic ¶
func (r *PersesDashboardReconciler) Generic( _ context.Context, _ event.TypedGenericEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardReconciler) GetApiConfig ¶
func (r *PersesDashboardReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
func (*PersesDashboardReconciler) GetAuthToken ¶
func (r *PersesDashboardReconciler) GetAuthToken() string
func (*PersesDashboardReconciler) GetControllerStopFunction ¶
func (r *PersesDashboardReconciler) GetControllerStopFunction() *context.CancelFunc
func (*PersesDashboardReconciler) GetHttpRetryDelay ¶
func (r *PersesDashboardReconciler) GetHttpRetryDelay() time.Duration
func (*PersesDashboardReconciler) HttpClient ¶
func (r *PersesDashboardReconciler) HttpClient() *http.Client
func (*PersesDashboardReconciler) InitializeSelfMonitoringMetrics ¶
func (r *PersesDashboardReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*PersesDashboardReconciler) IsSynchronizationEnabled ¶
func (r *PersesDashboardReconciler) IsSynchronizationEnabled(monitoringResource *dash0v1beta1.Dash0Monitoring) bool
func (*PersesDashboardReconciler) IsWatching ¶
func (r *PersesDashboardReconciler) IsWatching() bool
func (*PersesDashboardReconciler) K8sClient ¶
func (r *PersesDashboardReconciler) K8sClient() client.Client
func (*PersesDashboardReconciler) KindDisplayName ¶
func (r *PersesDashboardReconciler) KindDisplayName() string
func (*PersesDashboardReconciler) MapResourceToHttpRequests ¶
func (r *PersesDashboardReconciler) MapResourceToHttpRequests( preconditionChecksResult *preconditionValidationResult, action apiAction, logger *logr.Logger, ) (int, []HttpRequestWithItemName, []string, map[string][]string, map[string]string)
func (*PersesDashboardReconciler) Queue ¶
func (r *PersesDashboardReconciler) Queue() *workqueue.Typed[ThirdPartyResourceSyncJob]
func (*PersesDashboardReconciler) SetControllerStopFunction ¶
func (r *PersesDashboardReconciler) SetControllerStopFunction(controllerStopFunction *context.CancelFunc)
func (*PersesDashboardReconciler) ShortName ¶
func (r *PersesDashboardReconciler) ShortName() string
func (*PersesDashboardReconciler) Update ¶
func (r *PersesDashboardReconciler) Update( ctx context.Context, e event.TypedUpdateEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PersesDashboardReconciler) UpdateSynchronizationResultsInDash0MonitoringStatus ¶
func (_ *PersesDashboardReconciler) UpdateSynchronizationResultsInDash0MonitoringStatus( monitoringResource *dash0v1beta1.Dash0Monitoring, qualifiedName string, status dash0common.ThirdPartySynchronizationStatus, _ int, _ []string, synchronizationErrors map[string]string, validationIssuesMap map[string][]string, ) interface{}
type PrometheusRuleCrdReconciler ¶
func NewPrometheusRuleCrdReconciler ¶
func NewPrometheusRuleCrdReconciler( k8sClient client.Client, queue *workqueue.Typed[ThirdPartyResourceSyncJob], leaderElectionAware util.LeaderElectionAware, httpClient *http.Client, ) *PrometheusRuleCrdReconciler
func (*PrometheusRuleCrdReconciler) ControllerName ¶
func (r *PrometheusRuleCrdReconciler) ControllerName() string
func (*PrometheusRuleCrdReconciler) Create ¶
func (r *PrometheusRuleCrdReconciler) Create( ctx context.Context, _ event.TypedCreateEvent[client.Object], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleCrdReconciler) CreateThirdPartyResourceReconciler ¶
func (r *PrometheusRuleCrdReconciler) CreateThirdPartyResourceReconciler(pseudoClusterUid types.UID)
func (*PrometheusRuleCrdReconciler) Delete ¶
func (r *PrometheusRuleCrdReconciler) Delete( ctx context.Context, _ event.TypedDeleteEvent[client.Object], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleCrdReconciler) DoesCrdExist ¶
func (r *PrometheusRuleCrdReconciler) DoesCrdExist() *atomic.Bool
func (*PrometheusRuleCrdReconciler) Generic ¶
func (r *PrometheusRuleCrdReconciler) Generic( context.Context, event.TypedGenericEvent[client.Object], workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleCrdReconciler) Group ¶
func (r *PrometheusRuleCrdReconciler) Group() string
func (*PrometheusRuleCrdReconciler) InitializeSelfMonitoringMetrics ¶
func (r *PrometheusRuleCrdReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*PrometheusRuleCrdReconciler) Kind ¶
func (r *PrometheusRuleCrdReconciler) Kind() string
func (*PrometheusRuleCrdReconciler) KindDisplayName ¶
func (r *PrometheusRuleCrdReconciler) KindDisplayName() string
func (*PrometheusRuleCrdReconciler) Manager ¶
func (r *PrometheusRuleCrdReconciler) Manager() ctrl.Manager
func (*PrometheusRuleCrdReconciler) OperatorManagerIsLeader ¶
func (r *PrometheusRuleCrdReconciler) OperatorManagerIsLeader() bool
func (*PrometheusRuleCrdReconciler) QualifiedKind ¶
func (r *PrometheusRuleCrdReconciler) QualifiedKind() string
func (*PrometheusRuleCrdReconciler) RemoveApiEndpointAndDataset ¶
func (r *PrometheusRuleCrdReconciler) RemoveApiEndpointAndDataset(ctx context.Context, logger *logr.Logger)
func (*PrometheusRuleCrdReconciler) RemoveAuthToken ¶
func (r *PrometheusRuleCrdReconciler) RemoveAuthToken(ctx context.Context, logger *logr.Logger)
func (*PrometheusRuleCrdReconciler) SetApiEndpointAndDataset ¶
func (*PrometheusRuleCrdReconciler) SetAuthToken ¶
func (*PrometheusRuleCrdReconciler) SetCrdExists ¶
func (r *PrometheusRuleCrdReconciler) SetCrdExists(exists bool)
func (*PrometheusRuleCrdReconciler) SetupWithManager ¶
func (*PrometheusRuleCrdReconciler) SkipNameValidation ¶
func (r *PrometheusRuleCrdReconciler) SkipNameValidation() bool
func (*PrometheusRuleCrdReconciler) ThirdPartyResourceReconciler ¶
func (r *PrometheusRuleCrdReconciler) ThirdPartyResourceReconciler() ThirdPartyResourceReconciler
func (*PrometheusRuleCrdReconciler) Update ¶
func (r *PrometheusRuleCrdReconciler) Update( context.Context, event.TypedUpdateEvent[client.Object], workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleCrdReconciler) Version ¶
func (r *PrometheusRuleCrdReconciler) Version() string
type PrometheusRuleReconciler ¶
func (*PrometheusRuleReconciler) ControllerName ¶
func (r *PrometheusRuleReconciler) ControllerName() string
func (*PrometheusRuleReconciler) ControllerStopFunctionLock ¶
func (r *PrometheusRuleReconciler) ControllerStopFunctionLock() *sync.Mutex
func (*PrometheusRuleReconciler) Create ¶
func (r *PrometheusRuleReconciler) Create( ctx context.Context, e event.TypedCreateEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleReconciler) CreateDeleteRequests ¶
func (r *PrometheusRuleReconciler) CreateDeleteRequests( preconditionChecksResult *preconditionValidationResult, existingOriginsFromApi []string, originsInResource []string, logger *logr.Logger, ) ([]HttpRequestWithItemName, map[string]string)
func (*PrometheusRuleReconciler) Delete ¶
func (r *PrometheusRuleReconciler) Delete( ctx context.Context, e event.TypedDeleteEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleReconciler) FetchExistingResourceOriginsRequest ¶
func (r *PrometheusRuleReconciler) FetchExistingResourceOriginsRequest( preconditionChecksResult *preconditionValidationResult, ) (*http.Request, error)
func (*PrometheusRuleReconciler) Generic ¶
func (r *PrometheusRuleReconciler) Generic( _ context.Context, _ event.TypedGenericEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleReconciler) GetApiConfig ¶
func (r *PrometheusRuleReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
func (*PrometheusRuleReconciler) GetAuthToken ¶
func (r *PrometheusRuleReconciler) GetAuthToken() string
func (*PrometheusRuleReconciler) GetControllerStopFunction ¶
func (r *PrometheusRuleReconciler) GetControllerStopFunction() *context.CancelFunc
func (*PrometheusRuleReconciler) GetHttpRetryDelay ¶
func (r *PrometheusRuleReconciler) GetHttpRetryDelay() time.Duration
func (*PrometheusRuleReconciler) HttpClient ¶
func (r *PrometheusRuleReconciler) HttpClient() *http.Client
func (*PrometheusRuleReconciler) InitializeSelfMonitoringMetrics ¶
func (r *PrometheusRuleReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*PrometheusRuleReconciler) IsSynchronizationEnabled ¶
func (r *PrometheusRuleReconciler) IsSynchronizationEnabled(monitoringResource *dash0v1beta1.Dash0Monitoring) bool
func (*PrometheusRuleReconciler) IsWatching ¶
func (r *PrometheusRuleReconciler) IsWatching() bool
func (*PrometheusRuleReconciler) K8sClient ¶
func (r *PrometheusRuleReconciler) K8sClient() client.Client
func (*PrometheusRuleReconciler) KindDisplayName ¶
func (r *PrometheusRuleReconciler) KindDisplayName() string
func (*PrometheusRuleReconciler) MapResourceToHttpRequests ¶
func (r *PrometheusRuleReconciler) MapResourceToHttpRequests( preconditionChecksResult *preconditionValidationResult, action apiAction, logger *logr.Logger, ) (int, []HttpRequestWithItemName, []string, map[string][]string, map[string]string)
func (*PrometheusRuleReconciler) Queue ¶
func (r *PrometheusRuleReconciler) Queue() *workqueue.Typed[ThirdPartyResourceSyncJob]
func (*PrometheusRuleReconciler) SetControllerStopFunction ¶
func (r *PrometheusRuleReconciler) SetControllerStopFunction(controllerStopFunction *context.CancelFunc)
func (*PrometheusRuleReconciler) ShortName ¶
func (r *PrometheusRuleReconciler) ShortName() string
func (*PrometheusRuleReconciler) Update ¶
func (r *PrometheusRuleReconciler) Update( ctx context.Context, e event.TypedUpdateEvent[*unstructured.Unstructured], _ workqueue.TypedRateLimitingInterface[reconcile.Request], )
func (*PrometheusRuleReconciler) UpdateSynchronizationResultsInDash0MonitoringStatus ¶
func (_ *PrometheusRuleReconciler) UpdateSynchronizationResultsInDash0MonitoringStatus( monitoringResource *dash0v1beta1.Dash0Monitoring, qualifiedName string, status dash0common.ThirdPartySynchronizationStatus, itemsTotal int, successfullySynchronized []string, synchronizationErrorsPerItem map[string]string, validationIssuesPerItem map[string][]string, ) interface{}
type SyntheticCheckReconciler ¶
func NewSyntheticCheckReconciler ¶
func NewSyntheticCheckReconciler( k8sClient client.Client, pseudoClusterUid types.UID, leaderElectionAware util.LeaderElectionAware, httpClient *http.Client, ) *SyntheticCheckReconciler
func (*SyntheticCheckReconciler) ControllerName ¶
func (r *SyntheticCheckReconciler) ControllerName() string
func (*SyntheticCheckReconciler) GetApiConfig ¶
func (r *SyntheticCheckReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
func (*SyntheticCheckReconciler) GetAuthToken ¶
func (r *SyntheticCheckReconciler) GetAuthToken() string
func (*SyntheticCheckReconciler) GetHttpRetryDelay ¶
func (r *SyntheticCheckReconciler) GetHttpRetryDelay() time.Duration
func (*SyntheticCheckReconciler) HttpClient ¶
func (r *SyntheticCheckReconciler) HttpClient() *http.Client
func (*SyntheticCheckReconciler) InitializeSelfMonitoringMetrics ¶
func (r *SyntheticCheckReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*SyntheticCheckReconciler) K8sClient ¶
func (r *SyntheticCheckReconciler) K8sClient() client.Client
func (*SyntheticCheckReconciler) KindDisplayName ¶
func (r *SyntheticCheckReconciler) KindDisplayName() string
func (*SyntheticCheckReconciler) MapResourceToHttpRequests ¶
func (r *SyntheticCheckReconciler) MapResourceToHttpRequests( preconditionChecksResult *preconditionValidationResult, action apiAction, logger *logr.Logger, ) (int, []HttpRequestWithItemName, []string, map[string][]string, map[string]string)
func (*SyntheticCheckReconciler) NotifiyOperatorManagerJustBecameLeader ¶
func (r *SyntheticCheckReconciler) NotifiyOperatorManagerJustBecameLeader(ctx context.Context, logger *logr.Logger)
func (*SyntheticCheckReconciler) RemoveApiEndpointAndDataset ¶
func (r *SyntheticCheckReconciler) RemoveApiEndpointAndDataset(_ context.Context, _ *logr.Logger)
func (*SyntheticCheckReconciler) RemoveAuthToken ¶
func (r *SyntheticCheckReconciler) RemoveAuthToken(_ context.Context, _ *logr.Logger)
func (*SyntheticCheckReconciler) SetApiEndpointAndDataset ¶
func (*SyntheticCheckReconciler) SetAuthToken ¶
func (*SyntheticCheckReconciler) SetupWithManager ¶
func (r *SyntheticCheckReconciler) SetupWithManager(mgr manager.Manager) error
func (*SyntheticCheckReconciler) ShortName ¶
func (r *SyntheticCheckReconciler) ShortName() string
func (*SyntheticCheckReconciler) WriteSynchronizationResultToSynchronizedResource ¶
func (r *SyntheticCheckReconciler) WriteSynchronizationResultToSynchronizedResource( ctx context.Context, synchronizedResource client.Object, status dash0common.Dash0ApiResourceSynchronizationStatus, validationIssues []string, synchronizationError string, logger *logr.Logger, )
type ThirdPartyCrdReconciler ¶
type ThirdPartyCrdReconciler interface { handler.TypedEventHandler[client.Object, reconcile.Request] reconcile.TypedReconciler[reconcile.Request] Manager() ctrl.Manager KindDisplayName() string Group() string Kind() string Version() string QualifiedKind() string ControllerName() string DoesCrdExist() *atomic.Bool SetCrdExists(bool) SkipNameValidation() bool OperatorManagerIsLeader() bool CreateThirdPartyResourceReconciler(types.UID) ThirdPartyResourceReconciler() ThirdPartyResourceReconciler }
ThirdPartyCrdReconciler is an interface for reconcilers that act on CRDs of third-party resource types (i.e. when a particular CRD is deployed to the cluster or removed).
type ThirdPartyResourceReconciler ¶
type ThirdPartyResourceReconciler interface { ApiSyncReconciler handler.TypedEventHandler[*unstructured.Unstructured, reconcile.Request] reconcile.TypedReconciler[reconcile.Request] IsSynchronizationEnabled(*dash0v1beta1.Dash0Monitoring) bool ControllerStopFunctionLock() *sync.Mutex GetControllerStopFunction() *context.CancelFunc SetControllerStopFunction(*context.CancelFunc) IsWatching() bool Queue() *workqueue.Typed[ThirdPartyResourceSyncJob] // FetchExistingResourceOriginsRequest creates an HTTP request for retrieving the existing origins from the Dash0 // API for a given Kubernetes resource. // FetchExistingResourceOriginsRequest is only used for resource types where one Kubernetes resource (say, a // PrometheusRule) is potentially associated with multiple Dash0 api objects (multiple checks). Controllers // which manage objects with a one-to-one relation (like Perses dashboards) should return nil, nil. FetchExistingResourceOriginsRequest(*preconditionValidationResult) (*http.Request, error) // CreateDeleteRequests produces an HTTP DELETE requests for the resources that still exist in Dash0, but should // not. It does so by comparing the list of IDs of objects that exist in the Dash0 backend with the list // of IDs found in a given Kubernetes resource. This mechanism is only used for resource types where one Kubernetes // resource (say, a PrometheusRule) is potentially associated with multiple Dash0 api objects (multiple checks). // Controllers which manage objects with a one-to-one relation (like Perses dashboards, synthetic checks, view) // should return nil, nil. CreateDeleteRequests(*preconditionValidationResult, []string, []string, *logr.Logger) ([]HttpRequestWithItemName, map[string]string) // UpdateSynchronizationResultsInDash0MonitoringStatus Modifies the status of the provided Dash0Monitoring resource // to reflect the results of the synchronization operation for one third-party Kubernetes resource. UpdateSynchronizationResultsInDash0MonitoringStatus( monitoringResource *dash0v1beta1.Dash0Monitoring, qualifiedName string, status dash0common.ThirdPartySynchronizationStatus, itemsTotal int, successfullySynchronized []string, synchronizationErrorsPerItem map[string]string, validationIssuesPerItem map[string][]string, ) interface{} }
ThirdPartyResourceReconciler extends the ApiSyncReconciler interface with methods that are specific to reconcilers for third-party resource types (like Perses dashboards or Prometheus rules).
type ThirdPartyResourceSyncJob ¶
type ThirdPartyResourceSyncJob struct {
// contains filtered or unexported fields
}
type ViewReconciler ¶
func NewViewReconciler ¶
func NewViewReconciler( k8sClient client.Client, pseudoClusterUid types.UID, leaderElectionAware util.LeaderElectionAware, httpClient *http.Client, ) *ViewReconciler
func (*ViewReconciler) ControllerName ¶
func (r *ViewReconciler) ControllerName() string
func (*ViewReconciler) GetApiConfig ¶
func (r *ViewReconciler) GetApiConfig() *atomic.Pointer[ApiConfig]
func (*ViewReconciler) GetAuthToken ¶
func (r *ViewReconciler) GetAuthToken() string
func (*ViewReconciler) GetHttpRetryDelay ¶
func (r *ViewReconciler) GetHttpRetryDelay() time.Duration
func (*ViewReconciler) HttpClient ¶
func (r *ViewReconciler) HttpClient() *http.Client
func (*ViewReconciler) InitializeSelfMonitoringMetrics ¶
func (r *ViewReconciler) InitializeSelfMonitoringMetrics( meter otelmetric.Meter, metricNamePrefix string, logger *logr.Logger, )
func (*ViewReconciler) K8sClient ¶
func (r *ViewReconciler) K8sClient() client.Client
func (*ViewReconciler) KindDisplayName ¶
func (r *ViewReconciler) KindDisplayName() string
func (*ViewReconciler) MapResourceToHttpRequests ¶
func (r *ViewReconciler) MapResourceToHttpRequests( preconditionChecksResult *preconditionValidationResult, action apiAction, logger *logr.Logger, ) (int, []HttpRequestWithItemName, []string, map[string][]string, map[string]string)
func (*ViewReconciler) NotifiyOperatorManagerJustBecameLeader ¶
func (r *ViewReconciler) NotifiyOperatorManagerJustBecameLeader(ctx context.Context, logger *logr.Logger)
func (*ViewReconciler) RemoveApiEndpointAndDataset ¶
func (r *ViewReconciler) RemoveApiEndpointAndDataset(_ context.Context, _ *logr.Logger)
func (*ViewReconciler) RemoveAuthToken ¶
func (r *ViewReconciler) RemoveAuthToken(_ context.Context, _ *logr.Logger)
func (*ViewReconciler) SetApiEndpointAndDataset ¶
func (*ViewReconciler) SetAuthToken ¶
func (*ViewReconciler) SetupWithManager ¶
func (r *ViewReconciler) SetupWithManager(mgr manager.Manager) error
func (*ViewReconciler) ShortName ¶
func (r *ViewReconciler) ShortName() string
func (*ViewReconciler) WriteSynchronizationResultToSynchronizedResource ¶
func (r *ViewReconciler) WriteSynchronizationResultToSynchronizedResource( ctx context.Context, synchronizedResource client.Object, status dash0common.Dash0ApiResourceSynchronizationStatus, validationIssues []string, synchronizationError string, logger *logr.Logger, )