Struct QueryTimeRange 

pub struct QueryTimeRange { /* private fields */ }

A time range for querying journal entries with automatic alignment.

This type encapsulates:

• The original requested time boundaries
• The computed bucket duration based on the range
• The aligned boundaries for consistent indexing and querying

All alignment logic is handled internally, ensuring consistency between histogram computation, file indexing, and log queries.

Implementations

impl QueryTimeRange

pub fn new(start: u32, end: u32) -> Result<Self, EngineError>

Create a new query time range with automatic alignment.

The bucket duration is computed based on the range duration, and the boundaries are aligned to bucket boundaries:

• aligned_start rounds down to the nearest bucket boundary
• aligned_end rounds up to the nearest bucket boundary

Arguments

• start - Start time in seconds (inclusive)
• end - End time in seconds (exclusive)

Returns

• Ok(QueryTimeRange) if the range is valid
• Err(EngineError::InvalidTimeRange) if start >= end

Example

use journal_engine::QueryTimeRange;

let range = QueryTimeRange::new(100, 500).unwrap();
assert_eq!(range.requested_start(), 100);
assert_eq!(range.requested_end(), 500);
assert!(range.aligned_start() <= 100);
assert!(range.aligned_end() >= 500);

pub fn requested_start(&self) -> u32

Get the original requested start time (seconds).

pub fn requested_end(&self) -> u32

Get the original requested end time (seconds).

pub fn bucket_duration(&self) -> u32

Get the computed bucket duration (seconds).

This is used for file indexing to ensure all files are indexed with the same bucket size.

pub fn bucket_duration_seconds(&self) -> Seconds

Get the bucket duration as Seconds.

pub fn aligned_start(&self) -> u32

Get the aligned start time (seconds).

This is the start time rounded down to the nearest bucket boundary.

pub fn aligned_end(&self) -> u32

Get the aligned end time (seconds).

This is the end time rounded up to the nearest bucket boundary.

pub fn aligned_duration(&self) -> u32

Get the duration of the aligned range (seconds).

pub fn requested_duration(&self) -> u32

Get the duration of the requested range (seconds).

pub fn buckets(&self) -> impl Iterator<Item = (u32, u32)> + '_

Returns an iterator over the bucket time ranges.

Each bucket is a (start, end) tuple in seconds, where:

• start is inclusive
• end is exclusive
• end - start == bucket_duration

Example

use journal_engine::QueryTimeRange;

let range = QueryTimeRange::new(0, 1000).unwrap();
for (start, end) in range.buckets() {
    println!("Bucket: [{}, {})", start, end);
}

Trait Implementations

impl Clone for QueryTimeRange

fn clone(&self) -> QueryTimeRange

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for QueryTimeRange

impl Debug for QueryTimeRange

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

Formats the value using the given formatter.

impl Eq for QueryTimeRange

impl PartialEq for QueryTimeRange

fn eq(&self, other: &QueryTimeRange) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for QueryTimeRange