v1

type ADXCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ADXClusterSpec   `json:"spec,omitempty"`
	Status ADXClusterStatus `json:"status,omitempty"`
}

type ADXClusterDatabaseSpec struct {
	//+kubebuilder:validation:Required
	//+kubebuilder:validation:Pattern=^[a-zA-Z0-9_]+$
	//+kubebuilder:validation:MaxLength=64
	//+kubebuilder:validation:MinLength=1
	// ADX valid database name, required
	DatabaseName string `json:"databaseName"`
	//+kubebuilder:validation:Optional
	//+kubebuilder:default=30
	// default 30, optional
	RetentionInDays int `json:"retentionInDays,omitempty"`
	//+kubebuilder:validation:Optional
	// ADX retention policy, optional
	RetentionPolicy string `json:"retentionPolicy,omitempty"`
	//+kubebuilder:validation:Required
	//+kubebuilder:validation:Enum=Metrics;Logs;Traces
	// TelemetryType: Required
	TelemetryType DatabaseTelemetryType `json:"telemetryType"`
}

type ADXClusterFederatedClusterSpec struct {
	//+kubebuilder:validation:Required
	// Endpoint is the URI of the federated ADX cluster. Example: "https://mycluster.kusto.windows.net"
	Endpoint string `json:"endpoint"`

	//+kubebuilder:validation:Required
	//+kubebuilder:validation:Pattern=^[a-zA-Z0-9_]+$
	HeartbeatDatabase string `json:"heartbeatDatabase"`

	//+kubebuilder:validation:Required
	//+kubebuilder:validation:Pattern=^[a-zA-Z0-9_]+$
	HeartbeatTable string `json:"heartbeatTable"`

	//+kubebuilder:validation:Required
	// Used for writing logs to the federated cluster.
	ManagedIdentityClientId string `json:"managedIdentityClientId"`
}

type ADXClusterFederationSpec struct {

	//+kubebuilder:validation:Optional
	// If role is "Partition", specifies the Federated cluster(s) details for heartbeating.
	FederationTargets []ADXClusterFederatedClusterSpec `json:"federatedTargets,omitempty"`

	//+kubebuilder:validation:Optional
	// If role is "Partition", specifies the ADX cluster's partition details.  Open-ended map/object for partitioning metadata (geo, location, tenant, etc.).
	Partitioning *map[string]string `json:"partitioning,omitempty"`

	//+kubebuilder:validation:Optional
	// If role is "Federated", specifies the ADX cluster's heartbeat database.
	//+kubebuilder:validation:Pattern=^[a-zA-Z0-9_]+$
	HeartbeatDatabase *string `json:"heartbeatDatabase,omitempty"`

	//+kubebuilder:validation:Optional
	// If role is "Federated", specifies the ADX cluster's heartbeat table.
	//+kubebuilder:validation:Pattern=^[a-zA-Z0-9_]+$
	HeartbeatTable *string `json:"heartbeatTable,omitempty"`

	//+kubebuilder:validation:Optional
	//+kubebuilder:default="1h"
	//+kubebuilder:validation:Pattern=^(\d+h)?(\d+m)?(\d+s)?$
	// If role is "Federated", specifies the ADX cluster's heartbeat table TTL.
	HeartbeatTTL *string `json:"heartbeatTTL,omitempty"`
}

type ADXClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ADXCluster `json:"items"`
}

type ADXClusterProvisionSpec struct {
	//+kubebuilder:validation:Optional
	// SubscriptionId is the Azure subscription ID to use for provisioning. When the operator manages provisioning this value must be supplied explicitly; it is no longer auto-detected or defaulted by the controller.
	SubscriptionId string `json:"subscriptionId,omitempty"`
	//+kubebuilder:validation:Optional
	// ResourceGroup is the Azure resource group for the ADX cluster. This must be provided when provisioning is enabled; the operator no longer mutates the spec to fill this value.
	ResourceGroup string `json:"resourceGroup,omitempty"`
	//+kubebuilder:validation:Optional
	// Location is the Azure region for the ADX cluster (e.g., "eastus2"). Required when the operator provisions the cluster and must be set explicitly by the user.
	Location string `json:"location,omitempty"`
	//+kubebuilder:validation:Optional
	// SkuName is the Azure SKU for the ADX cluster (e.g., "Standard_L8as_v3"). Required when provisioning is enabled; defaults are not applied automatically by the controller.
	SkuName string `json:"skuName,omitempty"`
	//+kubebuilder:validation:Optional
	// Tier is the Azure ADX tier (e.g., "Standard"). Required when provisioning is enabled; the operator no longer assigns a default.
	Tier string `json:"tier,omitempty"`
	//+kubebuilder:validation:Optional
	// UserAssignedIdentities is a list of MSIs that can be attached to the cluster. They should be resource-ids of the form
	// /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ManagedIdentity/userAssignedIdentities/{identityName}
	UserAssignedIdentities []string `json:"userAssignedIdentities,omitempty"`
	//+kubebuilder:validation:Optional
	////+kubebuilder:default=false
	// AutoScale indicates whether to enable auto-scaling for the ADX cluster. Optional. Defaults to false if not specified.
	AutoScale bool `json:"autoScale,omitempty"`
	//+kubebuilder:validation:Optional
	//+kubebuilder:default=10
	// AutoScaleMax is the maximum number of nodes for auto-scaling. Optional. Defaults to 10 if not specified.
	AutoScaleMax int `json:"autoScaleMax,omitempty"`
	//+kubebuilder:validation:Optional
	//+kubebuilder:default=2
	// AutoScaleMin is the minimum number of nodes for auto-scaling. Optional. Defaults to 2 if not specified.
	AutoScaleMin int `json:"autoScaleMin,omitempty"`
}

type ADXClusterSpec struct {
	//+kubebuilder:validation:Required
	//+kubebuilder:validation:Pattern=^[a-zA-Z0-9-]+$
	//+kubebuilder:validation:MaxLength=100
	// ClusterName is the unique, valid name for the ADX cluster. Must match ^[a-zA-Z0-9-]+$ and be at most 100 characters. Used for resource identification and naming in Azure.
	ClusterName string `json:"clusterName"`

	//+kubebuilder:validation:Format=uri
	// Endpoint is the URI of an existing ADX cluster. When set, the controller treats the cluster as bring-your-own (no Azure provisioning is attempted). Example: "https://mycluster.kusto.windows.net"
	Endpoint string `json:"endpoint,omitempty"`

	//+kubebuilder:validation:Optional
	// Databases is an array of ADXClusterDatabaseSpec objects. Each object defines a database to be created in the ADX cluster. If not specified, no databases will be created.
	Databases []ADXClusterDatabaseSpec `json:"databases,omitempty"`

	//+kubebuilder:validation:Optional
	// Provision contains Azure provisioning details for the ADX cluster. Reconciliation of Azure resources only occurs when this section is provided. If omitted, the operator skips provisioning and treats the cluster as bring-your-own.
	Provision *ADXClusterProvisionSpec `json:"provision,omitempty"`

	//+kubebuilder:validation:Optional
	//+kubebuilder:validation:Enum=Partition;Federated
	// Role specifies the cluster's role: "Partition" (default, for data-holding clusters) or "Federated" (for the central federating cluster).
	Role *ClusterRole `json:"role,omitempty"`

	//+kubebuilder:validation:Optional
	// Supports cluster partitioning. Only relevant if Role is set.
	Federation *ADXClusterFederationSpec `json:"federation,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression evaluated against
	// operator cluster labels (region, environment, cloud, and any --cluster-labels key/value pairs).
	// Every label is exposed as a string variable that can be referenced directly, for example:
	//
	//   criteriaExpression: "region in ['eastus','westus'] && environment == 'prod'"
	//
	// Semantics:
	//   * Empty / omitted expression => the ADXCluster always reconciles.
	//   * When specified, the expression must evaluate to true for reconciliation; false skips quietly.
	//   * CEL parse, type-check, or evaluation errors are surfaced via status and block reconciliation
	//     until corrected.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type ADXClusterStatus struct {
	//+kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
	//+kubebuilder:validation:Optional
	// Endpoint reflects the observed Kusto endpoint when the controller manages provisioning, or mirrors spec.endpoint when running in BYO mode.
	Endpoint string `json:"endpoint,omitempty"`
	//+kubebuilder:validation:Optional
	// AppliedProvisionState captures the last Azure provisioning state reconciled by the controller.
	AppliedProvisionState *AppliedProvisionState `json:"appliedProvisionState,omitempty"`
}

type AlertRule struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AlertRuleSpec   `json:"spec,omitempty"`
	Status AlertRuleStatus `json:"status,omitempty"`
}

type AlertRuleList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AlertRule `json:"items"`
}

type AlertRuleSpec struct {
	Database string `json:"database,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self == ” || duration(self) > duration('0s')",message="interval must be a valid positive duration"
	Interval metav1.Duration `json:"interval,omitempty"`
	Query    string          `json:"query,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self == ” || duration(self) >= duration('0s')",message="autoMitigateAfter must be a valid duration"
	AutoMitigateAfter metav1.Duration `json:"autoMitigateAfter,omitempty"`
	Destination       string          `json:"destination,omitempty"`

	// Key/Value pairs used to determine when an alert can execute.  If empty, always execute.  Keys and values
	// are deployment specific and configured on alerter instances.  For example, an alerter instance may be
	// started with `--tag cloud=public`. If an AlertRule has `criteria: {cloud: public}`, then the rule will only
	// execute on that alerter. Any key/values pairs must match (case-insensitive) for the rule to execute.
	Criteria map[string][]string `json:"criteria,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression that provides a richer way
	// to determine if the alert should execute. The CEL environment is dynamically constructed from the alerter's
	// execution context (cloud, region, and any --tag key/value pairs). All variables are exposed as strings and
	// can be referenced directly by their tag name. For example:
	//
	//   criteriaExpression: "cloud == 'public' && region in ['eastus','westus'] && env == 'prod'"
	//
	// Execution semantics:
	//   * If neither criteria nor criteriaExpression are specified, the rule always executes.
	//   * If only criteriaExpression is specified, it must evaluate to true for the rule to execute.
	//   * If only criteria (map) is specified, existing matching behavior (any key/value match) applies.
	//   * If both are specified, the rule executes when BOTH the criteria map matches AND the expression evaluates to true.
	//
	// An invalid expression (parse or type check error) will treated as an error and prevent the rule from executing.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type AlertRuleStatus struct {
	Status        string      `json:"status,omitempty"`
	Message       string      `json:"message,omitempty"`
	LastQueryTime metav1.Time `json:"lastQueryTime,omitempty"`
	LastAlertTime metav1.Time `json:"lastAlertTime,omitempty"`
	// Conditions provide standardized status signaling. Controllers may
	// set shared conditions defined in conditions.go such as ConditionCriteria
	// to reflect evaluation of Spec.Criteria / Spec.CriteriaExpression.
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type Alerter struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AlerterSpec   `json:"spec,omitempty"`
	Status AlerterStatus `json:"status,omitempty"`
}

type AlerterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Alerter `json:"items"`
}

type AlerterSpec struct {
	//+kubebuilder:validation:Optional
	// Image is the container image to use for the alerter component. Optional; if omitted, a default image will be used.
	Image string `json:"image,omitempty"`

	//+kubebuilder:validation:Required
	//+kubebuilder:validation:Format=uri
	// NotificationEndpoint is the URI where alert notifications will be sent. This field is required.
	NotificationEndpoint string `json:"notificationEndpoint"`

	//+kubebuilder:validation:Required
	// ADXClusterSelector is a label selector used to select the ADXCluster CRDs this alerter should target. This field is required.
	ADXClusterSelector *metav1.LabelSelector `json:"adxClusterSelector"`

	// AppliedProvisionState is a JSON-serialized snapshot of the CRD
	// as last applied by the operator. This is set by the operator and is read-only for users.
	AppliedProvisionState string `json:"appliedProvisionState,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression evaluated against
	// operator cluster labels (region, environment, cloud, and any --cluster-labels key/value pairs).
	// All labels are exposed as string variables that can be referenced directly. Example:
	//
	//   criteriaExpression: "region == 'eastus' && environment == 'prod'"
	//
	// Semantics:
	//   * Empty / omitted expression => the Alerter always reconciles.
	//   * When specified, the expression must evaluate to true for reconciliation; false skips quietly.
	//   * CEL parse, type-check, or evaluation errors surface via status and block reconciliation until
	//     corrected.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type AlerterStatus struct {
	//+kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type AppliedProvisionState struct {
	SkuName                string   `json:"skuName,omitempty"`
	Tier                   string   `json:"tier,omitempty"`
	UserAssignedIdentities []string `json:"userAssignedIdentities,omitempty"`
}

type AsyncOperation struct {
	OperationId string `json:"operationId"`
	StartTime   string `json:"startTime"`
	EndTime     string `json:"endTime"`
}

type ClusterRole string

type Collector struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CollectorSpec   `json:"spec,omitempty"`
	Status CollectorStatus `json:"status,omitempty"`
}

type CollectorList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Collector `json:"items"`
}

type CollectorSpec struct {
	//+kubebuilder:validation:Optional
	// Image is the container image to use for the collector component. Optional; if omitted, a default image will be used.
	Image string `json:"image,omitempty"`

	//+kubebuilder:validation:Optional
	//+kubebuilder:validation:Format=uri
	// IngestorEndpoint is the URI endpoint for the ingestor service that this collector should send data to. Optional; if omitted, the operator will configure it automatically.
	IngestorEndpoint string `json:"ingestorEndpoint,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression evaluated against
	// operator cluster labels (region, environment, cloud, and any --cluster-labels key/value pairs).
	// All labels are exposed as string variables. Example:
	//
	//   criteriaExpression: "environment == 'prod' && region == 'eastus'"
	//
	// Semantics:
	//   * Empty / omitted expression => the Collector always reconciles.
	//   * When specified, the expression must evaluate to true for reconciliation; false skips quietly.
	//   * CEL parse, type-check, or evaluation errors surface via status and block reconciliation until
	//     corrected.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type CollectorStatus struct {
	//+kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type ConditionedObject interface {
	GetCondition() *metav1.Condition
	SetCondition(condition metav1.Condition)
}

type DatabaseTelemetryType string

type Function struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FunctionSpec   `json:"spec,omitempty"`
	Status FunctionStatus `json:"status,omitempty"`
}

type FunctionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Function `json:"items"`
}

type FunctionSpec struct {
	//+kubebuilder:validation:Optional
	// This flag tells the controller to suspend subsequent executions, it does
	// not apply to already started executions.  Defaults to false.
	Suspend *bool `json:"suspend,omitempty"`

	//+kubebuilder:validation:Required
	// Database is the name of the database in which the function will be created
	Database string `json:"database"`

	//+kubebuilder:validation:Required
	// Body is the KQL body of the function
	Body string `json:"body"`

	//+kubebuilder:validation:Optional
	// AppliedEndpoint is a JSON-serialized of the endpoints that the function
	// is applied to. This is set by the operator and is read-only for users.
	AppliedEndpoint string `json:"appliedEndpoint,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression evaluated against
	// operator cluster labels (region, environment, cloud, and any --cluster-labels key/value pairs).
	// Every label is exposed as a string variable. Example:
	//
	//   criteriaExpression: "environment == 'prod' && region in ['eastus','westus']"
	//
	// Semantics:
	//   * Empty / omitted expression => the Function always reconciles.
	//   * When specified, the expression must evaluate to true for reconciliation; false skips quietly.
	//   * CEL parse, type-check, or evaluation errors surface via status and block reconciliation until
	//     corrected.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type FunctionStatus struct {
	// ObservedGeneration is the most recent generation observed for this Function
	ObservedGeneration int64 `json:"observedGeneration"`
	// LastTimeReconciled is the last time the Function was reconciled
	LastTimeReconciled metav1.Time `json:"lastTimeReconciled"`
	// Message is a human-readable message indicating details about the Function
	Message string `json:"message,omitempty"`
	// Reason is a string that communicates the reason for a transition
	Reason string `json:"reason,omitempty"`
	// Status is an enum that represents the status of the Function
	Status FunctionStatusEnum `json:"status"`
	// Error is a string that communicates any error message if one exists
	Error string `json:"error,omitempty"`
	// Conditions conveys detailed reconciliation state in a Kubernetes-native format.
	// Controllers set FunctionCriteriaMatch to surface criteria gating decisions and
	// FunctionReconciled to report the outcome of the most recent reconciliation attempt.
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type FunctionStatusEnum string

type Ingestor struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   IngestorSpec   `json:"spec,omitempty"`
	Status IngestorStatus `json:"status,omitempty"`
}

type IngestorList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Ingestor `json:"items"`
}

type IngestorSpec struct {
	//+kubebuilder:validation:Optional
	// Image is the container image to use for the ingestor component. Optional; if omitted, a default image will be used.
	Image string `json:"image,omitempty"`

	//+kubebuilder:validation:Optional
	//+kubebuilder:default=1
	// Replicas is the number of ingestor replicas to run. Optional; defaults to 1 if omitted.
	Replicas int32 `json:"replicas,omitempty"`

	//+kubebuilder:validation:Optional
	// Endpoint is the endpoint to use for the ingestor. If running in a cluster, this should be the service name; otherwise, the operator will generate an endpoint. Optional.
	Endpoint string `json:"endpoint,omitempty"`

	//+kubebuilder:validation:Optional
	//+kubebuilder:default=false
	// ExposeExternally indicates if the ingestor should be exposed externally as reflected in the Endpoint. Optional; defaults to false.
	ExposeExternally bool `json:"exposeExternally,omitempty"`

	//+kubebuilder:validation:Required
	// ADXClusterSelector is a label selector used to select the ADXCluster CRDs this ingestor should target. This field is required.
	ADXClusterSelector *metav1.LabelSelector `json:"adxClusterSelector"`

	// AppliedProvisionState is a JSON-serialized snapshot of the CRD
	// as last applied by the operator. This is set by the operator and is read-only for users.
	AppliedProvisionState string `json:"appliedProvisionState,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression evaluated against
	// operator cluster labels (region, environment, cloud, and any --cluster-labels key/value pairs).
	// All labels are exposed as string variables. Example:
	//
	//   criteriaExpression: "environment == 'prod' && region == 'eastus'"
	//
	// Semantics:
	//   * Empty / omitted expression => the Ingestor always reconciles.
	//   * When specified, the expression must evaluate to true for reconciliation; false skips quietly.
	//   * CEL parse, type-check, or evaluation errors surface via status and block reconciliation until
	//     corrected.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type IngestorStatus struct {
	//+kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type ManagementCommand struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ManagementCommandSpec   `json:"spec,omitempty"`
	Status ManagementCommandStatus `json:"status,omitempty"`
}

type ManagementCommandList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ManagementCommand `json:"items"`
}

type ManagementCommandSpec struct {

	// Database is the target database for a management command. Not all management commands
	// are database specific.
	// +kubebuilder:validation:Optional
	Database string `json:"database,omitempty"`

	// Body is the management command to execute
	Body string `json:"body"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression evaluated against
	// operator / ingestor cluster labels (region, environment, cloud, and any --cluster-labels key/value
	// pairs). All labels are exposed as string variables. Example:
	//
	//   criteriaExpression: "environment == 'prod' && region == 'eastus'"
	//
	// Semantics:
	//   * Empty / omitted expression => the ManagementCommand always executes when selected.
	//   * When specified, the expression must evaluate to true; false skips execution.
	//   * CEL parse, type-check, or evaluation errors surface via status and block execution until
	//     corrected.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type ManagementCommandStatus struct {

	// Conditions is a list of conditions that apply to the Function
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type MetricsExporter struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   MetricsExporterSpec   `json:"spec,omitempty"`
	Status MetricsExporterStatus `json:"status,omitempty"`
}

type MetricsExporterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []MetricsExporter `json:"items"`
}

type MetricsExporterSpec struct {
	// Database is the name of the database to query
	Database string `json:"database"`

	// Body is the KQL query to execute
	Body string `json:"body"`

	// Interval defines how often to execute the query and refresh metrics
	Interval metav1.Duration `json:"interval"`

	// Transform defines how to convert query results to metrics
	Transform TransformConfig `json:"transform"`

	// Criteria for cluster-based execution selection (same pattern as SummaryRule)
	// Key/Value pairs used to determine when a metrics exporter can execute. If empty, always execute. Keys and values
	// are deployment specific and configured on adxexporter instances. For example, an adxexporter instance may be
	// started with `--cluster-labels=region=eastus,environment=production`. If a MetricsExporter has `criteria: {region: [eastus], environment: [production]}`, then the rule will only
	// execute on that adxexporter. Any key/values pairs must match (case-insensitive) for the rule to execute.
	Criteria map[string][]string `json:"criteria,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression that provides a richer way
	// to determine if the metrics exporter should execute. The CEL environment is dynamically constructed from the
	// exporter's cluster labels (e.g. region, cloud, environment, and any --cluster-labels key/value pairs). All variables
	// are exposed as strings and can be referenced directly by their label name. For example:
	//
	//   criteriaExpression: "region in ['eastus','westus'] && environment == 'prod'"
	//
	// Execution semantics mirror AlertRule:
	//   * If neither criteria nor criteriaExpression are specified, the exporter always executes.
	//   * If only criteriaExpression is specified, it must evaluate to true for execution.
	//   * If only criteria is specified, existing matching behavior (any key/value match) applies.
	//   * If both are specified, BOTH must match (criteria map match AND expression true).
	//
	// An invalid expression (parse or type check error) will be treated as an error and prevent execution.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type MetricsExporterStatus struct {
	// Conditions is an array of current observed MetricsExporter conditions.
	// Controllers set at minimum the owner condition (MetricsExporterOwner) and may also
	// use shared conditions defined in conditions.go: ConditionCriteria, ConditionCompleted, ConditionFailed.
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type SummaryRule struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SummaryRuleSpec   `json:"spec,omitempty"`
	Status SummaryRuleStatus `json:"status,omitempty"`
}

type SummaryRuleList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []SummaryRule `json:"items"`
}

type SummaryRuleSpec struct {
	// Database is the name of the database in which the function will be created
	Database string `json:"database"`
	// Table is rule output destination
	Table string `json:"table"`
	// Name is the name of the rule (deprecated and not used - use `metadata.name` instead)
	Name string `json:"name,omitempty"`
	// Body is the KQL body of the function
	Body string `json:"body"`
	// Interval is the cadence at which the rule will be executed
	// +kubebuilder:validation:XValidation:rule="duration(self) > duration('0s')",message="interval must be a valid positive duration"
	Interval metav1.Duration `json:"interval"`
	// IngestionDelay is subtracted from the execution window start and end times to account
	// for data ingestion latency, ensuring the query only processes fully ingested data.
	// NOTE: Current implementation also subtracts this delay from the "now" used to decide
	// whether an interval has elapsed (i.e. scheduling readiness). This effectively lengthens
	// wall‑clock spacing between executions to Interval + IngestionDelay. If you intend only
	// to shift the processed window but keep wall‑clock cadence at Interval, this behavior
	// will be adjusted in a future release.
	// +optional
	// +kubebuilder:validation:XValidation:rule="self == ” || duration(self) >= duration('0s')",message="ingestionDelay must be a valid duration"
	IngestionDelay *metav1.Duration `json:"ingestionDelay,omitempty"`

	// Key/Value pairs used to determine when a summary rule can execute. If empty, always execute. Keys and values
	// are deployment specific and configured on ingestor instances. For example, an ingestor instance may be
	// started with `--cluster-labels=region=eastus`. If a SummaryRule has `criteria: {region: [eastus]}`, then the rule will only
	// execute on that ingestor. Any key/values pairs must match (case-insensitive) for the rule to execute.
	Criteria map[string][]string `json:"criteria,omitempty"`

	// CriteriaExpression is an optional CEL (Common Expression Language) expression that provides a richer way
	// to determine if the summary rule should execute. The CEL environment is dynamically constructed from the
	// ingestor's cluster labels (e.g. region, cloud, and any --cluster-labels key/value pairs). All variables are
	// exposed as strings and can be referenced directly by their label name. For example:
	//
	//   criteriaExpression: "region in ['eastus','westus'] && environment == 'prod'"
	//
	// Execution semantics:
	//   * If neither criteria nor criteriaExpression are specified, the rule always executes.
	//   * If only criteriaExpression is specified, it must evaluate to true for the rule to execute.
	//   * If only criteria (map) is specified, existing matching behavior (any key/value match) applies.
	//   * If both are specified, the rule executes when BOTH the criteria map matches AND the expression evaluates to true.
	//
	// An invalid expression (parse or type check error) will be treated as an error and prevent the rule from executing.
	CriteriaExpression string `json:"criteriaExpression,omitempty"`
}

type SummaryRuleStatus struct {
	// Conditions is an array of current observed SummaryRule conditions.
	// SummaryRule controllers set at minimum the owner condition (SummaryRuleOwner) and may also
	// use shared conditions defined in conditions.go: ConditionCriteria, ConditionCompleted, ConditionFailed.
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type TransformConfig struct {
	// MetricNameColumn specifies which column contains the metric name
	MetricNameColumn string `json:"metricNameColumn,omitempty"`

	// MetricNamePrefix provides optional team/project namespacing for all metrics
	MetricNamePrefix string `json:"metricNamePrefix,omitempty"`

	// ValueColumns specifies columns to use as metric values
	ValueColumns []string `json:"valueColumns"`

	// TimestampColumn specifies which column contains the timestamp
	TimestampColumn string `json:"timestampColumn"`

	// LabelColumns specifies columns to use as metric labels
	LabelColumns []string `json:"labelColumns,omitempty"`

	// DefaultMetricName provides a fallback if MetricNameColumn is not specified
	DefaultMetricName string `json:"defaultMetricName,omitempty"`
}