Struct ApplicationSourceHandle 

pub struct ApplicationSourceHandle { /* private fields */ }

Handle for programmatic event injection into an Application Source

ApplicationSourceHandle provides a type-safe API for injecting graph data changes (node inserts, updates, deletes, and relationship inserts) directly from your application code into the Drasi continuous query processing pipeline.

Implementations

impl ApplicationSourceHandle

pub async fn send(&self, change: SourceChange) -> Result<()>

Send a raw source change event

pub async fn send_node_insert( &self, element_id: impl Into<Arc<str>>, labels: Vec<impl Into<Arc<str>>>, properties: ElementPropertyMap, ) -> Result<()>

Insert a new node into the graph

pub async fn send_node_update( &self, element_id: impl Into<Arc<str>>, labels: Vec<impl Into<Arc<str>>>, properties: ElementPropertyMap, ) -> Result<()>

Update an existing node in the graph

pub async fn send_delete( &self, element_id: impl Into<Arc<str>>, labels: Vec<impl Into<Arc<str>>>, ) -> Result<()>

Delete a node or relationship from the graph

pub async fn send_relation_insert( &self, element_id: impl Into<Arc<str>>, labels: Vec<impl Into<Arc<str>>>, properties: ElementPropertyMap, start_node_id: impl Into<Arc<str>>, end_node_id: impl Into<Arc<str>>, ) -> Result<()>

Insert a new relationship into the graph

pub async fn send_batch(&self, changes: Vec<SourceChange>) -> Result<()>

Send a batch of source changes efficiently

pub fn source_id(&self) -> &str

Get the source ID that this handle is connected to

Trait Implementations

impl Clone for ApplicationSourceHandle

fn clone(&self) -> ApplicationSourceHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.