Struct OtlpHttpLogsClient 

pub struct OtlpHttpLogsClient { /* private fields */ }

HTTP client for querying the agent’s OTLP log store.

Sends GET requests to /api/otlp/logs/query, /api/otlp/labels, and /api/otlp/health endpoints on the agent daemon.

Implementations

impl OtlpHttpLogsClient

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

Create a new OTLP HTTP logs client.

Arguments

• base_url - The agent daemon URL (e.g., “http://localhost:3030”)

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

Trait Implementations

impl LogsClient for OtlpHttpLogsClient

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.