Skip to content

Commit 9f12600

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit 73c1307 of spec repo
1 parent 4a2aea3 commit 9f12600

File tree

72 files changed

+9771
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

72 files changed

+9771
-0
lines changed

.generator/schemas/v2/openapi.yaml

Lines changed: 1065 additions & 0 deletions
Large diffs are not rendered by default.
Lines changed: 48 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,48 @@
1+
// Create connection returns "Connection created successfully" response
2+
use datadog_api_client::datadog;
3+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
4+
use datadog_api_client::datadogV2::model::CreateConnectionRequest;
5+
use datadog_api_client::datadogV2::model::CreateConnectionRequestData;
6+
use datadog_api_client::datadogV2::model::CreateConnectionRequestDataAttributes;
7+
use datadog_api_client::datadogV2::model::CreateConnectionRequestDataAttributesFieldsItems;
8+
use datadog_api_client::datadogV2::model::UpdateConnectionRequestDataType;
9+
10+
#[tokio::main]
11+
async fn main() {
12+
let body = CreateConnectionRequest::new().data(
13+
CreateConnectionRequestData::new(UpdateConnectionRequestDataType::CONNECTION_ID)
14+
.attributes(
15+
CreateConnectionRequestDataAttributes::new(
16+
"user_email".to_string(),
17+
"email".to_string(),
18+
"ref_table".to_string(),
19+
)
20+
.fields(vec![
21+
CreateConnectionRequestDataAttributesFieldsItems::new(
22+
"customer_tier".to_string(),
23+
"subscription_tier".to_string(),
24+
"string".to_string(),
25+
)
26+
.description(r#"Customer subscription tier from `CRM`"#.to_string())
27+
.display_name("Customer Tier".to_string()),
28+
CreateConnectionRequestDataAttributesFieldsItems::new(
29+
"lifetime_value".to_string(),
30+
"ltv".to_string(),
31+
"number".to_string(),
32+
)
33+
.description(r#"Customer lifetime value in `USD`"#.to_string())
34+
.display_name("Lifetime Value".to_string()),
35+
]),
36+
)
37+
.id("crm-integration".to_string()),
38+
);
39+
let mut configuration = datadog::Configuration::new();
40+
configuration.set_unstable_operation_enabled("v2.CreateConnection", true);
41+
let api = RumAudienceManagementAPI::with_config(configuration);
42+
let resp = api.create_connection("users".to_string(), body).await;
43+
if let Ok(value) = resp {
44+
println!("{:#?}", value);
45+
} else {
46+
println!("{:#?}", resp.unwrap_err());
47+
}
48+
}
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
// Delete connection returns "Connection deleted successfully" response
2+
use datadog_api_client::datadog;
3+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
4+
5+
#[tokio::main]
6+
async fn main() {
7+
let mut configuration = datadog::Configuration::new();
8+
configuration.set_unstable_operation_enabled("v2.DeleteConnection", true);
9+
let api = RumAudienceManagementAPI::with_config(configuration);
10+
let resp = api
11+
.delete_connection("connection-id-123".to_string(), "users".to_string())
12+
.await;
13+
if let Ok(value) = resp {
14+
println!("{:#?}", value);
15+
} else {
16+
println!("{:#?}", resp.unwrap_err());
17+
}
18+
}
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
// Get account facet info returns "Successful response with facet information"
2+
// response
3+
use datadog_api_client::datadog;
4+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
5+
use datadog_api_client::datadogV2::model::FacetInfoRequest;
6+
use datadog_api_client::datadogV2::model::FacetInfoRequestData;
7+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataAttributes;
8+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataAttributesSearch;
9+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataAttributesTermSearch;
10+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataType;
11+
12+
#[tokio::main]
13+
async fn main() {
14+
let body = FacetInfoRequest::new().data(
15+
FacetInfoRequestData::new(FacetInfoRequestDataType::USERS_FACET_INFO_REQUEST)
16+
.attributes(
17+
FacetInfoRequestDataAttributes::new("first_browser_name".to_string(), 10)
18+
.search(
19+
FacetInfoRequestDataAttributesSearch::new()
20+
.query("user_org_id:5001 AND first_country_code:US".to_string()),
21+
)
22+
.term_search(
23+
FacetInfoRequestDataAttributesTermSearch::new().value("Chrome".to_string()),
24+
),
25+
)
26+
.id("facet_info_request".to_string()),
27+
);
28+
let mut configuration = datadog::Configuration::new();
29+
configuration.set_unstable_operation_enabled("v2.GetAccountFacetInfo", true);
30+
let api = RumAudienceManagementAPI::with_config(configuration);
31+
let resp = api.get_account_facet_info(body).await;
32+
if let Ok(value) = resp {
33+
println!("{:#?}", value);
34+
} else {
35+
println!("{:#?}", resp.unwrap_err());
36+
}
37+
}
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
// Get mapping returns "Successful response with entity mapping configuration"
2+
// response
3+
use datadog_api_client::datadog;
4+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
5+
6+
#[tokio::main]
7+
async fn main() {
8+
let mut configuration = datadog::Configuration::new();
9+
configuration.set_unstable_operation_enabled("v2.GetMapping", true);
10+
let api = RumAudienceManagementAPI::with_config(configuration);
11+
let resp = api.get_mapping("users".to_string()).await;
12+
if let Ok(value) = resp {
13+
println!("{:#?}", value);
14+
} else {
15+
println!("{:#?}", resp.unwrap_err());
16+
}
17+
}
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
// Get user facet info returns "Successful response with facet information"
2+
// response
3+
use datadog_api_client::datadog;
4+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
5+
use datadog_api_client::datadogV2::model::FacetInfoRequest;
6+
use datadog_api_client::datadogV2::model::FacetInfoRequestData;
7+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataAttributes;
8+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataAttributesSearch;
9+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataAttributesTermSearch;
10+
use datadog_api_client::datadogV2::model::FacetInfoRequestDataType;
11+
12+
#[tokio::main]
13+
async fn main() {
14+
let body = FacetInfoRequest::new().data(
15+
FacetInfoRequestData::new(FacetInfoRequestDataType::USERS_FACET_INFO_REQUEST)
16+
.attributes(
17+
FacetInfoRequestDataAttributes::new("first_browser_name".to_string(), 10)
18+
.search(
19+
FacetInfoRequestDataAttributesSearch::new()
20+
.query("user_org_id:5001 AND first_country_code:US".to_string()),
21+
)
22+
.term_search(
23+
FacetInfoRequestDataAttributesTermSearch::new().value("Chrome".to_string()),
24+
),
25+
)
26+
.id("facet_info_request".to_string()),
27+
);
28+
let mut configuration = datadog::Configuration::new();
29+
configuration.set_unstable_operation_enabled("v2.GetUserFacetInfo", true);
30+
let api = RumAudienceManagementAPI::with_config(configuration);
31+
let resp = api.get_user_facet_info(body).await;
32+
if let Ok(value) = resp {
33+
println!("{:#?}", value);
34+
} else {
35+
println!("{:#?}", resp.unwrap_err());
36+
}
37+
}
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
// List connections returns "Successful response with list of connections" response
2+
use datadog_api_client::datadog;
3+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
4+
5+
#[tokio::main]
6+
async fn main() {
7+
let mut configuration = datadog::Configuration::new();
8+
configuration.set_unstable_operation_enabled("v2.ListConnections", true);
9+
let api = RumAudienceManagementAPI::with_config(configuration);
10+
let resp = api.list_connections("users".to_string()).await;
11+
if let Ok(value) = resp {
12+
println!("{:#?}", value);
13+
} else {
14+
println!("{:#?}", resp.unwrap_err());
15+
}
16+
}
Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
// Query accounts returns "Successful response with account data" response
2+
use datadog_api_client::datadog;
3+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
4+
use datadog_api_client::datadogV2::model::QueryAccountRequest;
5+
use datadog_api_client::datadogV2::model::QueryAccountRequestData;
6+
use datadog_api_client::datadogV2::model::QueryAccountRequestDataAttributes;
7+
use datadog_api_client::datadogV2::model::QueryAccountRequestDataAttributesSort;
8+
use datadog_api_client::datadogV2::model::QueryAccountRequestDataType;
9+
10+
#[tokio::main]
11+
async fn main() {
12+
let body = QueryAccountRequest::new().data(
13+
QueryAccountRequestData::new(QueryAccountRequestDataType::QUERY_ACCOUNT_REQUEST)
14+
.attributes(
15+
QueryAccountRequestDataAttributes::new()
16+
.limit(20)
17+
.query(
18+
"plan_type:enterprise AND user_count:>100 AND subscription_status:active"
19+
.to_string(),
20+
)
21+
.select_columns(vec![
22+
"account_id".to_string(),
23+
"account_name".to_string(),
24+
"user_count".to_string(),
25+
"plan_type".to_string(),
26+
"subscription_status".to_string(),
27+
"created_at".to_string(),
28+
"mrr".to_string(),
29+
"industry".to_string(),
30+
])
31+
.sort(
32+
QueryAccountRequestDataAttributesSort::new()
33+
.field("user_count".to_string())
34+
.order("DESC".to_string()),
35+
)
36+
.wildcard_search_term("tech".to_string()),
37+
)
38+
.id("query_account_request".to_string()),
39+
);
40+
let mut configuration = datadog::Configuration::new();
41+
configuration.set_unstable_operation_enabled("v2.QueryAccounts", true);
42+
let api = RumAudienceManagementAPI::with_config(configuration);
43+
let resp = api.query_accounts(body).await;
44+
if let Ok(value) = resp {
45+
println!("{:#?}", value);
46+
} else {
47+
println!("{:#?}", resp.unwrap_err());
48+
}
49+
}
Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
// Query event filtered users returns "Successful response with filtered user
2+
// data" response
3+
use datadog_api_client::datadog;
4+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
5+
use datadog_api_client::datadogV2::model::QueryEventFilteredUsersRequest;
6+
use datadog_api_client::datadogV2::model::QueryEventFilteredUsersRequestData;
7+
use datadog_api_client::datadogV2::model::QueryEventFilteredUsersRequestDataAttributes;
8+
use datadog_api_client::datadogV2::model::QueryEventFilteredUsersRequestDataAttributesEventQuery;
9+
use datadog_api_client::datadogV2::model::QueryEventFilteredUsersRequestDataAttributesEventQueryTimeFrame;
10+
use datadog_api_client::datadogV2::model::QueryEventFilteredUsersRequestDataType;
11+
12+
#[tokio::main]
13+
async fn main() {
14+
let body =
15+
QueryEventFilteredUsersRequest
16+
::new().data(
17+
QueryEventFilteredUsersRequestData::new(
18+
QueryEventFilteredUsersRequestDataType::QUERY_EVENT_FILTERED_USERS_REQUEST,
19+
)
20+
.attributes(
21+
QueryEventFilteredUsersRequestDataAttributes::new()
22+
.event_query(
23+
QueryEventFilteredUsersRequestDataAttributesEventQuery::new()
24+
.query(
25+
"@type:view AND @view.loading_time:>3000 AND @application.name:ecommerce-platform".to_string(),
26+
)
27+
.time_frame(
28+
QueryEventFilteredUsersRequestDataAttributesEventQueryTimeFrame::new()
29+
.end(1761309676)
30+
.start(1760100076),
31+
),
32+
)
33+
.include_row_count(true)
34+
.limit(25)
35+
.query("user_org_id:5001 AND first_country_code:US AND first_browser_name:Chrome".to_string())
36+
.select_columns(
37+
vec![
38+
"user_id".to_string(),
39+
"user_email".to_string(),
40+
"first_country_code".to_string(),
41+
"first_browser_name".to_string(),
42+
"events_count".to_string(),
43+
"session_count".to_string(),
44+
"error_count".to_string(),
45+
"avg_loading_time".to_string()
46+
],
47+
),
48+
)
49+
.id("query_event_filtered_users_request".to_string()),
50+
);
51+
let mut configuration = datadog::Configuration::new();
52+
configuration.set_unstable_operation_enabled("v2.QueryEventFilteredUsers", true);
53+
let api = RumAudienceManagementAPI::with_config(configuration);
54+
let resp = api.query_event_filtered_users(body).await;
55+
if let Ok(value) = resp {
56+
println!("{:#?}", value);
57+
} else {
58+
println!("{:#?}", resp.unwrap_err());
59+
}
60+
}
Lines changed: 52 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,52 @@
1+
// Query users returns "Successful response with user data" response
2+
use datadog_api_client::datadog;
3+
use datadog_api_client::datadogV2::api_rum_audience_management::RumAudienceManagementAPI;
4+
use datadog_api_client::datadogV2::model::QueryUsersRequest;
5+
use datadog_api_client::datadogV2::model::QueryUsersRequestData;
6+
use datadog_api_client::datadogV2::model::QueryUsersRequestDataAttributes;
7+
use datadog_api_client::datadogV2::model::QueryUsersRequestDataAttributesSort;
8+
use datadog_api_client::datadogV2::model::QueryUsersRequestDataType;
9+
10+
#[tokio::main]
11+
async fn main() {
12+
let body =
13+
QueryUsersRequest
14+
::new().data(
15+
QueryUsersRequestData::new(QueryUsersRequestDataType::QUERY_USERS_REQUEST)
16+
.attributes(
17+
QueryUsersRequestDataAttributes::new()
18+
.limit(25)
19+
.query(
20+
"user_email:*@techcorp.com AND first_country_code:US AND first_browser_name:Chrome".to_string(),
21+
)
22+
.select_columns(
23+
vec![
24+
"user_id".to_string(),
25+
"user_email".to_string(),
26+
"user_name".to_string(),
27+
"user_org_id".to_string(),
28+
"first_country_code".to_string(),
29+
"first_browser_name".to_string(),
30+
"first_device_type".to_string(),
31+
"last_seen".to_string()
32+
],
33+
)
34+
.sort(
35+
QueryUsersRequestDataAttributesSort::new()
36+
.field("first_seen".to_string())
37+
.order("DESC".to_string()),
38+
)
39+
.wildcard_search_term("john".to_string()),
40+
)
41+
.id("query_users_request".to_string()),
42+
);
43+
let mut configuration = datadog::Configuration::new();
44+
configuration.set_unstable_operation_enabled("v2.QueryUsers", true);
45+
let api = RumAudienceManagementAPI::with_config(configuration);
46+
let resp = api.query_users(body).await;
47+
if let Ok(value) = resp {
48+
println!("{:#?}", value);
49+
} else {
50+
println!("{:#?}", resp.unwrap_err());
51+
}
52+
}

0 commit comments

Comments
 (0)