Struct EngineClient 

pub struct EngineClient { /* private fields */ }

Client for communicating with the AGNT5 Engine.

Uses a pool of N independent gRPC connections with round-robin selection. This prevents the h2 PoisonError that occurs when many concurrent checkpoint events are routed through a single HTTP/2 connection.

Implementations

impl EngineClient

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

Connect to the engine at the given endpoint with a pool of connections.

pub async fn begin_activation( &mut self, request: BeginActivationRequest, ) -> Result<BeginActivationResponse>

Admit one logical activation and return the journal-authoritative decision.

pub async fn complete_activation( &mut self, request: CompleteActivationRequest, ) -> Result<CompleteActivationResponse>

Commit one fenced activation completion and wait for its durability acknowledgement.

pub async fn fail_activation( &mut self, request: FailActivationRequest, ) -> Result<FailActivationResponse>

Commit one fenced activation failure and wait for its durability acknowledgement.

pub async fn suspend_activation( &mut self, request: SuspendActivationRequest, ) -> Result<SuspendActivationResponse>

Atomically park one fenced activation and its parent run until a durable timer generation is ready.

pub async fn append(&mut self, record: Record) -> Result<(u64, i64)>

Append a single record to the engine.

pub async fn append_batch(&mut self, records: Vec<Record>) -> Result<i32>

Append a batch of records to the engine.

pub async fn stream_events( &mut self, events: Vec<EventStreamMessage>, ) -> Result<i64>

Publish a bounded batch of ephemeral events and wait until the runtime acknowledges every frame. Closing each batch supplies the ordering barrier needed before a durable terminal event is appended.

Trait Implementations

impl Clone for EngineClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EngineClient

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

Formats the value using the given formatter.