Struct PrometheusClient 

pub struct PrometheusClient { /* private fields */ }

Client for querying Prometheus via its HTTP API.

Executes PromQL queries directly against the /api/v1/query_range endpoint. Uses reqwest for HTTP requests on both native (with tokio) and WASM (with wasm-bindgen-futures).

Example

use enya_client::{QueryManager, QueryRequest};
use enya_client::prometheus::PrometheusClient;

let client = PrometheusClient::new("http://localhost:9090");
let mut manager = QueryManager::new();

let request = QueryRequest::new("cpu_usage", "sum(env:prod) by (host)");
manager.execute(&client, request, &ctx);

Implementations

impl PrometheusClient

pub fn new(base_url: impl Into<String>) -> Self

Create a new Prometheus client.

Arguments

• base_url - The base URL of the Prometheus server (e.g., “http://localhost:9090”)

If no protocol is specified, http:// is assumed (Prometheus default).

Panics

On native, panics if called outside a tokio runtime context.

pub fn with_runtime(base_url: impl Into<String>, handle: Handle) -> Self

Create a new Prometheus client with an explicit runtime handle.

Use this when creating the client outside a tokio runtime context.

Trait Implementations

impl MetricsClient for PrometheusClient

fn query(&self, request: QueryRequest, ctx: &Context) -> Promise<QueryResult>

Execute a query request (non-blocking).

fn fetch_label_names(&self, ctx: &Context) -> Promise<LabelsResult>

Fetch all available label names (tag keys) from the backend.

fn fetch_label_values( &self, label: &str, ctx: &Context, ) -> Promise<LabelsResult>

Fetch all values for a specific label (tag key) from the backend.

fn fetch_metric_names(&self, ctx: &Context) -> Promise<LabelsResult>

Fetch all metric names from the backend.

fn fetch_metric_labels( &self, metric: &str, ctx: &Context, ) -> Promise<MetricLabelsResult>

Fetch labels for a specific metric.

fn backend_type(&self) -> &'static str

Get the backend type identifier (e.g., “prometheus”, “enya”).

fn health_check(&self, ctx: &Context) -> Promise<HealthCheckResult>

Check backend health and connectivity.