pub struct Builder { /* private fields */ }Expand description
A builder for InvokeEndpointAsyncOutput.
Implementations§
source§impl Builder
impl Builder
sourcepub fn inference_id(self, input: impl Into<String>) -> Self
pub fn inference_id(self, input: impl Into<String>) -> Self
Identifier for an inference request. This will be the same as the InferenceId specified in the input. Amazon SageMaker will generate an identifier for you if you do not specify one.
sourcepub fn set_inference_id(self, input: Option<String>) -> Self
pub fn set_inference_id(self, input: Option<String>) -> Self
Identifier for an inference request. This will be the same as the InferenceId specified in the input. Amazon SageMaker will generate an identifier for you if you do not specify one.
Examples found in repository?
src/json_deser.rs (lines 345-351)
327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374
pub(crate) fn deser_operation_crate_operation_invoke_endpoint_async(
value: &[u8],
mut builder: crate::output::invoke_endpoint_async_output::Builder,
) -> Result<
crate::output::invoke_endpoint_async_output::Builder,
aws_smithy_json::deserialize::error::DeserializeError,
> {
let mut tokens_owned =
aws_smithy_json::deserialize::json_token_iter(crate::json_deser::or_empty_doc(value))
.peekable();
let tokens = &mut tokens_owned;
aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"InferenceId" => {
builder = builder.set_inference_id(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
if tokens.next().is_some() {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"found more JSON tokens after completing parsing",
),
);
}
Ok(builder)
}sourcepub fn output_location(self, input: impl Into<String>) -> Self
pub fn output_location(self, input: impl Into<String>) -> Self
The Amazon S3 URI where the inference response payload is stored.
sourcepub fn set_output_location(self, input: Option<String>) -> Self
pub fn set_output_location(self, input: Option<String>) -> Self
The Amazon S3 URI where the inference response payload is stored.
Examples found in repository?
src/operation_deser.rs (lines 256-259)
241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262
pub fn parse_invoke_endpoint_async_response(
response: &http::Response<bytes::Bytes>,
) -> std::result::Result<
crate::output::InvokeEndpointAsyncOutput,
crate::error::InvokeEndpointAsyncError,
> {
Ok({
#[allow(unused_mut)]
let mut output = crate::output::invoke_endpoint_async_output::Builder::default();
let _ = response;
output = crate::json_deser::deser_operation_crate_operation_invoke_endpoint_async(
response.body().as_ref(),
output,
)
.map_err(crate::error::InvokeEndpointAsyncError::unhandled)?;
output = output.set_output_location(
crate::http_serde::deser_header_invoke_endpoint_async_invoke_endpoint_async_output_output_location(response.headers())
.map_err(|_|crate::error::InvokeEndpointAsyncError::unhandled("Failed to parse OutputLocation from header `X-Amzn-SageMaker-OutputLocation"))?
);
output.build()
})
}sourcepub fn build(self) -> InvokeEndpointAsyncOutput
pub fn build(self) -> InvokeEndpointAsyncOutput
Consumes the builder and constructs a InvokeEndpointAsyncOutput.
Examples found in repository?
src/operation_deser.rs (line 260)
241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262
pub fn parse_invoke_endpoint_async_response(
response: &http::Response<bytes::Bytes>,
) -> std::result::Result<
crate::output::InvokeEndpointAsyncOutput,
crate::error::InvokeEndpointAsyncError,
> {
Ok({
#[allow(unused_mut)]
let mut output = crate::output::invoke_endpoint_async_output::Builder::default();
let _ = response;
output = crate::json_deser::deser_operation_crate_operation_invoke_endpoint_async(
response.body().as_ref(),
output,
)
.map_err(crate::error::InvokeEndpointAsyncError::unhandled)?;
output = output.set_output_location(
crate::http_serde::deser_header_invoke_endpoint_async_invoke_endpoint_async_output_output_location(response.headers())
.map_err(|_|crate::error::InvokeEndpointAsyncError::unhandled("Failed to parse OutputLocation from header `X-Amzn-SageMaker-OutputLocation"))?
);
output.build()
})
}