pub struct Request {
pub token: String,
pub connection_params: BTreeMap<String, String>,
pub subject: Subject,
pub credential: Credential,
pub access: Access,
pub host: Host,
pub idempotency_key: String,
pub workflow: Map<String, Value>,
pub invocation_token: String,
}Expand description
Carries execution-scoped metadata into typed operation handlers.
Fields§
§token: StringRequest token supplied to hosted HTTP operation handlers.
connection_params: BTreeMap<String, String>Connection parameters resolved by the host.
subject: SubjectSubject that initiated the request.
credential: CredentialCredential used to authorize the request.
access: AccessAccess decision attached to the request.
host: HostPublic host metadata attached to the request.
idempotency_key: StringIdempotency key supplied by the host.
workflow: Map<String, Value>Workflow callback metadata uses a JSON-style lowerCamelCase object
such as runId, target.plugin.pluginName, trigger.scheduleId, and
trigger.event.specVersion.
invocation_token: StringInvocation token used to call host services.
Implementations§
Source§impl Request
impl Request
Sourcepub fn connection_param(&self, name: &str) -> Option<&str>
pub fn connection_param(&self, name: &str) -> Option<&str>
Returns one resolved connection parameter by name.
Sourcepub fn invocation_token(&self) -> &str
pub fn invocation_token(&self) -> &str
Returns the invocation token used to call host services.
Sourcepub async fn invoker(&self) -> Result<PluginInvoker, PluginInvokerError>
pub async fn invoker(&self) -> Result<PluginInvoker, PluginInvokerError>
Creates a plugin invoker using this request’s invocation token.
Sourcepub async fn workflow_manager(
&self,
) -> Result<WorkflowManager, WorkflowManagerError>
pub async fn workflow_manager( &self, ) -> Result<WorkflowManager, WorkflowManagerError>
Creates a workflow manager using this request’s invocation token.
Sourcepub async fn agent_manager(&self) -> Result<AgentManager, AgentManagerError>
pub async fn agent_manager(&self) -> Result<AgentManager, AgentManagerError>
Creates an agent manager using this request’s invocation token.
Trait Implementations§
impl StructuralPartialEq for Request
Auto Trait Implementations§
impl Freeze for Request
impl RefUnwindSafe for Request
impl Send for Request
impl Sync for Request
impl Unpin for Request
impl UnsafeUnpin for Request
impl UnwindSafe for Request
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request