Enum ComRequest 

pub enum ComRequest {
    ListServers {
        host: String,
        reply: Sender<OpcResult<Vec<String>>>,
    },
    ReadTagValues {
        server: String,
        tag_ids: Vec<String>,
        presentation: ReadPresentation,
        reply: Sender<OpcResult<Vec<TagValue>>>,
    },
    WriteTagValue {
        server: String,
        tag_id: String,
        value: OpcValue,
        reply: Sender<OpcResult<WriteResult>>,
    },
    BrowseTags {
        server: String,
        max_tags: usize,
        progress: Arc<AtomicUsize>,
        tags_sink: Arc<Mutex<Vec<String>>>,
        reply: Sender<OpcResult<Vec<String>>>,
    },
    BrowseCapabilities {
        server: String,
        reply: Sender<OpcResult<BrowseCapabilities>>,
    },
    OpenBrowseSession {
        server: String,
        reply: Sender<OpcResult<BrowseSessionToken>>,
    },
    BrowsePage {
        session: BrowseSessionToken,
        request: BrowsePageRequest,
        reply: Sender<OpcResult<BrowsePage>>,
    },
    CloseBrowseSession {
        session: BrowseSessionToken,
        reply: Sender<OpcResult<()>>,
    },
}

Represents a asynchronous request dispatched to the COM worker thread.

Variants

ListServers

Request to enumerate available OPC DA servers on a host.

Fields

host: String

Hostname or IP address to target.

reply: Sender<OpcResult<Vec<String>>>

One-shot channel to send back the server enumeration result.

ReadTagValues

Request to read current values, quality, and timestamps for tag IDs.

Fields

server: String

OPC server ProgID.

tag_ids: Vec<String>

List of fully qualified tag identifiers to read.

presentation: ReadPresentation

Value formatting intent for this read.

reply: Sender<OpcResult<Vec<TagValue>>>

One-shot channel to send back the tag values result.

WriteTagValue

Request to write a typed value to a single tag.

Fields

server: String

OPC server ProgID.

tag_id: String

Tag identifier to write.

value: OpcValue

Typed value to write.

reply: Sender<OpcResult<WriteResult>>

One-shot channel to send back the write operation result.

BrowseTags

Request to recursively browse available tags on a server.

Fields

server: String

OPC server ProgID.

max_tags: usize

Maximum number of tags to discover before stopping.

progress: Arc<AtomicUsize>

Atomic counter tracking total tags discovered.

tags_sink: Arc<Mutex<Vec<String>>>

Shared mutex-protected vector storing discovered tag names incrementally.

reply: Sender<OpcResult<Vec<String>>>

One-shot channel to send back the complete tag discovery list.

BrowseCapabilities

Request the native browse capabilities of a server.

Fields

server: String

OPC server ProgID.

reply: Sender<OpcResult<BrowseCapabilities>>

One-shot channel to send back the capabilities.

OpenBrowseSession

Open an isolated native browse session.

Fields

server: String

OPC server ProgID.

reply: Sender<OpcResult<BrowseSessionToken>>

One-shot channel to send back the opaque session token.

BrowsePage

Request one bounded native browse page.

Fields

session: BrowseSessionToken

Opaque browse session token.

request: BrowsePageRequest

One-level browse request.

reply: Sender<OpcResult<BrowsePage>>

One-shot channel to send back the page.

CloseBrowseSession

Close an isolated native browse session.

Fields

session: BrowseSessionToken

Opaque browse session token.

reply: Sender<OpcResult<()>>

One-shot channel to report completion.