Struct RequestQueryHost 

pub struct RequestQueryHost { /* private fields */ }

The host a request:query function runs on: reads, one outbound call, and refusals that say why.

Implementations

impl RequestQueryHost

pub fn new( event_payload: EventPayload, reader: Option<Arc<dyn GuestQueryBridge>>, principal: Option<&SecurityContext>, http: HostContextConfig, ) -> Self

Build the host for one field invocation.

pub fn with_http_client(self, client: Arc<Client>) -> Self

Share an existing outbound HTTP client rather than building one per call.

Trait Implementations

impl HostContext for RequestQueryHost

async fn query(&self, graphql: &str, variables: Value) -> Result<Value>

Execute a GraphQL query.

async fn sql_query(&self, _sql: &str, _params: &[Value]) -> Result<Vec<Value>>

Execute a raw SQL query.

async fn http_request( &self, method: &str, url: &str, headers: &[(String, String)], body: Option<&[u8]>, ) -> Result<HttpResponse>

Make an HTTP request.

async fn storage_get(&self, _bucket: &str, _key: &str) -> Result<Vec<u8>>

Retrieve an object from storage.

async fn storage_put( &self, _bucket: &str, _key: &str, _body: &[u8], _content_type: &str, ) -> Result<()>

Store an object to storage.

async fn send_email( &self, _request: &SendEmailRequest, ) -> Result<SendEmailResponse>

Send an email.

fn auth_context(&self) -> Result<Value>

Get the current authenticated user’s context.

fn env_var(&self, _name: &str) -> Result<Option<String>>

Get an environment variable.

fn event_payload(&self) -> &EventPayload

Get the current event payload (for reference).

fn log(&self, level: LogLevel, message: &str)

Log a message to the tracing subscriber.

fn idempotency_token(&self) -> Option<String>

A per-dispatch idempotency token, stable across retries of the same dispatch and distinct per dispatch.

fn cursor(&self) -> impl Future<Output = Result<Option<Value>>> + Send

Read this source’s durable opaque cursor (Model B pull sources, #573).

fn advance_cursor( &self, value: Value, ) -> impl Future<Output = Result<()>> + Send

Advance this source’s durable cursor to value (Model B pull sources, #573).