add accept header (#436)

This commit is contained in:
Adam Leventhal 2023-04-24 17:42:22 -07:00 committed by GitHub
parent 819ebb2d8b
commit a9e76608ca
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
14 changed files with 5359 additions and 616 deletions

View File

@ -999,10 +999,15 @@ impl Generator {
} }
} }
OperationResponseType::Upgrade => { OperationResponseType::Upgrade => {
if response.status_code == OperationResponseStatus::Default { if response.status_code
return quote! { } // catch-all handled below == OperationResponseStatus::Default
{
return quote! {}; // catch-all handled below
} else { } else {
todo!("non-default error response handling for upgrade requests is not yet implemented"); todo!(
"non-default error response handling for \
upgrade requests is not yet implemented"
);
} }
} }
}; };
@ -1010,6 +1015,22 @@ impl Generator {
quote! { #pat => { #decode } } quote! { #pat => { #decode } }
}); });
let accept_header = matches!(
(&response_type, &error_type),
(OperationResponseType::Type(_), _)
| (OperationResponseType::None, OperationResponseType::Type(_))
)
.then(|| {
quote! {
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static(
"application/json",
),
)
}
});
// Generate the catch-all case for other statuses. If the operation // Generate the catch-all case for other statuses. If the operation
// specifies a default response, we've already generated a default // specifies a default response, we've already generated a default
// match as part of error response code handling. (And we've handled // match as part of error response code handling. (And we've handled
@ -1042,6 +1063,7 @@ impl Generator {
let request = #client.client let request = #client.client
. #method_func (url) . #method_func (url)
#accept_header
#(#body_func)* #(#body_func)*
#query_use #query_use
#headers_use #headers_use

View File

@ -1872,7 +1872,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<()>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<()>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/control/hold", client.baseurl,); let url = format!("{}/v1/control/hold", client.baseurl,);
let request = client.client.post(url).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1945,7 +1952,14 @@ pub mod builder {
client.baseurl, client.baseurl,
encode_path(&task.to_string()), encode_path(&task.to_string()),
); );
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1972,7 +1986,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<Vec<types::Task>>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<Vec<types::Task>>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/tasks", client.baseurl,); let url = format!("{}/v1/tasks", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2025,7 +2046,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::TaskSubmit>::try_into) .and_then(std::convert::TryInto::<types::TaskSubmit>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/v1/tasks", client.baseurl,); let url = format!("{}/v1/tasks", client.baseurl,);
let request = client.client.post(url).json(&body).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2093,7 +2122,15 @@ pub mod builder {
if let Some(v) = &minseq { if let Some(v) = &minseq {
query.push(("minseq", v.to_string())); query.push(("minseq", v.to_string()));
} }
let request = client.client.get(url).query(&query).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.query(&query)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2139,7 +2176,14 @@ pub mod builder {
client.baseurl, client.baseurl,
encode_path(&task.to_string()), encode_path(&task.to_string()),
); );
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2256,7 +2300,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::UserCreate>::try_into) .and_then(std::convert::TryInto::<types::UserCreate>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/v1/users", client.baseurl,); let url = format!("{}/v1/users", client.baseurl,);
let request = client.client.post(url).json(&body).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2283,7 +2335,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<types::WhoamiResult>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<types::WhoamiResult>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/whoami", client.baseurl,); let url = format!("{}/v1/whoami", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2336,7 +2395,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::WorkerBootstrap>::try_into) .and_then(std::convert::TryInto::<types::WorkerBootstrap>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/v1/worker/bootstrap", client.baseurl,); let url = format!("{}/v1/worker/bootstrap", client.baseurl,);
let request = client.client.post(url).json(&body).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2363,7 +2430,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<types::WorkerPingResult>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<types::WorkerPingResult>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/worker/ping", client.baseurl,); let url = format!("{}/v1/worker/ping", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2497,6 +2571,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.header( .header(
reqwest::header::CONTENT_TYPE, reqwest::header::CONTENT_TYPE,
reqwest::header::HeaderValue::from_static("application/octet-stream"), reqwest::header::HeaderValue::from_static("application/octet-stream"),
@ -2671,7 +2749,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<types::WorkersResult>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<types::WorkersResult>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/workers", client.baseurl,); let url = format!("{}/v1/workers", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {

View File

@ -1872,7 +1872,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<()>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<()>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/control/hold", client.baseurl,); let url = format!("{}/v1/control/hold", client.baseurl,);
let request = client.client.post(url).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1945,7 +1952,14 @@ pub mod builder {
client.baseurl, client.baseurl,
encode_path(&task.to_string()), encode_path(&task.to_string()),
); );
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1972,7 +1986,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<Vec<types::Task>>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<Vec<types::Task>>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/tasks", client.baseurl,); let url = format!("{}/v1/tasks", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2025,7 +2046,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::TaskSubmit>::try_into) .and_then(std::convert::TryInto::<types::TaskSubmit>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/v1/tasks", client.baseurl,); let url = format!("{}/v1/tasks", client.baseurl,);
let request = client.client.post(url).json(&body).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2093,7 +2122,15 @@ pub mod builder {
if let Some(v) = &minseq { if let Some(v) = &minseq {
query.push(("minseq", v.to_string())); query.push(("minseq", v.to_string()));
} }
let request = client.client.get(url).query(&query).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.query(&query)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2139,7 +2176,14 @@ pub mod builder {
client.baseurl, client.baseurl,
encode_path(&task.to_string()), encode_path(&task.to_string()),
); );
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2256,7 +2300,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::UserCreate>::try_into) .and_then(std::convert::TryInto::<types::UserCreate>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/v1/users", client.baseurl,); let url = format!("{}/v1/users", client.baseurl,);
let request = client.client.post(url).json(&body).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2283,7 +2335,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<types::WhoamiResult>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<types::WhoamiResult>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/whoami", client.baseurl,); let url = format!("{}/v1/whoami", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2336,7 +2395,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::WorkerBootstrap>::try_into) .and_then(std::convert::TryInto::<types::WorkerBootstrap>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/v1/worker/bootstrap", client.baseurl,); let url = format!("{}/v1/worker/bootstrap", client.baseurl,);
let request = client.client.post(url).json(&body).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2363,7 +2430,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<types::WorkerPingResult>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<types::WorkerPingResult>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/worker/ping", client.baseurl,); let url = format!("{}/v1/worker/ping", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2497,6 +2571,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.header( .header(
reqwest::header::CONTENT_TYPE, reqwest::header::CONTENT_TYPE,
reqwest::header::HeaderValue::from_static("application/octet-stream"), reqwest::header::HeaderValue::from_static("application/octet-stream"),
@ -2671,7 +2749,14 @@ pub mod builder {
pub async fn send(self) -> Result<ResponseValue<types::WorkersResult>, Error<()>> { pub async fn send(self) -> Result<ResponseValue<types::WorkersResult>, Error<()>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/v1/workers", client.baseurl,); let url = format!("{}/v1/workers", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {

View File

@ -311,7 +311,14 @@ impl Client {
///Sends a `POST` request to `/v1/control/hold` ///Sends a `POST` request to `/v1/control/hold`
pub async fn control_hold<'a>(&'a self) -> Result<ResponseValue<()>, Error<()>> { pub async fn control_hold<'a>(&'a self) -> Result<ResponseValue<()>, Error<()>> {
let url = format!("{}/v1/control/hold", self.baseurl,); let url = format!("{}/v1/control/hold", self.baseurl,);
let request = self.client.post(url).build()?; let request = self
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -342,7 +349,14 @@ impl Client {
self.baseurl, self.baseurl,
encode_path(&task.to_string()), encode_path(&task.to_string()),
); );
let request = self.client.get(url).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -354,7 +368,14 @@ impl Client {
///Sends a `GET` request to `/v1/tasks` ///Sends a `GET` request to `/v1/tasks`
pub async fn tasks_get<'a>(&'a self) -> Result<ResponseValue<Vec<types::Task>>, Error<()>> { pub async fn tasks_get<'a>(&'a self) -> Result<ResponseValue<Vec<types::Task>>, Error<()>> {
let url = format!("{}/v1/tasks", self.baseurl,); let url = format!("{}/v1/tasks", self.baseurl,);
let request = self.client.get(url).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -369,7 +390,15 @@ impl Client {
body: &'a types::TaskSubmit, body: &'a types::TaskSubmit,
) -> Result<ResponseValue<types::TaskSubmitResult>, Error<()>> { ) -> Result<ResponseValue<types::TaskSubmitResult>, Error<()>> {
let url = format!("{}/v1/tasks", self.baseurl,); let url = format!("{}/v1/tasks", self.baseurl,);
let request = self.client.post(url).json(&body).build()?; let request = self
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -394,7 +423,15 @@ impl Client {
query.push(("minseq", v.to_string())); query.push(("minseq", v.to_string()));
} }
let request = self.client.get(url).query(&query).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.query(&query)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -413,7 +450,14 @@ impl Client {
self.baseurl, self.baseurl,
encode_path(&task.to_string()), encode_path(&task.to_string()),
); );
let request = self.client.get(url).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -449,7 +493,15 @@ impl Client {
body: &'a types::UserCreate, body: &'a types::UserCreate,
) -> Result<ResponseValue<types::UserCreateResult>, Error<()>> { ) -> Result<ResponseValue<types::UserCreateResult>, Error<()>> {
let url = format!("{}/v1/users", self.baseurl,); let url = format!("{}/v1/users", self.baseurl,);
let request = self.client.post(url).json(&body).build()?; let request = self
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -461,7 +513,14 @@ impl Client {
///Sends a `GET` request to `/v1/whoami` ///Sends a `GET` request to `/v1/whoami`
pub async fn whoami<'a>(&'a self) -> Result<ResponseValue<types::WhoamiResult>, Error<()>> { pub async fn whoami<'a>(&'a self) -> Result<ResponseValue<types::WhoamiResult>, Error<()>> {
let url = format!("{}/v1/whoami", self.baseurl,); let url = format!("{}/v1/whoami", self.baseurl,);
let request = self.client.get(url).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -476,7 +535,15 @@ impl Client {
body: &'a types::WorkerBootstrap, body: &'a types::WorkerBootstrap,
) -> Result<ResponseValue<types::WorkerBootstrapResult>, Error<()>> { ) -> Result<ResponseValue<types::WorkerBootstrapResult>, Error<()>> {
let url = format!("{}/v1/worker/bootstrap", self.baseurl,); let url = format!("{}/v1/worker/bootstrap", self.baseurl,);
let request = self.client.post(url).json(&body).build()?; let request = self
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -490,7 +557,14 @@ impl Client {
&'a self, &'a self,
) -> Result<ResponseValue<types::WorkerPingResult>, Error<()>> { ) -> Result<ResponseValue<types::WorkerPingResult>, Error<()>> {
let url = format!("{}/v1/worker/ping", self.baseurl,); let url = format!("{}/v1/worker/ping", self.baseurl,);
let request = self.client.get(url).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -533,6 +607,10 @@ impl Client {
let request = self let request = self
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.header( .header(
reqwest::header::CONTENT_TYPE, reqwest::header::CONTENT_TYPE,
reqwest::header::HeaderValue::from_static("application/octet-stream"), reqwest::header::HeaderValue::from_static("application/octet-stream"),
@ -592,7 +670,14 @@ impl Client {
&'a self, &'a self,
) -> Result<ResponseValue<types::WorkersResult>, Error<()>> { ) -> Result<ResponseValue<types::WorkersResult>, Error<()>> {
let url = format!("{}/v1/workers", self.baseurl,); let url = format!("{}/v1/workers", self.baseurl,);
let request = self.client.get(url).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {

View File

@ -1171,7 +1171,15 @@ pub mod builder {
let url = format!("{}/global/jobs", client.baseurl,); let url = format!("{}/global/jobs", client.baseurl,);
let mut header_map = HeaderMap::with_capacity(1usize); let mut header_map = HeaderMap::with_capacity(1usize);
header_map.append("Authorization", HeaderValue::try_from(authorization)?); header_map.append("Authorization", HeaderValue::try_from(authorization)?);
let request = client.client.get(url).headers(header_map).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.headers(header_map)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1218,7 +1226,15 @@ pub mod builder {
let url = format!("{}/ping", client.baseurl,); let url = format!("{}/ping", client.baseurl,);
let mut header_map = HeaderMap::with_capacity(1usize); let mut header_map = HeaderMap::with_capacity(1usize);
header_map.append("Authorization", HeaderValue::try_from(authorization)?); header_map.append("Authorization", HeaderValue::try_from(authorization)?);
let request = client.client.get(url).headers(header_map).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.headers(header_map)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1295,6 +1311,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;
@ -1374,6 +1394,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;
@ -1451,6 +1475,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;

View File

@ -1171,7 +1171,15 @@ pub mod builder {
let url = format!("{}/global/jobs", client.baseurl,); let url = format!("{}/global/jobs", client.baseurl,);
let mut header_map = HeaderMap::with_capacity(1usize); let mut header_map = HeaderMap::with_capacity(1usize);
header_map.append("Authorization", HeaderValue::try_from(authorization)?); header_map.append("Authorization", HeaderValue::try_from(authorization)?);
let request = client.client.get(url).headers(header_map).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.headers(header_map)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1218,7 +1226,15 @@ pub mod builder {
let url = format!("{}/ping", client.baseurl,); let url = format!("{}/ping", client.baseurl,);
let mut header_map = HeaderMap::with_capacity(1usize); let mut header_map = HeaderMap::with_capacity(1usize);
header_map.append("Authorization", HeaderValue::try_from(authorization)?); header_map.append("Authorization", HeaderValue::try_from(authorization)?);
let request = client.client.get(url).headers(header_map).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.headers(header_map)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -1295,6 +1311,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;
@ -1374,6 +1394,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;
@ -1451,6 +1475,10 @@ pub mod builder {
let request = client let request = client
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;

View File

@ -235,7 +235,15 @@ impl Client {
let url = format!("{}/global/jobs", self.baseurl,); let url = format!("{}/global/jobs", self.baseurl,);
let mut header_map = HeaderMap::with_capacity(1usize); let mut header_map = HeaderMap::with_capacity(1usize);
header_map.append("Authorization", HeaderValue::try_from(authorization)?); header_map.append("Authorization", HeaderValue::try_from(authorization)?);
let request = self.client.get(url).headers(header_map).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.headers(header_map)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -255,7 +263,15 @@ impl Client {
let url = format!("{}/ping", self.baseurl,); let url = format!("{}/ping", self.baseurl,);
let mut header_map = HeaderMap::with_capacity(1usize); let mut header_map = HeaderMap::with_capacity(1usize);
header_map.append("Authorization", HeaderValue::try_from(authorization)?); header_map.append("Authorization", HeaderValue::try_from(authorization)?);
let request = self.client.get(url).headers(header_map).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.headers(header_map)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -280,6 +296,10 @@ impl Client {
let request = self let request = self
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;
@ -307,6 +327,10 @@ impl Client {
let request = self let request = self
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;
@ -334,6 +358,10 @@ impl Client {
let request = self let request = self
.client .client
.post(url) .post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body) .json(&body)
.headers(header_map) .headers(header_map)
.build()?; .build()?;

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@ -2124,7 +2124,14 @@ pub mod builder {
) -> Result<ResponseValue<types::InstanceGetResponse>, Error<types::Error>> { ) -> Result<ResponseValue<types::InstanceGetResponse>, Error<types::Error>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/instance", client.baseurl,); let url = format!("{}/instance", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2187,7 +2194,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::InstanceEnsureRequest>::try_into) .and_then(std::convert::TryInto::<types::InstanceEnsureRequest>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/instance", client.baseurl,); let url = format!("{}/instance", client.baseurl,);
let request = client.client.put(url).json(&body).build()?; let request = client
.client
.put(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2258,7 +2273,14 @@ pub mod builder {
encode_path(&id.to_string()), encode_path(&id.to_string()),
encode_path(&snapshot_id.to_string()), encode_path(&snapshot_id.to_string()),
); );
let request = client.client.post(url).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2321,7 +2343,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::InstanceMigrateStatusRequest>::try_into) .and_then(std::convert::TryInto::<types::InstanceMigrateStatusRequest>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/instance/migrate/status", client.baseurl,); let url = format!("{}/instance/migrate/status", client.baseurl,);
let request = client.client.get(url).json(&body).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2412,7 +2442,15 @@ pub mod builder {
let Self { client, body } = self; let Self { client, body } = self;
let body = body.map_err(Error::InvalidRequest)?; let body = body.map_err(Error::InvalidRequest)?;
let url = format!("{}/instance/state", client.baseurl,); let url = format!("{}/instance/state", client.baseurl,);
let request = client.client.put(url).json(&body).build()?; let request = client
.client
.put(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2475,7 +2513,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::InstanceStateMonitorRequest>::try_into) .and_then(std::convert::TryInto::<types::InstanceStateMonitorRequest>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/instance/state-monitor", client.baseurl,); let url = format!("{}/instance/state-monitor", client.baseurl,);
let request = client.client.get(url).json(&body).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {

View File

@ -2130,7 +2130,14 @@ pub mod builder {
) -> Result<ResponseValue<types::InstanceGetResponse>, Error<types::Error>> { ) -> Result<ResponseValue<types::InstanceGetResponse>, Error<types::Error>> {
let Self { client } = self; let Self { client } = self;
let url = format!("{}/instance", client.baseurl,); let url = format!("{}/instance", client.baseurl,);
let request = client.client.get(url).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2193,7 +2200,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::InstanceEnsureRequest>::try_into) .and_then(std::convert::TryInto::<types::InstanceEnsureRequest>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/instance", client.baseurl,); let url = format!("{}/instance", client.baseurl,);
let request = client.client.put(url).json(&body).build()?; let request = client
.client
.put(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2264,7 +2279,14 @@ pub mod builder {
encode_path(&id.to_string()), encode_path(&id.to_string()),
encode_path(&snapshot_id.to_string()), encode_path(&snapshot_id.to_string()),
); );
let request = client.client.post(url).build()?; let request = client
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2327,7 +2349,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::InstanceMigrateStatusRequest>::try_into) .and_then(std::convert::TryInto::<types::InstanceMigrateStatusRequest>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/instance/migrate/status", client.baseurl,); let url = format!("{}/instance/migrate/status", client.baseurl,);
let request = client.client.get(url).json(&body).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2418,7 +2448,15 @@ pub mod builder {
let Self { client, body } = self; let Self { client, body } = self;
let body = body.map_err(Error::InvalidRequest)?; let body = body.map_err(Error::InvalidRequest)?;
let url = format!("{}/instance/state", client.baseurl,); let url = format!("{}/instance/state", client.baseurl,);
let request = client.client.put(url).json(&body).build()?; let request = client
.client
.put(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -2481,7 +2519,15 @@ pub mod builder {
.and_then(std::convert::TryInto::<types::InstanceStateMonitorRequest>::try_into) .and_then(std::convert::TryInto::<types::InstanceStateMonitorRequest>::try_into)
.map_err(Error::InvalidRequest)?; .map_err(Error::InvalidRequest)?;
let url = format!("{}/instance/state-monitor", client.baseurl,); let url = format!("{}/instance/state-monitor", client.baseurl,);
let request = client.client.get(url).json(&body).build()?; let request = client
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = client.client.execute(request).await; let result = client.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {

View File

@ -669,7 +669,14 @@ impl Client {
&'a self, &'a self,
) -> Result<ResponseValue<types::InstanceGetResponse>, Error<types::Error>> { ) -> Result<ResponseValue<types::InstanceGetResponse>, Error<types::Error>> {
let url = format!("{}/instance", self.baseurl,); let url = format!("{}/instance", self.baseurl,);
let request = self.client.get(url).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -690,7 +697,15 @@ impl Client {
body: &'a types::InstanceEnsureRequest, body: &'a types::InstanceEnsureRequest,
) -> Result<ResponseValue<types::InstanceEnsureResponse>, Error<types::Error>> { ) -> Result<ResponseValue<types::InstanceEnsureResponse>, Error<types::Error>> {
let url = format!("{}/instance", self.baseurl,); let url = format!("{}/instance", self.baseurl,);
let request = self.client.put(url).json(&body).build()?; let request = self
.client
.put(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -719,7 +734,14 @@ impl Client {
encode_path(&id.to_string()), encode_path(&id.to_string()),
encode_path(&snapshot_id.to_string()), encode_path(&snapshot_id.to_string()),
); );
let request = self.client.post(url).build()?; let request = self
.client
.post(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -740,7 +762,15 @@ impl Client {
body: &'a types::InstanceMigrateStatusRequest, body: &'a types::InstanceMigrateStatusRequest,
) -> Result<ResponseValue<types::InstanceMigrateStatusResponse>, Error<types::Error>> { ) -> Result<ResponseValue<types::InstanceMigrateStatusResponse>, Error<types::Error>> {
let url = format!("{}/instance/migrate/status", self.baseurl,); let url = format!("{}/instance/migrate/status", self.baseurl,);
let request = self.client.get(url).json(&body).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -789,7 +819,15 @@ impl Client {
body: types::InstanceStateRequested, body: types::InstanceStateRequested,
) -> Result<ResponseValue<()>, Error<types::Error>> { ) -> Result<ResponseValue<()>, Error<types::Error>> {
let url = format!("{}/instance/state", self.baseurl,); let url = format!("{}/instance/state", self.baseurl,);
let request = self.client.put(url).json(&body).build()?; let request = self
.client
.put(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {
@ -810,7 +848,15 @@ impl Client {
body: &'a types::InstanceStateMonitorRequest, body: &'a types::InstanceStateMonitorRequest,
) -> Result<ResponseValue<types::InstanceStateMonitorResponse>, Error<types::Error>> { ) -> Result<ResponseValue<types::InstanceStateMonitorResponse>, Error<types::Error>> {
let url = format!("{}/instance/state-monitor", self.baseurl,); let url = format!("{}/instance/state-monitor", self.baseurl,);
let request = self.client.get(url).json(&body).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.json(&body)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {

View File

@ -102,7 +102,15 @@ impl Client {
query.push(("if", if_.to_string())); query.push(("if", if_.to_string()));
query.push(("in", in_.to_string())); query.push(("in", in_.to_string()));
query.push(("use", use_.to_string())); query.push(("use", use_.to_string()));
let request = self.client.get(url).query(&query).build()?; let request = self
.client
.get(url)
.header(
reqwest::header::ACCEPT,
reqwest::header::HeaderValue::from_static("application/json"),
)
.query(&query)
.build()?;
let result = self.client.execute(request).await; let result = self.client.execute(request).await;
let response = result?; let response = result?;
match response.status().as_u16() { match response.status().as_u16() {