pub struct MockConnector { /* private fields */ }Expand description
Mock connector for testing with deterministic in-memory data
Implementations§
Source§impl MockConnector
impl MockConnector
Sourcepub fn with_delay(delay_ms: u64) -> Self
pub fn with_delay(delay_ms: u64) -> Self
Create a mock connector with custom connection delay
Trait Implementations§
Source§impl Connector for MockConnector
impl Connector for MockConnector
Source§fn connect<'life0, 'async_trait>(
&'life0 mut self,
_config: ConnectorInitConfig,
) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn connect<'life0, 'async_trait>(
&'life0 mut self,
_config: ConnectorInitConfig,
) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Establish connection to the backend data source
Source§fn execute_query<'life0, 'async_trait>(
&'life0 self,
query: ConnectorQuery,
) -> Pin<Box<dyn Future<Output = NirvResult<QueryResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn execute_query<'life0, 'async_trait>(
&'life0 self,
query: ConnectorQuery,
) -> Pin<Box<dyn Future<Output = NirvResult<QueryResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Execute a query against the connected data source
Source§fn get_schema<'life0, 'life1, 'async_trait>(
&'life0 self,
object_name: &'life1 str,
) -> Pin<Box<dyn Future<Output = NirvResult<Schema>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_schema<'life0, 'life1, 'async_trait>(
&'life0 self,
object_name: &'life1 str,
) -> Pin<Box<dyn Future<Output = NirvResult<Schema>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Retrieve schema information for a specific data object
Source§fn disconnect<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn disconnect<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Close connection and cleanup resources
Source§fn get_connector_type(&self) -> ConnectorType
fn get_connector_type(&self) -> ConnectorType
Get the type of this connector
Source§fn supports_transactions(&self) -> bool
fn supports_transactions(&self) -> bool
Check if this connector supports transactions
Source§fn is_connected(&self) -> bool
fn is_connected(&self) -> bool
Check if the connector is currently connected
Source§fn get_capabilities(&self) -> ConnectorCapabilities
fn get_capabilities(&self) -> ConnectorCapabilities
Get connector-specific capabilities
Source§impl Debug for MockConnector
impl Debug for MockConnector
Auto Trait Implementations§
impl Freeze for MockConnector
impl RefUnwindSafe for MockConnector
impl Send for MockConnector
impl Sync for MockConnector
impl Unpin for MockConnector
impl UnwindSafe for MockConnector
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more