Struct Connector 

pub struct Connector {
    pub config: ConnectorConfig,
    /* private fields */
}

A connector that can fetch entities from a remote Haystack server.

Fields

config: ConnectorConfig

Implementations

impl Connector

pub fn new(config: ConnectorConfig) -> Self

Create a new connector with an empty cache.

pub async fn sync(&self) -> Result<usize, String>

Connect to the remote server, fetch all entities, apply id prefixing, and store them in the cache. Returns the count of entities synced.

Uses the persistent client if available, otherwise establishes a new connection (WS-first, falling back to HTTP).

pub fn update_cache(&self, entities: Vec<HDict>)

Replace the cached entities and rebuild the owned-ID index.

Extracts all id Ref values from the given entities into a HashSet, then atomically replaces both the entity cache and the ownership set.

pub fn owns(&self, id: &str) -> bool

Returns true if this connector owns an entity with the given ID.

pub fn cached_entities(&self) -> Vec<HDict>

Returns a clone of all cached entities.

pub fn entity_count(&self) -> usize

Returns the number of cached entities.

pub fn add_remote_watch(&self, prefixed_id: &str)

Add a federated entity ID to the remote watch set.

pub fn remove_remote_watch(&self, prefixed_id: &str)

Remove a federated entity ID from the remote watch set.

pub fn remote_watch_count(&self) -> usize

Returns the number of entity IDs being watched remotely.

pub fn transport_mode(&self) -> TransportMode

Returns the current transport mode.

pub fn is_connected(&self) -> bool

Returns whether the connector is currently connected (last sync succeeded).

pub fn last_sync_time(&self) -> Option<DateTime<Utc>>

Returns the timestamp of the last successful sync, if any.

pub async fn proxy_his_read( &self, prefixed_id: &str, range: &str, ) -> Result<HGrid, String>

Proxy a hisRead request to the remote server.

pub async fn proxy_point_write( &self, prefixed_id: &str, level: u8, val: &Kind, ) -> Result<HGrid, String>

Proxy a pointWrite request to the remote server.

pub async fn proxy_his_write( &self, prefixed_id: &str, items: Vec<HDict>, ) -> Result<HGrid, String>

Proxy a hisWrite request to the remote server.

pub async fn proxy_import(&self, entity: &HDict) -> Result<HGrid, String>

Proxy an import request for a single entity to the remote server.

Strips the id prefix from the entity, wraps it in a single-row grid, and calls the remote import op.

pub async fn proxy_invoke_action( &self, prefixed_id: &str, action: &str, args: HDict, ) -> Result<HGrid, String>

Proxy an invokeAction request to the remote server.

pub fn spawn_sync_task(connector: Arc<Connector>) -> JoinHandle<()>

Spawn a background sync task for this connector.

The task loops forever, syncing entities at the configured interval. On error, the persistent client is cleared to force reconnection on the next iteration.