Struct Neo4jExecutor 

pub struct Neo4jExecutor { /* private fields */ }

Neo4j graph-store executor using the HTTP Transactional Cypher API.

Implementations

impl Neo4jExecutor

pub fn new(config: Neo4jConfig) -> Self

Construct from config.

GAP 28 fix: the HTTP client is built with a configurable request timeout (UDB_GRAPH_TIMEOUT_SECS, default 30 s) so Neo4j calls cannot block the runtime indefinitely. A warning is emitted when plain HTTP is used, because Basic Auth credentials will be transmitted unencrypted.

GAP 39: When UDB_NEO4J_DEPLOY_MODE=cloud (or the DSN looks like an AuraDB / cloud URL), the URL must use https:// and the client is built with .https_only(true) to prevent credential leakage.

pub fn kind(&self) -> BackendKind

pub fn name(&self) -> &str

pub fn from_env() -> Option<Self>

Construct from environment variables. Returns None when UDB_GRAPH_DSN / UDB_GRAPH_HTTP_URL are absent.

pub async fn cypher( &self, statements: &[(&str, Json)], ) -> Result<Vec<Json>, String>

Execute one or more Cypher statements in a single auto-commit transaction. statements is a slice of (cypher, parameters) pairs.

pub async fn create_node( &self, label: &str, id: &str, properties: Json, ) -> Result<(), String>

Create or merge a node with a given label and properties. Uses MERGE on the id property to achieve idempotency.

pub async fn find_nodes( &self, label: &str, filter: Json, limit: i64, ) -> Result<Vec<Json>, String>

Find nodes of a given label that match a filter (key/value pairs in filter).

pub async fn update_node( &self, label: &str, id: &str, properties: Json, ) -> Result<(), String>

Update a node (merge properties onto it).

pub async fn delete_node(&self, label: &str, id: &str) -> Result<(), String>

Delete a node by id (DETACH DELETE removes all relationships).

pub async fn create_relationship( &self, from_label: &str, from_id: &str, to_label: &str, to_id: &str, rel_type: &str, properties: Json, ) -> Result<(), String>

Create or merge a typed relationship between two nodes.

Trait Implementations

impl BackendContextEnforcer for Neo4jExecutor

fn backend_label(&self) -> &str

Backend label (canonical lowercase: "postgres", "mysql", …).

fn enforce(&self, ctx: &AppliedContext) -> ContextEffect

Apply the context and report the effect. Implementations either emit SQL session variables (SQL backends), prepend filter fragments (document backends), or produce a key prefix (KV / object stores).

impl BackendExecutor for Neo4jExecutor

async fn transaction(&self, _request_json: &str) -> Result<String, Status>

async fn probe(&self) -> Result<BackendProbe, Status>

impl BackendHealth for Neo4jExecutor

async fn ping(&self) -> Result<(), String>

impl Clone for Neo4jExecutor

fn clone(&self) -> Neo4jExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Neo4jExecutor

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

Formats the value using the given formatter.

impl MutationExecutor for Neo4jExecutor

async fn mutate(&self, request_json: &str) -> Result<String, Status>

{"operation":"cypher|create_node|upsert_node|update_node|delete_node|create_relationship|upsert_relationship", ...}.

impl ObjectExecutor for Neo4jExecutor

async fn get_object(&self, _request_json: &str) -> Result<Vec<u8>, Status>

async fn put_object( &self, _request_json: &str, _bytes: Vec<u8>, ) -> Result<String, Status>

async fn get_object_stream( &self, request_json: &str, ) -> Result<ExecutorByteStream, Status>

async fn put_object_stream( &self, request_json: &str, stream: ExecutorByteStream, ) -> Result<String, Status>

Streaming upload (A.6). The default collects the byte stream into one buffer and delegates to ObjectExecutor::put_object, so backends that cannot stream keep working unchanged. Real object stores (S3/MinIO, …) override this to forward bytes to the provider without buffering the whole object in UDB.

async fn delete_object(&self, _request_json: &str) -> Result<(), Status>

Remove an object by {"bucket","object_key"|"key"}. Only real object stores (S3/MinIO, GCS, Azure Blob) override this; other backends report a typed capability refusal so callers never silently no-op a delete.

impl QueryExecutor for Neo4jExecutor

async fn query(&self, request_json: &str) -> Result<String, Status>

{"cypher":"MATCH ...","parameters":{...}} or {"label":"L","filter":{...},"limit":N}.

async fn query_stream( &self, request_json: &str, ) -> Result<ExecutorByteStream, Status>

impl ResourceAdminExecutor for Neo4jExecutor

async fn ensure_resource( &self, resource_name: &str, spec_json: &str, ) -> Result<(), Status>

async fn drop_resource(&self, resource_name: &str) -> Result<(), Status>

async fn list_resources(&self) -> Result<Vec<String>, Status>

impl SearchExecutor for Neo4jExecutor

async fn search(&self, _request_json: &str) -> Result<String, Status>