Struct JsonSource 

pub struct JsonSource { /* private fields */ }

A JSON/NDJSON file data source with schema inference and compression support.

Examples

use term_guard::sources::{JsonSource, JsonOptions, JsonFormatType};

// NDJSON file (auto-detected)
let source = JsonSource::new("data/events.ndjson")?;

// Regular JSON with custom options
let options = JsonOptions {
    format: JsonFormatType::Json,
    ..Default::default()
};
let source = JsonSource::with_options("data/config.json", options)?;

// Compressed NDJSON files with glob
let source = JsonSource::from_glob("logs/*.jsonl.gz").await?;

Implementations

impl JsonSource

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

Creates a new JSON source from a single file path.

pub fn with_options( path: impl Into<String>, options: JsonOptions, ) -> Result<Self>

Creates a new JSON source with custom options.

pub fn from_paths(paths: Vec<String>) -> Result<Self>

Creates a JSON source from multiple file paths.

pub async fn from_glob(pattern: impl Into<String>) -> Result<Self>

Creates a JSON source from a glob pattern.

pub async fn from_globs(patterns: Vec<String>) -> Result<Self>

Creates a JSON source from multiple glob patterns.

pub fn with_custom_options(self, options: JsonOptions) -> Self

Sets custom options for this JSON source.

Trait Implementations

impl Clone for JsonSource

fn clone(&self) -> JsonSource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DataSource for JsonSource

fn register_with_telemetry<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, table_name: &'life2 str, telemetry: Option<&'life3 Arc<TermTelemetry>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Registers this data source with telemetry support.

fn schema(&self) -> Option<&Arc<Schema>>

Returns the schema of this data source if known.

fn description(&self) -> String

Returns a human-readable description of this data source.

fn register<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, table_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Registers this data source with the given session context.

impl Debug for JsonSource

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

Formats the value using the given formatter.