v1

package

Go to main page

Versions in this module

v0

v0.3.0

Jul 8, 2026

Changes in this version

+ const ConditionBackfill

+ type BackfillOperation struct

+ EndTime string

+ OperationID string

+ StartTime string

+ func (in *BackfillOperation) DeepCopy() *BackfillOperation

+ func (in *BackfillOperation) DeepCopyInto(out *BackfillOperation)

+ type BackfillPhase string

+ const BackfillPhaseCompleted

+ const BackfillPhaseFailed

+ const BackfillPhasePending

+ const BackfillPhaseRunning

+ type BackfillSpec struct

+ EndTime metav1.Time

+ MaxInFlight int

+ RequestID string

+ StartTime metav1.Time

+ func (in *BackfillSpec) DeepCopy() *BackfillSpec

+ func (in *BackfillSpec) DeepCopyInto(out *BackfillSpec)

+ type BackfillStatus struct

+ ActiveOperations []BackfillOperation

+ CompletedWindows int

+ Message string

+ NextWindowStart metav1.Time

+ ObservedGeneration int64

+ Phase BackfillPhase

+ RequestID string

+ RetriedWindows int

+ SubmittedWindows int

+ func (in *BackfillStatus) DeepCopy() *BackfillStatus

+ func (in *BackfillStatus) DeepCopyInto(out *BackfillStatus)

type FunctionSpec

+ AllDatabases bool

+ type ManagementCommandScope string

+ const ScopeAllDatabases

+ const ScopeCluster

+ const ScopeDatabase

type ManagementCommandSpec

+ Scope ManagementCommandScope

type SummaryRuleSpec

+ Backfill *BackfillSpec

type SummaryRuleStatus

+ Backfill *BackfillStatus

v0.2.0

Apr 7, 2026

Changes in this version

+ const AlerterConditionOwner

+ const AllDatabases

+ const CollectorConditionOwner

+ const ConditionCompleted

+ const ConditionCriteria

+ const ConditionFailed

+ const FunctionCriteriaMatch

+ const FunctionReconciled

+ const IngestorConditionOwner

+ const ManagementCommandConditionOwner

+ const MetricsExporterLastSuccessfulExecution

+ const MetricsExporterOwner

+ const ReasonCriteriaExpressionError

+ const ReasonCriteriaMatched

+ const ReasonCriteriaNotMatched

+ const SummaryRuleAsyncOperationPollInterval

+ const SummaryRuleDesiredOwnerAnnotation

+ const SummaryRuleLastSuccessfulExecution

+ const SummaryRuleOperationIdOwner

+ const SummaryRuleOwner

+ const SummaryRuleOwnerADXExporter

+ const SummaryRuleOwnerAnnotation

+ const SummaryRuleOwnerIngestor

+ func FormatClusterLabels(labels map[string]string) string

+ type ADXCluster struct

+ Spec ADXClusterSpec

+ Status ADXClusterStatus

+ func (in *ADXCluster) DeepCopy() *ADXCluster

+ func (in *ADXCluster) DeepCopyInto(out *ADXCluster)

+ func (in *ADXCluster) DeepCopyObject() runtime.Object

+ type ADXClusterDatabaseSpec struct

+ DatabaseName string

+ RetentionInDays int

+ RetentionPolicy string

+ TelemetryType DatabaseTelemetryType

+ func (in *ADXClusterDatabaseSpec) DeepCopy() *ADXClusterDatabaseSpec

+ func (in *ADXClusterDatabaseSpec) DeepCopyInto(out *ADXClusterDatabaseSpec)

+ type ADXClusterFederatedClusterSpec struct

+ Endpoint string

+ HeartbeatDatabase string

+ HeartbeatTable string

+ ManagedIdentityClientId string

+ func (in *ADXClusterFederatedClusterSpec) DeepCopy() *ADXClusterFederatedClusterSpec

+ func (in *ADXClusterFederatedClusterSpec) DeepCopyInto(out *ADXClusterFederatedClusterSpec)

+ type ADXClusterFederationSpec struct

+ FederationTargets []ADXClusterFederatedClusterSpec

+ HeartbeatDatabase *string

+ HeartbeatTTL *string

+ HeartbeatTable *string

+ Partitioning *map[string]string

+ func (in *ADXClusterFederationSpec) DeepCopy() *ADXClusterFederationSpec

+ func (in *ADXClusterFederationSpec) DeepCopyInto(out *ADXClusterFederationSpec)

+ type ADXClusterList struct

+ Items []ADXCluster

+ func (in *ADXClusterList) DeepCopy() *ADXClusterList

+ func (in *ADXClusterList) DeepCopyInto(out *ADXClusterList)

+ func (in *ADXClusterList) DeepCopyObject() runtime.Object

+ type ADXClusterProvisionSpec struct

+ AutoScale bool

+ AutoScaleMax int

+ AutoScaleMin int

+ Location string

+ ResourceGroup string

+ SkuName string

+ SubscriptionId string

+ Tier string

+ UserAssignedIdentities []string

+ func (in *ADXClusterProvisionSpec) DeepCopy() *ADXClusterProvisionSpec

+ func (in *ADXClusterProvisionSpec) DeepCopyInto(out *ADXClusterProvisionSpec)

+ type ADXClusterSpec struct

+ ClusterName string

+ CriteriaExpression string

+ Databases []ADXClusterDatabaseSpec

+ Endpoint string

+ Federation *ADXClusterFederationSpec

+ Provision *ADXClusterProvisionSpec

+ Role *ClusterRole

+ func (in *ADXClusterSpec) DeepCopy() *ADXClusterSpec

+ func (in *ADXClusterSpec) DeepCopyInto(out *ADXClusterSpec)

+ type ADXClusterStatus struct

+ AppliedProvisionState *AppliedProvisionState

+ Conditions []metav1.Condition

+ Endpoint string

+ func (in *ADXClusterStatus) DeepCopy() *ADXClusterStatus

+ func (in *ADXClusterStatus) DeepCopyInto(out *ADXClusterStatus)

type AlertRuleSpec

+ CriteriaExpression string

type AlertRuleStatus

+ Conditions []metav1.Condition

+ type Alerter struct

+ Spec AlerterSpec

+ Status AlerterStatus

+ func (in *Alerter) DeepCopy() *Alerter

+ func (in *Alerter) DeepCopyInto(out *Alerter)

+ func (in *Alerter) DeepCopyObject() runtime.Object

+ type AlerterList struct

+ Items []Alerter

+ func (in *AlerterList) DeepCopy() *AlerterList

+ func (in *AlerterList) DeepCopyInto(out *AlerterList)

+ func (in *AlerterList) DeepCopyObject() runtime.Object

+ type AlerterSpec struct

+ ADXClusterSelector *metav1.LabelSelector

+ AppliedProvisionState string

+ CriteriaExpression string

+ Image string

+ NotificationEndpoint string

+ func (in *AlerterSpec) DeepCopy() *AlerterSpec

+ func (in *AlerterSpec) DeepCopyInto(out *AlerterSpec)

+ func (s *AlerterSpec) LoadAppliedProvisioningState() (*AlerterSpec, error)

+ func (s *AlerterSpec) StoreAppliedProvisioningState() error

+ type AlerterStatus struct

+ Conditions []metav1.Condition

+ func (in *AlerterStatus) DeepCopy() *AlerterStatus

+ func (in *AlerterStatus) DeepCopyInto(out *AlerterStatus)

+ type AppliedProvisionState struct

+ SkuName string

+ Tier string

+ UserAssignedIdentities []string

+ func (in *AppliedProvisionState) DeepCopy() *AppliedProvisionState

+ func (in *AppliedProvisionState) DeepCopyInto(out *AppliedProvisionState)

+ type AsyncOperation struct

+ EndTime string

+ OperationId string

+ StartTime string

+ func (in *AsyncOperation) DeepCopy() *AsyncOperation

+ func (in *AsyncOperation) DeepCopyInto(out *AsyncOperation)

+ type ClusterRole string

+ const ClusterRoleFederated

+ const ClusterRolePartition

+ type Collector struct

+ Spec CollectorSpec

+ Status CollectorStatus

+ func (in *Collector) DeepCopy() *Collector

+ func (in *Collector) DeepCopyInto(out *Collector)

+ func (in *Collector) DeepCopyObject() runtime.Object

+ type CollectorList struct

+ Items []Collector

+ func (in *CollectorList) DeepCopy() *CollectorList

+ func (in *CollectorList) DeepCopyInto(out *CollectorList)

+ func (in *CollectorList) DeepCopyObject() runtime.Object

+ type CollectorSpec struct

+ CriteriaExpression string

+ Image string

+ IngestorEndpoint string

+ func (in *CollectorSpec) DeepCopy() *CollectorSpec

+ func (in *CollectorSpec) DeepCopyInto(out *CollectorSpec)

+ type CollectorStatus struct

+ Conditions []metav1.Condition

+ func (in *CollectorStatus) DeepCopy() *CollectorStatus

+ func (in *CollectorStatus) DeepCopyInto(out *CollectorStatus)

+ type ConditionedObject interface

+ GetCondition func() *metav1.Condition

+ SetCondition func(condition metav1.Condition)

+ type DatabaseTelemetryType string

+ const ADXClusterConditionOwner

+ const DatabaseTelemetryLogs

+ const DatabaseTelemetryMetrics

+ const DatabaseTelemetryTraces

type Function

+ func (f *Function) GetCondition() *metav1.Condition

+ func (f *Function) SetCondition(condition metav1.Condition)

+ func (f *Function) SetCriteriaMatchCondition(matched bool, expression string, err error, clusterLabels map[string]string)

+ func (f *Function) SetReconcileCondition(status metav1.ConditionStatus, reason, message string)

type FunctionSpec

+ AppliedEndpoint string

+ CriteriaExpression string

type FunctionStatus

+ Conditions []metav1.Condition

+ type Ingestor struct

+ Spec IngestorSpec

+ Status IngestorStatus

+ func (in *Ingestor) DeepCopy() *Ingestor

+ func (in *Ingestor) DeepCopyInto(out *Ingestor)

+ func (in *Ingestor) DeepCopyObject() runtime.Object

+ type IngestorList struct

+ Items []Ingestor

+ func (in *IngestorList) DeepCopy() *IngestorList

+ func (in *IngestorList) DeepCopyInto(out *IngestorList)

+ func (in *IngestorList) DeepCopyObject() runtime.Object

+ type IngestorSpec struct

+ ADXClusterSelector *metav1.LabelSelector

+ AppliedProvisionState string

+ CriteriaExpression string

+ Endpoint string

+ ExposeExternally bool

+ Image string

+ Replicas int32

+ func (in *IngestorSpec) DeepCopy() *IngestorSpec

+ func (in *IngestorSpec) DeepCopyInto(out *IngestorSpec)

+ func (s *IngestorSpec) LoadAppliedProvisioningState() (*IngestorSpec, error)

+ func (s *IngestorSpec) StoreAppliedProvisioningState() error

+ type IngestorStatus struct

+ Conditions []metav1.Condition

+ func (in *IngestorStatus) DeepCopy() *IngestorStatus

+ func (in *IngestorStatus) DeepCopyInto(out *IngestorStatus)

+ type ManagementCommand struct

+ Spec ManagementCommandSpec

+ Status ManagementCommandStatus

+ func (in *ManagementCommand) DeepCopy() *ManagementCommand

+ func (in *ManagementCommand) DeepCopyInto(out *ManagementCommand)

+ func (in *ManagementCommand) DeepCopyObject() runtime.Object

+ func (m *ManagementCommand) GetCondition() *metav1.Condition

+ func (m *ManagementCommand) SetCondition(c metav1.Condition)

+ type ManagementCommandList struct

+ Items []ManagementCommand

+ func (in *ManagementCommandList) DeepCopy() *ManagementCommandList

+ func (in *ManagementCommandList) DeepCopyInto(out *ManagementCommandList)

+ func (in *ManagementCommandList) DeepCopyObject() runtime.Object

+ type ManagementCommandSpec struct

+ Body string

+ CriteriaExpression string

+ Database string

+ func (in *ManagementCommandSpec) DeepCopy() *ManagementCommandSpec

+ func (in *ManagementCommandSpec) DeepCopyInto(out *ManagementCommandSpec)

+ type ManagementCommandStatus struct

+ Conditions []metav1.Condition

+ func (in *ManagementCommandStatus) DeepCopy() *ManagementCommandStatus

+ func (in *ManagementCommandStatus) DeepCopyInto(out *ManagementCommandStatus)

+ type MetricsExporter struct

+ Spec MetricsExporterSpec

+ Status MetricsExporterStatus

+ func (in *MetricsExporter) DeepCopy() *MetricsExporter

+ func (in *MetricsExporter) DeepCopyInto(out *MetricsExporter)

+ func (in *MetricsExporter) DeepCopyObject() runtime.Object

+ func (me *MetricsExporter) GetCondition() *metav1.Condition

+ func (me *MetricsExporter) GetLastExecutionTime() *time.Time

+ func (me *MetricsExporter) NextExecutionWindow(clk clock.Clock) (windowStartTime time.Time, windowEndTime time.Time)

+ func (me *MetricsExporter) SetCondition(condition metav1.Condition)

+ func (me *MetricsExporter) SetLastExecutionTime(endTime time.Time)

+ func (me *MetricsExporter) ShouldExecuteQuery(clk clock.Clock) bool

+ type MetricsExporterList struct

+ Items []MetricsExporter

+ func (in *MetricsExporterList) DeepCopy() *MetricsExporterList

+ func (in *MetricsExporterList) DeepCopyInto(out *MetricsExporterList)

+ func (in *MetricsExporterList) DeepCopyObject() runtime.Object

+ type MetricsExporterSpec struct

+ Body string

+ Criteria map[string][]string

+ CriteriaExpression string

+ Database string

+ Interval metav1.Duration

+ Transform TransformConfig

+ func (in *MetricsExporterSpec) DeepCopy() *MetricsExporterSpec

+ func (in *MetricsExporterSpec) DeepCopyInto(out *MetricsExporterSpec)

+ type MetricsExporterStatus struct

+ Conditions []metav1.Condition

+ func (in *MetricsExporterStatus) DeepCopy() *MetricsExporterStatus

+ func (in *MetricsExporterStatus) DeepCopyInto(out *MetricsExporterStatus)

+ type SummaryRule struct

+ Spec SummaryRuleSpec

+ Status SummaryRuleStatus

+ func (in *SummaryRule) DeepCopy() *SummaryRule

+ func (in *SummaryRule) DeepCopyInto(out *SummaryRule)

+ func (in *SummaryRule) DeepCopyObject() runtime.Object

+ func (s *SummaryRule) BackfillAsyncOperations(clk clock.Clock)

+ func (s *SummaryRule) GetAsyncOperations() []AsyncOperation

+ func (s *SummaryRule) GetCondition() *metav1.Condition

+ func (s *SummaryRule) GetLastExecutionTime() *time.Time

+ func (s *SummaryRule) NextExecutionWindow(clk clock.Clock) (windowStartTime time.Time, windowEndTime time.Time)

+ func (s *SummaryRule) RemoveAsyncOperation(operationId string)

+ func (s *SummaryRule) SetAsyncOperation(operation AsyncOperation)

+ func (s *SummaryRule) SetCondition(c metav1.Condition)

+ func (s *SummaryRule) SetLastExecutionTime(endTime time.Time)

+ func (s *SummaryRule) ShouldSubmitRule(clk clock.Clock) bool

+ type SummaryRuleList struct

+ Items []SummaryRule

+ func (in *SummaryRuleList) DeepCopy() *SummaryRuleList

+ func (in *SummaryRuleList) DeepCopyInto(out *SummaryRuleList)

+ func (in *SummaryRuleList) DeepCopyObject() runtime.Object

+ type SummaryRuleSpec struct

+ Body string

+ Criteria map[string][]string

+ CriteriaExpression string

+ Database string

+ IngestionDelay *metav1.Duration

+ Interval metav1.Duration

+ Name string

+ Table string

+ func (in *SummaryRuleSpec) DeepCopy() *SummaryRuleSpec

+ func (in *SummaryRuleSpec) DeepCopyInto(out *SummaryRuleSpec)

+ type SummaryRuleStatus struct

+ Conditions []metav1.Condition

+ func (in *SummaryRuleStatus) DeepCopy() *SummaryRuleStatus

+ func (in *SummaryRuleStatus) DeepCopyInto(out *SummaryRuleStatus)

+ type TransformConfig struct

+ DefaultMetricName string

+ LabelColumns []string

+ MetricNameColumn string

+ MetricNamePrefix string

+ TimestampColumn string

+ ValueColumns []string

+ func (in *TransformConfig) DeepCopy() *TransformConfig

+ func (in *TransformConfig) DeepCopyInto(out *TransformConfig)

v0.1.0

Jan 22, 2025

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type AlertRule struct

+ Spec AlertRuleSpec

+ Status AlertRuleStatus

+ func (in *AlertRule) DeepCopy() *AlertRule

+ func (in *AlertRule) DeepCopyInto(out *AlertRule)

+ func (in *AlertRule) DeepCopyObject() runtime.Object

+ type AlertRuleList struct

+ Items []AlertRule

+ func (in *AlertRuleList) DeepCopy() *AlertRuleList

+ func (in *AlertRuleList) DeepCopyInto(out *AlertRuleList)

+ func (in *AlertRuleList) DeepCopyObject() runtime.Object

+ type AlertRuleSpec struct

+ AutoMitigateAfter metav1.Duration

+ Criteria map[string][]string

+ Database string

+ Destination string

+ Interval metav1.Duration

+ Query string

+ func (a *AlertRuleSpec) UnmarshalJSON(data []byte) error

+ func (in *AlertRuleSpec) DeepCopy() *AlertRuleSpec

+ func (in *AlertRuleSpec) DeepCopyInto(out *AlertRuleSpec)

+ type AlertRuleStatus struct

+ LastAlertTime metav1.Time

+ LastQueryTime metav1.Time

+ Message string

+ Status string

+ func (in *AlertRuleStatus) DeepCopy() *AlertRuleStatus

+ func (in *AlertRuleStatus) DeepCopyInto(out *AlertRuleStatus)

+ type Function struct

+ Spec FunctionSpec

+ Status FunctionStatus

+ func (in *Function) DeepCopy() *Function

+ func (in *Function) DeepCopyInto(out *Function)

+ func (in *Function) DeepCopyObject() runtime.Object

+ type FunctionList struct

+ Items []Function

+ func (in *FunctionList) DeepCopy() *FunctionList

+ func (in *FunctionList) DeepCopyInto(out *FunctionList)

+ func (in *FunctionList) DeepCopyObject() runtime.Object

+ type FunctionSpec struct

+ Body string

+ Database string

+ Suspend *bool

+ func (in *FunctionSpec) DeepCopy() *FunctionSpec

+ func (in *FunctionSpec) DeepCopyInto(out *FunctionSpec)

+ type FunctionStatus struct

+ Error string

+ LastTimeReconciled metav1.Time

+ Message string

+ ObservedGeneration int64

+ Reason string

+ Status FunctionStatusEnum

+ func (in *FunctionStatus) DeepCopy() *FunctionStatus

+ func (in *FunctionStatus) DeepCopyInto(out *FunctionStatus)

+ type FunctionStatusEnum string

+ const Failed

+ const PermanentFailure

+ const Success

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL