adxexporter

type AsyncOperationStatus struct {
	OperationId   string    `kusto:"OperationId"`
	LastUpdatedOn time.Time `kusto:"LastUpdatedOn"`
	State         string    `kusto:"State"`
	ShouldRetry   float64   `kusto:"ShouldRetry"`
	Status        string    `kusto:"Status"`
}

type KustoClient struct {
	// contains filtered or unexported fields
}

type KustoExecutor interface {
	// Database returns the target database name
	Database() string
	// Endpoint returns the Kusto cluster endpoint
	Endpoint() string
	// Query executes a KQL query and returns the results
	Query(ctx context.Context, query kusto.Statement, options ...kusto.QueryOption) (*kusto.RowIterator, error)
	// Mgmt executes a Kusto management command (dot-command)
	Mgmt(ctx context.Context, query kusto.Statement, options ...kusto.MgmtOption) (*kusto.RowIterator, error)
}

type MetricsExporterReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	// Configuration
	ClusterLabels         map[string]string
	KustoClusters         map[string]string // database name -> endpoint URL
	OTLPEndpoint          string
	AddResourceAttributes map[string]string // Additional OTLP resource attributes (merged with ClusterLabels)
	MetricNamePrefix      string            // Global prefix prepended to all metric names (combined with CRD prefix)
	EnableMetricsEndpoint bool              // Deprecated: kept for backward compatibility, not used with OTLP push
	MetricsPort           string            // Deprecated: kept for backward compatibility
	MetricsPath           string            // Deprecated: kept for backward compatibility

	// Query execution components
	QueryExecutors map[string]*QueryExecutor // keyed by database name
	Clock          clock.Clock

	// OTLP push client for metrics delivery
	OtlpExporter *export.PromToOtlpExporter
}

type QueryExecutor struct {
	// contains filtered or unexported fields
}

type QueryResult struct {
	Rows     []map[string]interface{}
	Error    error
	Duration time.Duration
}

type SummaryRuleReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	// Configuration
	ClusterLabels map[string]string
	KustoClusters map[string]string // database name -> endpoint URL

	KustoExecutors map[string]KustoExecutor // per-database Kusto clients supporting Query and Mgmt
	Clock          clock.Clock
}