devops_armory/cloud/gcp/vpc/address/
create_internal.rs1use std::time::Duration;
2use super::models::IpAddress;
3
4pub async fn create_internal_address(
7 token: String,
8 project: String,
9 ip_name: String,
10 ip_address: String,
11 ip_prefix: String,
12 network_tier: String,
13 ip_version: String,
14 ip_address_type: String,
15 ip_address_purpose: String,
16 net_name: String
17) -> Result<(), std::io::Error> {
18
19 let parent_network_url = format!("https://www.googleapis.com/compute/v1/projects/{project}/global/networks/{net_name}");
20
21 let address_body: IpAddress = IpAddress {
22 name: ip_name,
23 address: ip_address,
24 prefixLength: ip_prefix,
25 networkTier: network_tier,
26 ipVersion: ip_version,
27 addressType: ip_address_type,
28 purpose: ip_address_purpose,
29 network: parent_network_url
30 };
31
32 let client = awc::Client::default();
33 let request = client.post(format!("https://compute.googleapis.com/compute/v1/projects/{project}/global/addresses"))
34 .bearer_auth(&token)
35 .insert_header(("Content-Type", "application/json"))
36 .timeout(Duration::from_secs(30))
37 .send_json(&address_body)
38 .await
39 .expect("Request POST new address could not been sent");
40
41 let mut req = request;
42 let req_status = req.status().as_u16();
43 let respone = req.body().await.unwrap_or_default();
44
45 match req_status {
46 200 => {
47 println!("Request has been successfull: Status: {:?}, {:?}", req_status, respone);
48 },
49 400 => {
50 println!("Bad Request. Check URL parameters or body: {:?}", respone);
51 },
52 403 => {
53 println!("You don't have access to perform such request: {:?}", respone);
54 }
55 404 => {
56 println!("Requested resource does not exists: {:?}", respone);
57 },
58 409 => {
59 println!("Requested resource already exists! {:?}", respone)
60 }
61 _ => {
62 println!("Request status mismatch. Check response: {:?}", respone);
63 }
64 }
65
66 Ok(())
67
68}
69