Struct QueryClient 

pub struct QueryClient { /* private fields */ }

Default event query client using tonic gRPC.

Implementations

impl QueryClient

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

Connect to an event query service at the given endpoint.

Supports both TCP (host:port) and Unix Domain Sockets (file paths).

pub async fn from_env(env_var: &str, default: &str) -> Result<Self>

Connect using an endpoint from environment variable with fallback.

pub fn from_channel(channel: Channel) -> Self

Create a client from an existing channel.

pub async fn get_events(&self, query: Query) -> Result<EventBook>

Query events for an aggregate.

Trait Implementations

impl Clone for QueryClient

fn clone(&self) -> QueryClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl QueryClient for QueryClient

fn get_events<'life0, 'async_trait>( &'life0 self, query: Query, ) -> Pin<Box<dyn Future<Output = Result<EventBook>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get events for the given query.