Struct PluginDataSource 

pub struct PluginDataSource { /* private fields */ }

Wrapper around a plugin data source

Provides Rust-friendly access to plugin functionality including self-describing schema for LSP autocomplete and validation.

Implementations

impl PluginDataSource

pub fn new( name: String, vtable: &'static DataSourceVTable, config: &Value, ) -> Result<Self>

Create a new plugin data source instance

Arguments

• name - Plugin name
• vtable - Data source vtable (must be static)
• config - Configuration value (will be MessagePack encoded)

pub fn get_query_schema(&self) -> &ParsedQuerySchema

Get the query schema for LSP autocomplete and validation

pub fn get_output_schema(&self) -> &ParsedOutputSchema

Get the output schema for LSP autocomplete

pub fn name(&self) -> &str

Get the plugin name

pub fn validate_query(&self, query: &Value) -> Result<()>

Validate a query before execution

pub fn load(&self, query: &Value) -> Result<Value>

Load historical data

pub fn subscribe<F>(&self, query: &Value, callback: F) -> Result<u64>

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to streaming data

Arguments

• query - Query parameters
• callback - Called for each data point

Returns

Subscription ID (use to unsubscribe)

pub fn unsubscribe(&self, subscription_id: u64) -> Result<()>

Unsubscribe from streaming data

pub fn get_source_schema(&self, source_id: &str) -> Result<PluginSchema>

Query the schema for a specific data source.

This enables runtime schema discovery - the plugin returns what columns are available for a given source ID.

Arguments

• source_id - The source identifier (e.g., symbol, table name, device ID)

Returns

The plugin schema with column information

pub fn supports_schema_discovery(&self) -> bool

Check if this plugin supports schema discovery

pub fn supports_binary(&self) -> bool

Check if this plugin supports binary loading (ABI v2)

pub fn load_binary( &self, query: &Value, granularity: ProgressGranularity, progress_handle: Option<&ProgressHandle>, ) -> Result<ValueWord>

Load historical data in binary columnar format (ABI v2)

Trait Implementations

impl Drop for PluginDataSource

fn drop(&mut self)

Executes the destructor for this type.

impl Send for PluginDataSource

impl Sync for PluginDataSource