Struct HostState 

pub struct HostState { /* private fields */ }

Implementations

impl HostState

pub fn new( config: Arc<HostConfig>, http_client: Arc<BlockingClient>, mocks: Option<Arc<MockLayer>>, session_store: Option<DynSessionStore>, state_store: Option<DynStateStore>, secrets: DynSecretsManager, oauth_config: Option<OAuthBrokerConfig>, ) -> Result<Self>

pub fn get_secret(&self, key: &str) -> Result<String>

Trait Implementations

impl Host for HostState

fn send( &mut self, req: HttpRequest, ctx: Option<HttpTenantCtx>, ) -> Result<HttpResponse, HttpClientError>

Issues an HTTP request using the host’s networking stack.

impl Host for HostState

fn send( &mut self, req: HttpRequestV1_1, opts: Option<HttpRequestOptionsV1_1>, ctx: Option<HttpTenantCtxV1_1>, ) -> Result<HttpResponseV1_1, HttpClientErrorV1_1>

Issues an HTTP request using the host’s networking stack.

impl Host for HostState

fn request( &mut self, method: String, url: String, headers: Vec<String>, body: Option<Vec<u8>>, ) -> Result<Vec<u8>, String>

impl Host for HostState

fn get(&mut self, _ns: String, _key: String) -> Option<String>

fn put(&mut self, _ns: String, _key: String, _val: String)

impl Host for HostState

fn get(&mut self, key: String) -> Result<Option<Vec<u8>>, SecretsError>

Reads a secret value; returns none when the key is missing.

impl Host for HostState

fn read( &mut self, key: HostStateKey, ctx: Option<StateTenantCtx>, ) -> Result<Vec<u8>, StateError>

Reads a namespaced blob of state.

fn write( &mut self, key: HostStateKey, bytes: Vec<u8>, ctx: Option<StateTenantCtx>, ) -> Result<StateOpAck, StateError>

Writes a namespaced blob of state.

fn delete( &mut self, key: HostStateKey, ctx: Option<StateTenantCtx>, ) -> Result<StateOpAck, StateError>

Deletes a namespaced blob of state.

impl Host for HostState

fn log( &mut self, span: TelemetrySpanContext, fields: Vec<(String, String)>, _ctx: Option<TelemetryTenantCtx>, ) -> Result<TelemetryAck, TelemetryError>

Emits telemetry fields under the provided span context.