Versions in this module Expand all Collapse all v0 v0.2.0 Apr 7, 2026 Changes in this version + const ADXClusterCreatingReason + const ADXClusterWaitingReason + func SetClusterLabels(labels map[string]string) + type ADXClusterSchema struct + Database string + TableSchemas map[string]string + Tables []string + Views []string + type AdxReconciler struct + Scheme *runtime.Scheme + func (r *AdxReconciler) CheckStatus(ctx context.Context, cluster *adxmonv1.ADXCluster) (ctrl.Result, error) + func (r *AdxReconciler) CreateCluster(ctx context.Context, cluster *adxmonv1.ADXCluster) (ctrl.Result, error) + func (r *AdxReconciler) FederateClusters(ctx context.Context, cluster *adxmonv1.ADXCluster) (ctrl.Result, error) + func (r *AdxReconciler) HeartbeatFederatedClusters(ctx context.Context, cluster *adxmonv1.ADXCluster) (ctrl.Result, error) + func (r *AdxReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *AdxReconciler) SetupWithManager(mgr ctrl.Manager) error + func (r *AdxReconciler) UpdateCluster(ctx context.Context, cluster *adxmonv1.ADXCluster) (ctrl.Result, error) + type AlerterReconciler struct + Scheme *runtime.Scheme + func (r *AlerterReconciler) CreateAlerter(ctx context.Context, alerter *adxmonv1.Alerter) (ctrl.Result, error) + func (r *AlerterReconciler) IsReady(ctx context.Context, alerter *adxmonv1.Alerter) (ctrl.Result, error) + func (r *AlerterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *AlerterReconciler) ReconcileComponent(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *AlerterReconciler) SetupWithManager(mgr ctrl.Manager) error + type CollectorReconciler struct + Scheme *runtime.Scheme + func (r *CollectorReconciler) CreateCollector(ctx context.Context, collector *adxmonv1.Collector) (ctrl.Result, error) + func (r *CollectorReconciler) IsReady(ctx context.Context, collector *adxmonv1.Collector) (ctrl.Result, error) + func (r *CollectorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *CollectorReconciler) ReconcileComponent(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *CollectorReconciler) SetupWithManager(mgr ctrl.Manager) error + type DatabaseExistsRec struct + Count int64 + type DatabaseRec struct + DatabaseName string + type DatabaseSchemaRec struct + ColumnName string + ColumnType string + TableName string + type FederationState struct + DBSet map[string]struct{} + DBTableEndpoints map[string]map[string][]string + EndpointCount int + ParseErrors []string + SpokeDBEndpoints map[string][]string + func NewFederationState() *FederationState + type FunctionKind struct + Kind string + type FunctionRec struct + Body string + DocString string + Folder string + Name string + Parameters string + type FunctionSchemaRec struct + Kind string + OutputColumns json.RawMessage + type HeartbeatRow struct + ClusterEndpoint string + Schema json.RawMessage + Timestamp time.Time + type IngestorReconciler struct + Scheme *runtime.Scheme + func (r *IngestorReconciler) CreateIngestor(ctx context.Context, ingestor *adxmonv1.Ingestor) (ctrl.Result, error) + func (r *IngestorReconciler) IsReady(ctx context.Context, ingestor *adxmonv1.Ingestor) (ctrl.Result, error) + func (r *IngestorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *IngestorReconciler) ReconcileComponent(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *IngestorReconciler) SetupWithManager(mgr ctrl.Manager) error + type OutputColumn struct + CslType string + Name string + type TableExists struct + Count int64 + type TableRec struct + TableName string