Struct LokiClient 

pub struct LokiClient { /* private fields */ }

Client for querying Loki via its HTTP API.

Executes LogQL queries against the /loki/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::logs::{LokiClient, LogsClient, LogsQuery};

let client = LokiClient::new("http://localhost:3100");
let query = LogsQuery::new(start_ns, end_ns)
    .with_label("app", "myservice");
let promise = client.query_logs(query, &ctx);

Implementations

impl LokiClient

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

Create a new Loki client.

Arguments

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

If no protocol is specified, http:// is assumed.

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 Loki client with an explicit runtime handle.

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

Trait Implementations

impl LogsClient for LokiClient

fn query_logs(&self, query: LogsQuery, ctx: &Context) -> Promise<LogsResult>

Execute a logs query (non-blocking).

fn fetch_streams(&self, ctx: &Context) -> Promise<StreamsResult>

Fetch all available log streams/labels from the backend.

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

Get the backend type identifier (e.g., “loki”, “elasticsearch”).

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

Check backend health and connectivity.