Struct Client 

pub struct Client { /* private fields */ }

A connected client for an opcda-bridge gateway’s gRPC API.

Implementations

impl Client

pub async fn connect(host: &str) -> Result<Self>

Connect to a plaintext gateway at host (for example, localhost:7600).

pub async fn capabilities( &mut self, server: impl Into<String>, ) -> Result<Capabilities>

Report protocol, paging, browse-session, search, and namespace support.

pub async fn list_servers(&mut self) -> Result<Vec<String>>

List the OPC DA servers registered on the gateway’s host.

pub async fn browse( &mut self, server: impl Into<String>, page_size: u32, ) -> Result<BrowsePage>

Open a browse session and return only its first root page.

pub async fn open_browse( &mut self, server: impl Into<String>, page_size: u32, ) -> Result<BrowsePage>

Open a browse session and return only its first root page.

pub async fn browse_page( &mut self, request: BrowsePageRequest, ) -> Result<BrowsePage>

Request exactly one root, child, or continuation page.

This method never follows next_page_token automatically.

pub async fn close_browse_session( &mut self, session_id: impl Into<String>, ) -> Result<()>

Explicitly release a gateway browse session.

pub async fn search_stream( &mut self, request: SearchRequest, ) -> Result<SearchStream>

Start a bounded search and return its progressive event stream.

pub async fn search( &mut self, request: SearchRequest, ) -> Result<Vec<SearchEvent>>

Explicitly collect a complete search stream into memory.

pub async fn search_index_status( &mut self, server: impl Into<String>, ) -> Result<SearchIndexStatus>

Return the persistent namespace-index status for server.

pub async fn refresh_search_index( &mut self, server: impl Into<String>, force: bool, ) -> Result<SearchIndexStatus>

Start or coalesce a persistent namespace-index refresh.

pub async fn control_search_index( &mut self, server: impl Into<String>, action: SearchIndexControlAction, ) -> Result<SearchIndexStatus>

Pause, resume, or cancel a persistent namespace-index build.

pub async fn search_index( &mut self, request: SearchIndexRequest, ) -> Result<SearchIndexResponse>

Search the gateway-owned persistent namespace index.

This never falls back to live namespace traversal.

pub async fn read( &mut self, server: String, tags: Vec<String>, ) -> Result<Vec<TagValue>>

Read one or more exact OPC DA ItemIDs from server.

pub async fn write( &mut self, server: String, tag: String, value: Value, ) -> Result<WriteResult>

Write value to one exact OPC DA ItemID on server.

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.