controller

package
v0.0.0-...-102792a Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetupThirdPartyCrdReconcilerWithManager 

func SetupThirdPartyCrdReconcilerWithManager(
	ctx context.Context,
	k8sClient client.Client,
	crdReconciler ThirdPartyCrdReconciler,
	logger logd.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 logd.Logger,
)

func StopProcessingThirdPartySynchronizationQueue 

func StopProcessingThirdPartySynchronizationQueue(
	resourceReconcileQueue *workqueue.Typed[ThirdPartyResourceSyncJob],
	logger logd.Logger,
)

Types

type ApiClient 

type ApiClient interface {
	SetDefaultApiConfigs(context.Context, []ApiConfig, logd.Logger)
	RemoveDefaultApiConfigs(context.Context, logd.Logger)
}

type ApiConfig 

type ApiConfig struct {
	Endpoint string
	Dataset  string
	Token    string
}

type ApiSyncReconciler 

type ApiSyncReconciler interface {
	KindDisplayName() string
	ShortName() string
	GetDefaultApiConfigs() []ApiConfig
	GetNamespacedApiConfigs(string) ([]ApiConfig, bool)
	ControllerName() string
	K8sClient() client.Client
	HttpClient() *http.Client

	// 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, ApiConfig, apiAction, logd.Logger) *ResourceToRequestsResult

	ExtractIdFromResponseBody(
		responseBytes []byte,
		logger logd.Logger,
	) (string, error)
}

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 AutoNamespaceMonitoringReconciler 

type AutoNamespaceMonitoringReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

The AutoNamespaceMonitoringReconciler watches the operator configuration resource (in parallel to the operator configuration controller). If the operator configuration resource becomes available and has automatic namespace monitoring enabled, it starts watching namespaces. If automatic namespace monitoring is disabled, it stops watching namespaces.

func NewAutoNamespaceMonitoringReconciler 

func NewAutoNamespaceMonitoringReconciler(
	k8sClient client.Client,
	operatorNamespace string,
) *AutoNamespaceMonitoringReconciler

func (*AutoNamespaceMonitoringReconciler) InitializeSelfMonitoringMetrics 

func (r *AutoNamespaceMonitoringReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.Logger,
)

func (*AutoNamespaceMonitoringReconciler) Reconcile 

func (r *AutoNamespaceMonitoringReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*AutoNamespaceMonitoringReconciler) SetupWithManager 

func (r *AutoNamespaceMonitoringReconciler) SetupWithManager(mgr ctrl.Manager) error

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 Dash0ApiCrdObjectWithOrigin 

type Dash0ApiCrdObjectWithOrigin struct {
	Metadata struct {
		Labels map[string]string `json:"labels"`
	} `json:"metadata"`
}

Dash0ApiCrdObjectWithOrigin represents the response format from APIs that return full CRD objects (e.g., the recording rules API), where the origin is nested inside metadata.labels.

type Dash0ApiObjectLabels 

type Dash0ApiObjectLabels struct {
	Id          string `json:"dash0.com/id,omitempty"`
	Origin      string `json:"dash0.com/origin,omitempty"`
	ApiEndpoint string `json:"dash0.com/apiEndpoint"`
	Dataset     string `json:"dash0.com/dataset"`
}

type Dash0ApiObjectMetadata 

type Dash0ApiObjectMetadata struct {
	Labels Dash0ApiObjectLabels `json:"labels"`
}

type Dash0ApiObjectWithMetadata 

type Dash0ApiObjectWithMetadata struct {
	Metadata Dash0ApiObjectMetadata `json:"metadata"`
}

type Dash0ApiObjectWithOrigin 

type Dash0ApiObjectWithOrigin struct {
	Origin string `json:"origin"`
}

type Dash0ApiResponseWithOriginAsId 

type Dash0ApiResponseWithOriginAsId struct {
	Origin  string `json:"id"`
	Dataset string `json:"dataset"`
}

type Dash0DashboardMetadata 

type Dash0DashboardMetadata struct {
	Dash0Extensions Dash0ApiResponseWithOriginAsId `json:"dash0Extensions"`
}

type Dash0DashboardResponse 

type Dash0DashboardResponse struct {
	Metadata Dash0DashboardMetadata `json:"metadata"`
}

type MonitoringReconciler 

type MonitoringReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewMonitoringReconciler 

func NewMonitoringReconciler(
	k8sClient client.Client,
	clientset *kubernetes.Clientset,
	namespacedApiClients []NamespacedApiClient,
	instrumenter *instrumentation.Instrumenter,
	collectorManager *collectors.CollectorManager,
	targetAllocatorManager *targetallocator.TargetAllocatorManager,
	danglingEventsTimeouts *util.DanglingEventsTimeouts,
	operatorNamespace string,
) *MonitoringReconciler

func (*MonitoringReconciler) InitializeSelfMonitoringMetrics 

func (r *MonitoringReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.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. Needs to be idempotent.

func (*MonitoringReconciler) SetupWithManager 

func (r *MonitoringReconciler) SetupWithManager(mgr ctrl.Manager) error

type NamespaceWatcher 

type NamespaceWatcher struct {
	client.Client
	// contains filtered or unexported fields
}

func NewNamespaceWatcher 

func NewNamespaceWatcher(k8sClient client.Client, operatorNamespace string) *NamespaceWatcher

func (*NamespaceWatcher) InitializeSelfMonitoringMetrics 

func (w *NamespaceWatcher) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.Logger,
)

func (*NamespaceWatcher) Reconcile 

func (w *NamespaceWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type NamespacedApiClient 

type NamespacedApiClient interface {
	SetNamespacedApiConfigs(context.Context, string, []ApiConfig, logd.Logger)
	RemoveNamespacedApiConfigs(context.Context, string, logd.Logger)
	SetSynchronizationEnabled(context.Context, string, *dash0v1beta1.Dash0Monitoring, logd.Logger)
	RemoveSynchronizationEnabled(string)
}

type NotificationChannelReconciler 

type NotificationChannelReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewNotificationChannelReconciler 

func NewNotificationChannelReconciler(
	k8sClient client.Client,
	pseudoClusterUid types.UID,
	leaderElectionAware util.LeaderElectionAware,
	httpClient *http.Client,
) *NotificationChannelReconciler

func (*NotificationChannelReconciler) ControllerName 

func (r *NotificationChannelReconciler) ControllerName() string

func (*NotificationChannelReconciler) ExtractIdFromResponseBody 

func (r *NotificationChannelReconciler) ExtractIdFromResponseBody(
	responseBytes []byte,
	logger logd.Logger,
) (id string, err error)

func (*NotificationChannelReconciler) GetDefaultApiConfigs 

func (r *NotificationChannelReconciler) GetDefaultApiConfigs() []ApiConfig

func (*NotificationChannelReconciler) GetNamespacedApiConfigs 

func (r *NotificationChannelReconciler) GetNamespacedApiConfigs(namespace string) ([]ApiConfig, bool)

func (*NotificationChannelReconciler) HttpClient 

func (r *NotificationChannelReconciler) HttpClient() *http.Client

func (*NotificationChannelReconciler) InitializeSelfMonitoringMetrics 

func (r *NotificationChannelReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.Logger,
)

func (*NotificationChannelReconciler) K8sClient 

func (r *NotificationChannelReconciler) K8sClient() client.Client

func (*NotificationChannelReconciler) KindDisplayName 

func (r *NotificationChannelReconciler) KindDisplayName() string

func (*NotificationChannelReconciler) MapResourceToHttpRequests 

func (r *NotificationChannelReconciler) MapResourceToHttpRequests(
	preconditionChecksResult *preconditionValidationResult,
	apiConfig ApiConfig,
	action apiAction,
	logger logd.Logger,
) *ResourceToRequestsResult

func (*NotificationChannelReconciler) NotifyOperatorManagerJustBecameLeader 

func (r *NotificationChannelReconciler) NotifyOperatorManagerJustBecameLeader(
	ctx context.Context,
	logger logd.Logger,
)

func (*NotificationChannelReconciler) Reconcile 

func (r *NotificationChannelReconciler) Reconcile(
	ctx context.Context,
	req reconcile.Request,
) (reconcile.Result, error)

func (*NotificationChannelReconciler) RemoveDefaultApiConfigs 

func (r *NotificationChannelReconciler) RemoveDefaultApiConfigs(_ context.Context, _ logd.Logger)

func (*NotificationChannelReconciler) RemoveNamespacedApiConfigs 

func (r *NotificationChannelReconciler) RemoveNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	logger logd.Logger,
)

func (*NotificationChannelReconciler) RemoveSynchronizationEnabled 

func (r *NotificationChannelReconciler) RemoveSynchronizationEnabled(_ string)

func (*NotificationChannelReconciler) SetDefaultApiConfigs 

func (r *NotificationChannelReconciler) SetDefaultApiConfigs(
	ctx context.Context,
	apiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*NotificationChannelReconciler) SetNamespacedApiConfigs 

func (r *NotificationChannelReconciler) SetNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	updatedApiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*NotificationChannelReconciler) SetSynchronizationEnabled 

func (r *NotificationChannelReconciler) SetSynchronizationEnabled(
	_ context.Context,
	_ string,
	_ *dash0v1beta1.Dash0Monitoring,
	_ logd.Logger,
)

func (*NotificationChannelReconciler) SetupWithManager 

func (r *NotificationChannelReconciler) SetupWithManager(mgr manager.Manager) error

func (*NotificationChannelReconciler) ShortName 

func (r *NotificationChannelReconciler) ShortName() string

func (*NotificationChannelReconciler) WriteSynchronizationResultToSynchronizedResource 

func (r *NotificationChannelReconciler) WriteSynchronizationResultToSynchronizedResource(
	ctx context.Context,
	synchronizedResource client.Object,
	syncResults synchronizationResults,
	logger logd.Logger,
)

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,
	targetAllocatorManager *targetallocator.TargetAllocatorManager,
	intelligentEdgeManager *intelligentedge.IntelligentEdgeManager,
	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 logd.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. Needs to be idempotent.

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,
		synchronizationResults,
		logd.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 logd.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) Reconcile 

func (r *PersesDashboardCrdReconciler) Reconcile(
	_ context.Context,
	_ reconcile.Request,
) (reconcile.Result, error)

func (*PersesDashboardCrdReconciler) RemoveDefaultApiConfigs 

func (r *PersesDashboardCrdReconciler) RemoveDefaultApiConfigs(ctx context.Context, logger logd.Logger)

func (*PersesDashboardCrdReconciler) RemoveNamespacedApiConfigs 

func (r *PersesDashboardCrdReconciler) RemoveNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	logger logd.Logger,
)

func (*PersesDashboardCrdReconciler) RemoveSynchronizationEnabled 

func (r *PersesDashboardCrdReconciler) RemoveSynchronizationEnabled(namespace string)

func (*PersesDashboardCrdReconciler) SetCrdExists 

func (r *PersesDashboardCrdReconciler) SetCrdExists(exists bool)

func (*PersesDashboardCrdReconciler) SetDefaultApiConfigs 

func (r *PersesDashboardCrdReconciler) SetDefaultApiConfigs(
	ctx context.Context,
	apiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*PersesDashboardCrdReconciler) SetNamespacedApiConfigs 

func (r *PersesDashboardCrdReconciler) SetNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	updatedApiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*PersesDashboardCrdReconciler) SetSynchronizationEnabled 

func (r *PersesDashboardCrdReconciler) SetSynchronizationEnabled(
	ctx context.Context,
	namespace string,
	monitoringResource *dash0v1beta1.Dash0Monitoring,
	logger logd.Logger,
)

func (*PersesDashboardCrdReconciler) SetupWithManager 

func (r *PersesDashboardCrdReconciler) SetupWithManager(
	ctx context.Context,
	mgr ctrl.Manager,
	startupK8sClient client.Client,
	logger logd.Logger,
) error

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 

type PersesDashboardReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

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(
	_ ApiConfig,
	_ []string,
	_ []string,
	_ logd.Logger,
) ([]WrappedApiRequest, map[string]string)

func (*PersesDashboardReconciler) Delete 

func (r *PersesDashboardReconciler) Delete(
	ctx context.Context,
	e event.TypedDeleteEvent[*unstructured.Unstructured],
	_ workqueue.TypedRateLimitingInterface[reconcile.Request],
)

func (*PersesDashboardReconciler) ExtractIdFromResponseBody 

func (r *PersesDashboardReconciler) ExtractIdFromResponseBody(
	responseBytes []byte,
	logger logd.Logger,
) (id string, err error)

func (*PersesDashboardReconciler) FetchExistingResourceOriginsRequests 

func (r *PersesDashboardReconciler) FetchExistingResourceOriginsRequests(
	_ *preconditionValidationResult,
	_ ApiConfig,
) ([]*http.Request, error)

func (*PersesDashboardReconciler) Generic 

func (r *PersesDashboardReconciler) Generic(
	ctx context.Context,
	e event.TypedGenericEvent[*unstructured.Unstructured],
	_ workqueue.TypedRateLimitingInterface[reconcile.Request],
)

func (*PersesDashboardReconciler) GetControllerStopFunction 

func (r *PersesDashboardReconciler) GetControllerStopFunction() *context.CancelFunc

func (*PersesDashboardReconciler) GetDefaultApiConfigs 

func (r *PersesDashboardReconciler) GetDefaultApiConfigs() []ApiConfig

func (*PersesDashboardReconciler) GetNamespacedApiConfigs 

func (r *PersesDashboardReconciler) GetNamespacedApiConfigs(namespace string) ([]ApiConfig, bool)

func (*PersesDashboardReconciler) HttpClient 

func (r *PersesDashboardReconciler) HttpClient() *http.Client

func (*PersesDashboardReconciler) InitializeSelfMonitoringMetrics 

func (r *PersesDashboardReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.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,
	apiConfig ApiConfig,
	action apiAction,
	logger logd.Logger,
) *ResourceToRequestsResult

func (*PersesDashboardReconciler) Queue 

func (r *PersesDashboardReconciler) Queue() *workqueue.Typed[ThirdPartyResourceSyncJob]

func (*PersesDashboardReconciler) Reconcile 

func (r *PersesDashboardReconciler) Reconcile(
	context.Context,
	reconcile.Request,
) (reconcile.Result, error)

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,
	syncResults synchronizationResults,
) any

type PrometheusRuleCrdReconciler 

type PrometheusRuleCrdReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

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 logd.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) Reconcile 

func (r *PrometheusRuleCrdReconciler) Reconcile(
	_ context.Context,
	_ reconcile.Request,
) (reconcile.Result, error)

func (*PrometheusRuleCrdReconciler) RemoveDefaultApiConfigs 

func (r *PrometheusRuleCrdReconciler) RemoveDefaultApiConfigs(ctx context.Context, logger logd.Logger)

func (*PrometheusRuleCrdReconciler) RemoveNamespacedApiConfigs 

func (r *PrometheusRuleCrdReconciler) RemoveNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	logger logd.Logger,
)

func (*PrometheusRuleCrdReconciler) RemoveSynchronizationEnabled 

func (r *PrometheusRuleCrdReconciler) RemoveSynchronizationEnabled(namespace string)

func (*PrometheusRuleCrdReconciler) SetCrdExists 

func (r *PrometheusRuleCrdReconciler) SetCrdExists(exists bool)

func (*PrometheusRuleCrdReconciler) SetDefaultApiConfigs 

func (r *PrometheusRuleCrdReconciler) SetDefaultApiConfigs(
	ctx context.Context,
	apiConfig []ApiConfig,
	logger logd.Logger,
)

func (*PrometheusRuleCrdReconciler) SetNamespacedApiConfigs 

func (r *PrometheusRuleCrdReconciler) SetNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	updatedApiConfig []ApiConfig,
	logger logd.Logger,
)

func (*PrometheusRuleCrdReconciler) SetSynchronizationEnabled 

func (r *PrometheusRuleCrdReconciler) SetSynchronizationEnabled(
	ctx context.Context,
	namespace string,
	monitoringResource *dash0v1beta1.Dash0Monitoring,
	logger logd.Logger,
)

func (*PrometheusRuleCrdReconciler) SetupWithManager 

func (r *PrometheusRuleCrdReconciler) SetupWithManager(
	ctx context.Context,
	mgr ctrl.Manager,
	startupK8sClient client.Client,
	logger logd.Logger,
) error

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 

type PrometheusRuleReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

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(
	apiConfig ApiConfig,
	existingOriginsFromApi []string,
	originsInResource []string,
	logger logd.Logger,
) ([]WrappedApiRequest, map[string]string)

func (*PrometheusRuleReconciler) Delete 

func (r *PrometheusRuleReconciler) Delete(
	ctx context.Context,
	e event.TypedDeleteEvent[*unstructured.Unstructured],
	_ workqueue.TypedRateLimitingInterface[reconcile.Request],
)

func (*PrometheusRuleReconciler) ExtractIdFromResponseBody 

func (r *PrometheusRuleReconciler) ExtractIdFromResponseBody(
	responseBytes []byte,
	logger logd.Logger,
) (id string, err error)

func (*PrometheusRuleReconciler) FetchExistingResourceOriginsRequests 

func (r *PrometheusRuleReconciler) FetchExistingResourceOriginsRequests(
	preconditionValidationResult *preconditionValidationResult,
	apiConfig ApiConfig,
) ([]*http.Request, error)

func (*PrometheusRuleReconciler) Generic 

func (r *PrometheusRuleReconciler) Generic(
	ctx context.Context,
	e event.TypedGenericEvent[*unstructured.Unstructured],
	_ workqueue.TypedRateLimitingInterface[reconcile.Request],
)

func (*PrometheusRuleReconciler) GetControllerStopFunction 

func (r *PrometheusRuleReconciler) GetControllerStopFunction() *context.CancelFunc

func (*PrometheusRuleReconciler) GetDefaultApiConfigs 

func (r *PrometheusRuleReconciler) GetDefaultApiConfigs() []ApiConfig

func (*PrometheusRuleReconciler) GetNamespacedApiConfigs 

func (r *PrometheusRuleReconciler) GetNamespacedApiConfigs(namespace string) ([]ApiConfig, bool)

func (*PrometheusRuleReconciler) HttpClient 

func (r *PrometheusRuleReconciler) HttpClient() *http.Client

func (*PrometheusRuleReconciler) InitializeSelfMonitoringMetrics 

func (r *PrometheusRuleReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.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,
	apiConfig ApiConfig,
	action apiAction,
	logger logd.Logger,
) *ResourceToRequestsResult

func (*PrometheusRuleReconciler) Queue 

func (r *PrometheusRuleReconciler) Queue() *workqueue.Typed[ThirdPartyResourceSyncJob]

func (*PrometheusRuleReconciler) Reconcile 

func (r *PrometheusRuleReconciler) Reconcile(
	context.Context,
	reconcile.Request,
) (reconcile.Result, error)

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,
	syncResults synchronizationResults,
) any

type ResourceToRequestsResult 

type ResourceToRequestsResult struct {
	ApiConfig ApiConfig
	// the number of alerting rules in this resource (only relevant for PrometheusRule resources)
	AlertingRulesTotal int
	// the number of recording rules in this resource (only relevant for PrometheusRule resources)
	RecordingRulesTotal int
	// the number of orphan delete requests (rules removed from the resource but still present in the Dash0 API)
	OrphanDeletesTotal int
	// the request objects for which the conversion was successful
	ApiRequests []WrappedApiRequest
	// only set for resource types with a one-to-many relationship between Kubernetes resources and Dash0 entities,
	// contains a list of all Dash0 origins produced by this Kubernetes resource for this ApiConfig
	OriginsInResource []string
	// synchronization errors that occurred during the conversion - if there is a synchronization error for a resource,
	// ApiRequests must not contain a request for the associated resource
	SynchronizationErrors map[string]string
	// validation issues that occurred while preparing the request
	ValidationIssues map[string][]string
}

func NewResourceToRequestsResult 

func NewResourceToRequestsResult(
	apiConfig ApiConfig,
	apiRequests []WrappedApiRequest,
	origins []string,
	validationIssues map[string][]string,
	synchronizationErrors map[string]string,
) *ResourceToRequestsResult

func NewResourceToRequestsResultPreconditionError 

func NewResourceToRequestsResultPreconditionError(apiConfig ApiConfig, errorMessage string) *ResourceToRequestsResult

func NewResourceToRequestsResultSingleItemError 

func NewResourceToRequestsResultSingleItemError(
	apiConfig ApiConfig,
	itemName string,
	errorMessage string,
) *ResourceToRequestsResult

func NewResourceToRequestsResultSingleItemSuccess 

func NewResourceToRequestsResultSingleItemSuccess(
	apiConfig ApiConfig,
	request *http.Request,
	itemName string,
	origin string,
) *ResourceToRequestsResult

func NewResourceToRequestsResultSingleItemValidationIssue 

func NewResourceToRequestsResultSingleItemValidationIssue(
	apiConfig ApiConfig,
	itemName string,
	issue string,
) *ResourceToRequestsResult

func (*ResourceToRequestsResult) HasNoErrorsAndNoIssues 

func (m *ResourceToRequestsResult) HasNoErrorsAndNoIssues() bool

func (*ResourceToRequestsResult) IsNoOp 

func (m *ResourceToRequestsResult) IsNoOp() bool

func (*ResourceToRequestsResult) TotalProcessed 

func (m *ResourceToRequestsResult) TotalProcessed() int

TotalProcessed returns the total number of items processed, that is, update attempts (including failed attempts due to validation issues or synchronization errors), plus deleted orphans (only relevant for 1-to-many resource types like PrometheusRules).

type SamplingRuleReconciler 

type SamplingRuleReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewSamplingRuleReconciler 

func NewSamplingRuleReconciler(
	k8sClient client.Client,
	pseudoClusterUid types.UID,
	leaderElectionAware util.LeaderElectionAware,
	httpClient *http.Client,
) *SamplingRuleReconciler

func (*SamplingRuleReconciler) ControllerName 

func (r *SamplingRuleReconciler) ControllerName() string

func (*SamplingRuleReconciler) ExtractIdFromResponseBody 

func (r *SamplingRuleReconciler) ExtractIdFromResponseBody(
	responseBytes []byte,
	logger logd.Logger,
) (id string, err error)

func (*SamplingRuleReconciler) GetDefaultApiConfigs 

func (r *SamplingRuleReconciler) GetDefaultApiConfigs() []ApiConfig

func (*SamplingRuleReconciler) GetNamespacedApiConfigs 

func (r *SamplingRuleReconciler) GetNamespacedApiConfigs(_ string) ([]ApiConfig, bool)

func (*SamplingRuleReconciler) HttpClient 

func (r *SamplingRuleReconciler) HttpClient() *http.Client

func (*SamplingRuleReconciler) InitializeSelfMonitoringMetrics 

func (r *SamplingRuleReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.Logger,
)

func (*SamplingRuleReconciler) K8sClient 

func (r *SamplingRuleReconciler) K8sClient() client.Client

func (*SamplingRuleReconciler) KindDisplayName 

func (r *SamplingRuleReconciler) KindDisplayName() string

func (*SamplingRuleReconciler) MapResourceToHttpRequests 

func (r *SamplingRuleReconciler) MapResourceToHttpRequests(
	preconditionChecksResult *preconditionValidationResult,
	apiConfig ApiConfig,
	action apiAction,
	logger logd.Logger,
) *ResourceToRequestsResult

func (*SamplingRuleReconciler) NotifyOperatorManagerJustBecameLeader 

func (r *SamplingRuleReconciler) NotifyOperatorManagerJustBecameLeader(ctx context.Context, logger logd.Logger)

func (*SamplingRuleReconciler) Reconcile 

func (r *SamplingRuleReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*SamplingRuleReconciler) RemoveDefaultApiConfigs 

func (r *SamplingRuleReconciler) RemoveDefaultApiConfigs(_ context.Context, _ logd.Logger)

func (*SamplingRuleReconciler) SetDefaultApiConfigs 

func (r *SamplingRuleReconciler) SetDefaultApiConfigs(
	ctx context.Context,
	apiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*SamplingRuleReconciler) SetupWithManager 

func (r *SamplingRuleReconciler) SetupWithManager(mgr manager.Manager) error

func (*SamplingRuleReconciler) ShortName 

func (r *SamplingRuleReconciler) ShortName() string

func (*SamplingRuleReconciler) WriteSynchronizationResultToSynchronizedResource 

func (r *SamplingRuleReconciler) WriteSynchronizationResultToSynchronizedResource(
	ctx context.Context,
	synchronizedResource client.Object,
	syncResults synchronizationResults,
	logger logd.Logger,
)

type SpamFilterReconciler 

type SpamFilterReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewSpamFilterReconciler 

func NewSpamFilterReconciler(
	k8sClient client.Client,
	pseudoClusterUid types.UID,
	leaderElectionAware util.LeaderElectionAware,
	httpClient *http.Client,
) *SpamFilterReconciler

func (*SpamFilterReconciler) ControllerName 

func (r *SpamFilterReconciler) ControllerName() string

func (*SpamFilterReconciler) ExtractIdFromResponseBody 

func (r *SpamFilterReconciler) ExtractIdFromResponseBody(
	responseBytes []byte,
	logger logd.Logger,
) (id string, err error)

func (*SpamFilterReconciler) GetDefaultApiConfigs 

func (r *SpamFilterReconciler) GetDefaultApiConfigs() []ApiConfig

func (*SpamFilterReconciler) GetNamespacedApiConfigs 

func (r *SpamFilterReconciler) GetNamespacedApiConfigs(namespace string) ([]ApiConfig, bool)

func (*SpamFilterReconciler) HttpClient 

func (r *SpamFilterReconciler) HttpClient() *http.Client

func (*SpamFilterReconciler) InitializeSelfMonitoringMetrics 

func (r *SpamFilterReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.Logger,
)

func (*SpamFilterReconciler) K8sClient 

func (r *SpamFilterReconciler) K8sClient() client.Client

func (*SpamFilterReconciler) KindDisplayName 

func (r *SpamFilterReconciler) KindDisplayName() string

func (*SpamFilterReconciler) MapResourceToHttpRequests 

func (r *SpamFilterReconciler) MapResourceToHttpRequests(
	preconditionChecksResult *preconditionValidationResult,
	apiConfig ApiConfig,
	action apiAction,
	logger logd.Logger,
) *ResourceToRequestsResult

func (*SpamFilterReconciler) NotifyOperatorManagerJustBecameLeader 

func (r *SpamFilterReconciler) NotifyOperatorManagerJustBecameLeader(ctx context.Context, logger logd.Logger)

func (*SpamFilterReconciler) Reconcile 

func (r *SpamFilterReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*SpamFilterReconciler) RemoveDefaultApiConfigs 

func (r *SpamFilterReconciler) RemoveDefaultApiConfigs(_ context.Context, _ logd.Logger)

func (*SpamFilterReconciler) RemoveNamespacedApiConfigs 

func (r *SpamFilterReconciler) RemoveNamespacedApiConfigs(ctx context.Context, namespace string, logger logd.Logger)

func (*SpamFilterReconciler) RemoveSynchronizationEnabled 

func (r *SpamFilterReconciler) RemoveSynchronizationEnabled(_ string)

func (*SpamFilterReconciler) SetDefaultApiConfigs 

func (r *SpamFilterReconciler) SetDefaultApiConfigs(ctx context.Context, apiConfigs []ApiConfig, logger logd.Logger)

func (*SpamFilterReconciler) SetNamespacedApiConfigs 

func (r *SpamFilterReconciler) SetNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	updatedApiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*SpamFilterReconciler) SetSynchronizationEnabled 

func (r *SpamFilterReconciler) SetSynchronizationEnabled(
	_ context.Context,
	_ string,
	_ *dash0v1beta1.Dash0Monitoring,
	_ logd.Logger,
)

func (*SpamFilterReconciler) SetupWithManager 

func (r *SpamFilterReconciler) SetupWithManager(mgr manager.Manager) error

func (*SpamFilterReconciler) ShortName 

func (r *SpamFilterReconciler) ShortName() string

func (*SpamFilterReconciler) WriteSynchronizationResultToSynchronizedResource 

func (r *SpamFilterReconciler) WriteSynchronizationResultToSynchronizedResource(
	ctx context.Context,
	synchronizedResource client.Object,
	syncResults synchronizationResults,
	logger logd.Logger,
)

type SuccessfulSynchronizationResult 

type SuccessfulSynchronizationResult struct {
	ItemName string
	Labels   Dash0ApiObjectLabels
}

type SyntheticCheckReconciler 

type SyntheticCheckReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

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) ExtractIdFromResponseBody 

func (r *SyntheticCheckReconciler) ExtractIdFromResponseBody(
	responseBytes []byte,
	logger logd.Logger,
) (id string, err error)

func (*SyntheticCheckReconciler) GetDefaultApiConfigs 

func (r *SyntheticCheckReconciler) GetDefaultApiConfigs() []ApiConfig

func (*SyntheticCheckReconciler) GetNamespacedApiConfigs 

func (r *SyntheticCheckReconciler) GetNamespacedApiConfigs(namespace string) ([]ApiConfig, bool)

func (*SyntheticCheckReconciler) HttpClient 

func (r *SyntheticCheckReconciler) HttpClient() *http.Client

func (*SyntheticCheckReconciler) InitializeSelfMonitoringMetrics 

func (r *SyntheticCheckReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.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,
	apiConfig ApiConfig,
	action apiAction,
	logger logd.Logger,
) *ResourceToRequestsResult

func (*SyntheticCheckReconciler) NotifyOperatorManagerJustBecameLeader 

func (r *SyntheticCheckReconciler) NotifyOperatorManagerJustBecameLeader(ctx context.Context, logger logd.Logger)

func (*SyntheticCheckReconciler) Reconcile 

func (r *SyntheticCheckReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*SyntheticCheckReconciler) RemoveDefaultApiConfigs 

func (r *SyntheticCheckReconciler) RemoveDefaultApiConfigs(_ context.Context, _ logd.Logger)

func (*SyntheticCheckReconciler) RemoveNamespacedApiConfigs 

func (r *SyntheticCheckReconciler) RemoveNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	logger logd.Logger,
)

func (*SyntheticCheckReconciler) RemoveSynchronizationEnabled 

func (r *SyntheticCheckReconciler) RemoveSynchronizationEnabled(_ string)

func (*SyntheticCheckReconciler) SetDefaultApiConfigs 

func (r *SyntheticCheckReconciler) SetDefaultApiConfigs(
	ctx context.Context,
	apiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*SyntheticCheckReconciler) SetNamespacedApiConfigs 

func (r *SyntheticCheckReconciler) SetNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	updatedApiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*SyntheticCheckReconciler) SetSynchronizationEnabled 

func (r *SyntheticCheckReconciler) SetSynchronizationEnabled(
	_ context.Context,
	_ string,
	_ *dash0v1beta1.Dash0Monitoring,
	_ logd.Logger,
)

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,
	syncResults synchronizationResults,
	logger logd.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.
	FetchExistingResourceOriginsRequests(*preconditionValidationResult, ApiConfig) ([]*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(ApiConfig, []string, []string, logd.Logger) ([]WrappedApiRequest, 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,
		synchronizationResults synchronizationResults,
	) any
}

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 ValidatedApiConfigAndToken 

type ValidatedApiConfigAndToken struct {
	ApiConfig
}

ValidatedApiConfigAndToken ensures a complete API sync config where all fields have been validated, correctly formatted and (for optional values) defaults have been applied.

func NewValidatedApiConfigAndToken 

func NewValidatedApiConfigAndToken(endpoint string, dataset string, token string) *ValidatedApiConfigAndToken

type ViewReconciler 

type ViewReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

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) ExtractIdFromResponseBody 

func (r *ViewReconciler) ExtractIdFromResponseBody(
	responseBytes []byte,
	logger logd.Logger,
) (id string, err error)

func (*ViewReconciler) GetDefaultApiConfigs 

func (r *ViewReconciler) GetDefaultApiConfigs() []ApiConfig

func (*ViewReconciler) GetNamespacedApiConfigs 

func (r *ViewReconciler) GetNamespacedApiConfigs(namespace string) ([]ApiConfig, bool)

func (*ViewReconciler) HttpClient 

func (r *ViewReconciler) HttpClient() *http.Client

func (*ViewReconciler) InitializeSelfMonitoringMetrics 

func (r *ViewReconciler) InitializeSelfMonitoringMetrics(
	meter otelmetric.Meter,
	metricNamePrefix string,
	logger logd.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,
	apiConfig ApiConfig,
	action apiAction,
	logger logd.Logger,
) *ResourceToRequestsResult

func (*ViewReconciler) NotifyOperatorManagerJustBecameLeader 

func (r *ViewReconciler) NotifyOperatorManagerJustBecameLeader(ctx context.Context, logger logd.Logger)

func (*ViewReconciler) Reconcile 

func (r *ViewReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*ViewReconciler) RemoveDefaultApiConfigs 

func (r *ViewReconciler) RemoveDefaultApiConfigs(_ context.Context, _ logd.Logger)

func (*ViewReconciler) RemoveNamespacedApiConfigs 

func (r *ViewReconciler) RemoveNamespacedApiConfigs(ctx context.Context, namespace string, logger logd.Logger)

func (*ViewReconciler) RemoveSynchronizationEnabled 

func (r *ViewReconciler) RemoveSynchronizationEnabled(_ string)

func (*ViewReconciler) SetDefaultApiConfigs 

func (r *ViewReconciler) SetDefaultApiConfigs(ctx context.Context, apiConfigs []ApiConfig, logger logd.Logger)

func (*ViewReconciler) SetNamespacedApiConfigs 

func (r *ViewReconciler) SetNamespacedApiConfigs(
	ctx context.Context,
	namespace string,
	updatedApiConfigs []ApiConfig,
	logger logd.Logger,
)

func (*ViewReconciler) SetSynchronizationEnabled 

func (r *ViewReconciler) SetSynchronizationEnabled(
	_ context.Context,
	_ string,
	_ *dash0v1beta1.Dash0Monitoring,
	_ logd.Logger,
)

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,
	syncResults synchronizationResults,
	logger logd.Logger,
)

type WrappedApiRequest 

type WrappedApiRequest struct {
	Request   *http.Request
	ItemName  string
	Origin    string
	ApiConfig ApiConfig
}

WrappedApiRequest bundles an http.Request for the Dash0 API with additional metadata.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.