Skip to main content

LogsApi

Struct LogsApi 

Source
pub struct LogsApi<'a> { /* private fields */ }
Expand description

Logs API façade.

Implementations§

Source§

impl<'a> LogsApi<'a>

Source

pub fn new(client: &'a DatadogClient) -> Self

Wraps an existing DatadogClient for log operations.

Source

pub async fn search( &self, query: &str, from: &str, to: &str, limit: usize, sort: SortOrder, after: Option<&str>, ) -> Result<LogSearchResult>

Searches log events.

from and to are passed through to Datadog as strings. Datadog accepts ISO 8601 timestamps, epoch milliseconds, and relative shorthand like now-15m / now; callers are expected to convert CLI-level inputs into a form Datadog understands before calling.

Returns a single page only. When after is Some, Datadog resumes pagination at that cursor token (page.cursor in the request body). The next-page token is preserved on meta.page.after of the response so the caller (or LogsApi::search_all) can iterate.

limit is rejected client-side when it exceeds MAX_PAGE_LIMIT.

Source

pub async fn search_all( &self, query: &str, from: &str, to: &str, limit: usize, sort: SortOrder, ) -> Result<LogSearchResult>

Searches log events, auto-paginating via cursor as needed.

limit == 0 means “fetch every match up to HARD_CAP”. Any non-zero limit is upper-bounded by HARD_CAP to keep a single invocation from issuing more than 10k items’ worth of requests. Per-request page size is clamped to MAX_PAGE_LIMIT.

Termination follows cursor-pagination semantics: the loop stops when the response omits meta.page.after (Datadog signals “no more pages” only via the absent cursor — a short page on its own is not a terminator) or when cap items have been collected.

The returned envelope keeps the meta block from the last successful page so the response’s cursor reflects the iterator’s final position (typically None when the API is exhausted).

Trait Implementations§

Source§

impl<'a> Debug for LogsApi<'a>

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a> Freeze for LogsApi<'a>

§

impl<'a> !RefUnwindSafe for LogsApi<'a>

§

impl<'a> Send for LogsApi<'a>

§

impl<'a> Sync for LogsApi<'a>

§

impl<'a> Unpin for LogsApi<'a>

§

impl<'a> UnsafeUnpin for LogsApi<'a>

§

impl<'a> !UnwindSafe for LogsApi<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more