|
3 | 3 | use datadog_api_client::datadog;
|
4 | 4 | use datadog_api_client::datadogV1::api_synthetics::SyntheticsAPI;
|
5 | 5 | use datadog_api_client::datadogV1::model::SyntheticsAPIStep;
|
6 |
| -use datadog_api_client::datadogV1::model::SyntheticsAPIStepSubtype; |
7 | 6 | use datadog_api_client::datadogV1::model::SyntheticsAPITest;
|
8 | 7 | use datadog_api_client::datadogV1::model::SyntheticsAPITestConfig;
|
| 8 | +use datadog_api_client::datadogV1::model::SyntheticsAPITestStep; |
| 9 | +use datadog_api_client::datadogV1::model::SyntheticsAPITestStepSubtype; |
9 | 10 | use datadog_api_client::datadogV1::model::SyntheticsAPITestType;
|
| 11 | +use datadog_api_client::datadogV1::model::SyntheticsAPIWaitStep; |
| 12 | +use datadog_api_client::datadogV1::model::SyntheticsAPIWaitStepSubtype; |
10 | 13 | use datadog_api_client::datadogV1::model::SyntheticsAssertion;
|
11 | 14 | use datadog_api_client::datadogV1::model::SyntheticsAssertionOperator;
|
12 | 15 | use datadog_api_client::datadogV1::model::SyntheticsAssertionTarget;
|
@@ -40,71 +43,86 @@ async fn main() {
|
40 | 43 | )
|
41 | 44 | .steps(
|
42 | 45 | vec![
|
43 |
| - SyntheticsAPIStep::new( |
44 |
| - vec![ |
45 |
| - SyntheticsAssertion::SyntheticsAssertionTarget( |
46 |
| - Box::new( |
47 |
| - SyntheticsAssertionTarget::new( |
48 |
| - SyntheticsAssertionOperator::IS, |
49 |
| - Value::from(200), |
50 |
| - SyntheticsAssertionType::STATUS_CODE, |
51 |
| - ), |
52 |
| - ), |
53 |
| - ) |
54 |
| - ], |
55 |
| - "request is sent".to_string(), |
56 |
| - SyntheticsTestRequest::new() |
57 |
| - .http_version(SyntheticsTestOptionsHTTPVersion::HTTP2) |
58 |
| - .method("GET".to_string()) |
59 |
| - .timeout(10.0 as f64) |
60 |
| - .url("https://datadoghq.com".to_string()), |
61 |
| - SyntheticsAPIStepSubtype::HTTP, |
62 |
| - ) |
63 |
| - .allow_failure(true) |
64 |
| - .extracted_values( |
65 |
| - vec![ |
66 |
| - SyntheticsParsingOptions::new() |
67 |
| - .field("server".to_string()) |
68 |
| - .name("EXTRACTED_VALUE".to_string()) |
69 |
| - .parser( |
70 |
| - SyntheticsVariableParser::new(SyntheticsGlobalVariableParserType::RAW), |
| 46 | + SyntheticsAPIStep::SyntheticsAPITestStep( |
| 47 | + Box::new( |
| 48 | + SyntheticsAPITestStep::new( |
| 49 | + vec![ |
| 50 | + SyntheticsAssertion::SyntheticsAssertionTarget( |
| 51 | + Box::new( |
| 52 | + SyntheticsAssertionTarget::new( |
| 53 | + SyntheticsAssertionOperator::IS, |
| 54 | + Value::from(200), |
| 55 | + SyntheticsAssertionType::STATUS_CODE, |
| 56 | + ), |
| 57 | + ), |
71 | 58 | )
|
72 |
| - .secure(true) |
73 |
| - .type_(SyntheticsGlobalVariableParseTestOptionsType::HTTP_HEADER) |
74 |
| - ], |
75 |
| - ) |
76 |
| - .is_critical(true) |
77 |
| - .retry(SyntheticsTestOptionsRetry::new().count(5).interval(1000.0 as f64)), |
78 |
| - SyntheticsAPIStep::new( |
79 |
| - vec![ |
80 |
| - SyntheticsAssertion::SyntheticsAssertionTarget( |
81 |
| - Box::new( |
82 |
| - SyntheticsAssertionTarget::new( |
83 |
| - SyntheticsAssertionOperator::LESS_THAN, |
84 |
| - Value::from(1000), |
85 |
| - SyntheticsAssertionType::RESPONSE_TIME, |
86 |
| - ), |
87 |
| - ), |
| 59 | + ], |
| 60 | + "request is sent".to_string(), |
| 61 | + SyntheticsTestRequest::new() |
| 62 | + .http_version(SyntheticsTestOptionsHTTPVersion::HTTP2) |
| 63 | + .method("GET".to_string()) |
| 64 | + .timeout(10.0 as f64) |
| 65 | + .url("https://datadoghq.com".to_string()), |
| 66 | + SyntheticsAPITestStepSubtype::HTTP, |
88 | 67 | )
|
89 |
| - ], |
90 |
| - "GRPC CALL".to_string(), |
91 |
| - SyntheticsTestRequest::new() |
92 |
| - .call_type(SyntheticsTestCallType::UNARY) |
93 |
| - .compressed_json_descriptor( |
94 |
| - "eJy1lU1z2yAQhv+Lzj74I3ETH506bQ7OZOSm1w4Wa4epBARQppqM/3v5koCJJdvtxCdW77vPssCO3zMKUgHOFu/ZXvBiS6hZho/f8qe7pftYgXphWJrlA8XwxywEvNba+6PhkC2yVcVVswYp0R6ykRYlZ1SCV21SDrxsssPIeS9FJKqGfK2rqnmmSBwhWa2XlKgtaQPiDcRGCUDVfwGD2sKUqKEtc1cSoOrsMlaMOec1sySYCCgUYRSVLv2zSva2u+FQkB0pVkIw8bFuIudOOn3pOaKYVT3Iy97Pd0AYhOx5QcMsnxvRHlnuLf8ETDd3CNtrv2nejkDpRnANCmGkkFn/hsYzpBKE7jVbufgnKnV9HRM9zRPDDKPttYT61n0TdWkAAjggk9AhuxIeaXd69CYTcsGw7cBTakLVbNpRzGEgyWjkSOpMbZXkhGL6oX30R49qt3GoHrap7i0XdD41WQ+2icCNm5p1hmFqnHNlcla0riKmDZ183crDxChjbnurtxHPRE784sVhWvDfGP+SsTKibU3o5NtWHuZFGZOxP6P5VXqIOvaOSec4eYohyd7NslHuJbd1bewds85xYrNxkr2d+5IhFWF3NvaO684xjE2S5ulY+tu64Pna0fCPJgzw6vF5/WucLcYjt5xoq19O3UDptOg/OamJQRaCcPPnMTQ2QDFn+uhPvUfnCrMc99upyQY4Ui9Dlc/YoG3R/v4Cs9YE+g==".to_string(), |
| 68 | + .allow_failure(true) |
| 69 | + .extracted_values( |
| 70 | + vec![ |
| 71 | + SyntheticsParsingOptions::new() |
| 72 | + .field("server".to_string()) |
| 73 | + .name("EXTRACTED_VALUE".to_string()) |
| 74 | + .parser( |
| 75 | + SyntheticsVariableParser::new( |
| 76 | + SyntheticsGlobalVariableParserType::RAW, |
| 77 | + ), |
| 78 | + ) |
| 79 | + .secure(true) |
| 80 | + .type_(SyntheticsGlobalVariableParseTestOptionsType::HTTP_HEADER) |
| 81 | + ], |
| 82 | + ) |
| 83 | + .is_critical(true) |
| 84 | + .retry(SyntheticsTestOptionsRetry::new().count(5).interval(1000.0 as f64)), |
| 85 | + ), |
| 86 | + ), |
| 87 | + SyntheticsAPIStep::SyntheticsAPIWaitStep( |
| 88 | + Box::new( |
| 89 | + SyntheticsAPIWaitStep::new("Wait".to_string(), SyntheticsAPIWaitStepSubtype::WAIT, 1), |
| 90 | + ), |
| 91 | + ), |
| 92 | + SyntheticsAPIStep::SyntheticsAPITestStep( |
| 93 | + Box::new( |
| 94 | + SyntheticsAPITestStep::new( |
| 95 | + vec![ |
| 96 | + SyntheticsAssertion::SyntheticsAssertionTarget( |
| 97 | + Box::new( |
| 98 | + SyntheticsAssertionTarget::new( |
| 99 | + SyntheticsAssertionOperator::LESS_THAN, |
| 100 | + Value::from(1000), |
| 101 | + SyntheticsAssertionType::RESPONSE_TIME, |
| 102 | + ), |
| 103 | + ), |
| 104 | + ) |
| 105 | + ], |
| 106 | + "GRPC CALL".to_string(), |
| 107 | + SyntheticsTestRequest::new() |
| 108 | + .call_type(SyntheticsTestCallType::UNARY) |
| 109 | + .compressed_json_descriptor( |
| 110 | + "eJy1lU1z2yAQhv+Lzj74I3ETH506bQ7OZOSm1w4Wa4epBARQppqM/3v5koCJJdvtxCdW77vPssCO3zMKUgHOFu/ZXvBiS6hZho/f8qe7pftYgXphWJrlA8XwxywEvNba+6PhkC2yVcVVswYp0R6ykRYlZ1SCV21SDrxsssPIeS9FJKqGfK2rqnmmSBwhWa2XlKgtaQPiDcRGCUDVfwGD2sKUqKEtc1cSoOrsMlaMOec1sySYCCgUYRSVLv2zSva2u+FQkB0pVkIw8bFuIudOOn3pOaKYVT3Iy97Pd0AYhOx5QcMsnxvRHlnuLf8ETDd3CNtrv2nejkDpRnANCmGkkFn/hsYzpBKE7jVbufgnKnV9HRM9zRPDDKPttYT61n0TdWkAAjggk9AhuxIeaXd69CYTcsGw7cBTakLVbNpRzGEgyWjkSOpMbZXkhGL6oX30R49qt3GoHrap7i0XdD41WQ+2icCNm5p1hmFqnHNlcla0riKmDZ183crDxChjbnurtxHPRE784sVhWvDfGP+SsTKibU3o5NtWHuZFGZOxP6P5VXqIOvaOSec4eYohyd7NslHuJbd1bewds85xYrNxkr2d+5IhFWF3NvaO684xjE2S5ulY+tu64Pna0fCPJgzw6vF5/WucLcYjt5xoq19O3UDptOg/OamJQRaCcPPnMTQ2QDFn+uhPvUfnCrMc99upyQY4Ui9Dlc/YoG3R/v4Cs9YE+g==".to_string(), |
| 111 | + ) |
| 112 | + .host("grpcbin.test.k6.io".to_string()) |
| 113 | + .message("{}".to_string()) |
| 114 | + .metadata(BTreeMap::from([])) |
| 115 | + .method("Index".to_string()) |
| 116 | + .port(9000) |
| 117 | + .service("grpcbin.GRPCBin".to_string()), |
| 118 | + SyntheticsAPITestStepSubtype::GRPC, |
95 | 119 | )
|
96 |
| - .host("grpcbin.test.k6.io".to_string()) |
97 |
| - .message("{}".to_string()) |
98 |
| - .metadata(BTreeMap::from([])) |
99 |
| - .method("Index".to_string()) |
100 |
| - .port(9000) |
101 |
| - .service("grpcbin.GRPCBin".to_string()), |
102 |
| - SyntheticsAPIStepSubtype::GRPC, |
| 120 | + .allow_failure(false) |
| 121 | + .extracted_values(vec![]) |
| 122 | + .is_critical(true) |
| 123 | + .retry(SyntheticsTestOptionsRetry::new().count(0).interval(300.0 as f64)), |
| 124 | + ), |
103 | 125 | )
|
104 |
| - .allow_failure(false) |
105 |
| - .extracted_values(vec![]) |
106 |
| - .is_critical(true) |
107 |
| - .retry(SyntheticsTestOptionsRetry::new().count(0).interval(300.0 as f64)) |
108 | 126 | ],
|
109 | 127 | ),
|
110 | 128 | vec!["aws:us-east-2".to_string()],
|
|
0 commit comments