Sync 'audience_management.yaml' files with backend

examples/v2/rum-audience-management/CreateConnection.java

@@ -0,0 +1,55 @@
+// Create connection returns "Connection created successfully" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+import com.datadog.api.client.v2.model.CreateConnectionRequest;
+import com.datadog.api.client.v2.model.CreateConnectionRequestData;
+import com.datadog.api.client.v2.model.CreateConnectionRequestDataAttributes;
+import com.datadog.api.client.v2.model.CreateConnectionRequestDataAttributesFieldsItems;
+import com.datadog.api.client.v2.model.UpdateConnectionRequestDataType;
+import java.util.Arrays;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.createConnection", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    CreateConnectionRequest body =
+        new CreateConnectionRequest()
+            .data(
+                new CreateConnectionRequestData()
+                    .attributes(
+                        new CreateConnectionRequestDataAttributes()
+                            .fields(
+                                Arrays.asList(
+                                    new CreateConnectionRequestDataAttributesFieldsItems()
+                                        .description("Customer subscription tier from `CRM`")
+                                        .displayName("Customer Tier")
+                                        .id("customer_tier")
+                                        .sourceName("subscription_tier")
+                                        .type("string"),
+                                    new CreateConnectionRequestDataAttributesFieldsItems()
+                                        .description("Customer lifetime value in `USD`")
+                                        .displayName("Lifetime Value")
+                                        .id("lifetime_value")
+                                        .sourceName("ltv")
+                                        .type("number")))
+                            .joinAttribute("user_email")
+                            .joinType("email")
+                            .type("ref_table"))
+                    .id("crm-integration")
+                    .type(UpdateConnectionRequestDataType.CONNECTION_ID));
+
+    try {
+      apiInstance.createConnection("users", body);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#createConnection");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

examples/v2/rum-audience-management/DeleteConnection.java

@@ -0,0 +1,23 @@
+// Delete connection returns "Connection deleted successfully" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.deleteConnection", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    try {
+      apiInstance.deleteConnection("connection-id-123", "users");
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#deleteConnection");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

examples/v2/rum-audience-management/GetAccountFacetInfo.java

@@ -0,0 +1,47 @@
+// Get account facet info returns "Successful response with facet information" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+import com.datadog.api.client.v2.model.FacetInfoRequest;
+import com.datadog.api.client.v2.model.FacetInfoRequestData;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataAttributes;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataAttributesSearch;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataAttributesTermSearch;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataType;
+import com.datadog.api.client.v2.model.FacetInfoResponse;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.getAccountFacetInfo", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    FacetInfoRequest body =
+        new FacetInfoRequest()
+            .data(
+                new FacetInfoRequestData()
+                    .attributes(
+                        new FacetInfoRequestDataAttributes()
+                            .facetId("first_browser_name")
+                            .limit(10L)
+                            .search(
+                                new FacetInfoRequestDataAttributesSearch()
+                                    .query("user_org_id:5001 AND first_country_code:US"))
+                            .termSearch(
+                                new FacetInfoRequestDataAttributesTermSearch().value("Chrome")))
+                    .id("facet_info_request")
+                    .type(FacetInfoRequestDataType.USERS_FACET_INFO_REQUEST));
+
+    try {
+      FacetInfoResponse result = apiInstance.getAccountFacetInfo(body);
+      System.out.println(result);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#getAccountFacetInfo");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

examples/v2/rum-audience-management/GetMapping.java

@@ -0,0 +1,25 @@
+// Get mapping returns "Successful response with entity mapping configuration" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+import com.datadog.api.client.v2.model.GetMappingResponse;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.getMapping", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    try {
+      GetMappingResponse result = apiInstance.getMapping("users");
+      System.out.println(result);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#getMapping");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

examples/v2/rum-audience-management/GetUserFacetInfo.java

@@ -0,0 +1,47 @@
+// Get user facet info returns "Successful response with facet information" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+import com.datadog.api.client.v2.model.FacetInfoRequest;
+import com.datadog.api.client.v2.model.FacetInfoRequestData;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataAttributes;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataAttributesSearch;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataAttributesTermSearch;
+import com.datadog.api.client.v2.model.FacetInfoRequestDataType;
+import com.datadog.api.client.v2.model.FacetInfoResponse;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.getUserFacetInfo", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    FacetInfoRequest body =
+        new FacetInfoRequest()
+            .data(
+                new FacetInfoRequestData()
+                    .attributes(
+                        new FacetInfoRequestDataAttributes()
+                            .facetId("first_browser_name")
+                            .limit(10L)
+                            .search(
+                                new FacetInfoRequestDataAttributesSearch()
+                                    .query("user_org_id:5001 AND first_country_code:US"))
+                            .termSearch(
+                                new FacetInfoRequestDataAttributesTermSearch().value("Chrome")))
+                    .id("facet_info_request")
+                    .type(FacetInfoRequestDataType.USERS_FACET_INFO_REQUEST));
+
+    try {
+      FacetInfoResponse result = apiInstance.getUserFacetInfo(body);
+      System.out.println(result);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#getUserFacetInfo");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

examples/v2/rum-audience-management/ListConnections.java

@@ -0,0 +1,25 @@
+// List connections returns "Successful response with list of connections" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+import com.datadog.api.client.v2.model.ListConnectionsResponse;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.listConnections", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    try {
+      ListConnectionsResponse result = apiInstance.listConnections("users");
+      System.out.println(result);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#listConnections");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

examples/v2/rum-audience-management/QueryAccounts.java

@@ -0,0 +1,59 @@
+// Query accounts returns "Successful response with account data" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+import com.datadog.api.client.v2.model.QueryAccountRequest;
+import com.datadog.api.client.v2.model.QueryAccountRequestData;
+import com.datadog.api.client.v2.model.QueryAccountRequestDataAttributes;
+import com.datadog.api.client.v2.model.QueryAccountRequestDataAttributesSort;
+import com.datadog.api.client.v2.model.QueryAccountRequestDataType;
+import com.datadog.api.client.v2.model.QueryResponse;
+import java.util.Arrays;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.queryAccounts", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    QueryAccountRequest body =
+        new QueryAccountRequest()
+            .data(
+                new QueryAccountRequestData()
+                    .attributes(
+                        new QueryAccountRequestDataAttributes()
+                            .limit(20L)
+                            .query(
+                                "plan_type:enterprise AND user_count:>100 AND"
+                                    + " subscription_status:active")
+                            .selectColumns(
+                                Arrays.asList(
+                                    "account_id",
+                                    "account_name",
+                                    "user_count",
+                                    "plan_type",
+                                    "subscription_status",
+                                    "created_at",
+                                    "mrr",
+                                    "industry"))
+                            .sort(
+                                new QueryAccountRequestDataAttributesSort()
+                                    .field("user_count")
+                                    .order("DESC"))
+                            .wildcardSearchTerm("tech"))
+                    .id("query_account_request")
+                    .type(QueryAccountRequestDataType.QUERY_ACCOUNT_REQUEST));
+
+    try {
+      QueryResponse result = apiInstance.queryAccounts(body);
+      System.out.println(result);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#queryAccounts");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

examples/v2/rum-audience-management/QueryEventFilteredUsers.java

@@ -0,0 +1,66 @@
+// Query event filtered users returns "Successful response with filtered user data" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.RumAudienceManagementApi;
+import com.datadog.api.client.v2.model.QueryEventFilteredUsersRequest;
+import com.datadog.api.client.v2.model.QueryEventFilteredUsersRequestData;
+import com.datadog.api.client.v2.model.QueryEventFilteredUsersRequestDataAttributes;
+import com.datadog.api.client.v2.model.QueryEventFilteredUsersRequestDataAttributesEventQuery;
+import com.datadog.api.client.v2.model.QueryEventFilteredUsersRequestDataAttributesEventQueryTimeFrame;
+import com.datadog.api.client.v2.model.QueryEventFilteredUsersRequestDataType;
+import com.datadog.api.client.v2.model.QueryResponse;
+import java.util.Arrays;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    defaultClient.setUnstableOperationEnabled("v2.queryEventFilteredUsers", true);
+    RumAudienceManagementApi apiInstance = new RumAudienceManagementApi(defaultClient);
+
+    QueryEventFilteredUsersRequest body =
+        new QueryEventFilteredUsersRequest()
+            .data(
+                new QueryEventFilteredUsersRequestData()
+                    .attributes(
+                        new QueryEventFilteredUsersRequestDataAttributes()
+                            .eventQuery(
+                                new QueryEventFilteredUsersRequestDataAttributesEventQuery()
+                                    .query(
+                                        "@type:view AND @view.loading_time:>3000 AND"
+                                            + " @application.name:ecommerce-platform")
+                                    .timeFrame(
+                                        new QueryEventFilteredUsersRequestDataAttributesEventQueryTimeFrame()
+                                            .end(1761309676L)
+                                            .start(1760100076L)))
+                            .includeRowCount(true)
+                            .limit(25L)
+                            .query(
+                                "user_org_id:5001 AND first_country_code:US AND"
+                                    + " first_browser_name:Chrome")
+                            .selectColumns(
+                                Arrays.asList(
+                                    "user_id",
+                                    "user_email",
+                                    "first_country_code",
+                                    "first_browser_name",
+                                    "events_count",
+                                    "session_count",
+                                    "error_count",
+                                    "avg_loading_time")))
+                    .id("query_event_filtered_users_request")
+                    .type(
+                        QueryEventFilteredUsersRequestDataType.QUERY_EVENT_FILTERED_USERS_REQUEST));
+
+    try {
+      QueryResponse result = apiInstance.queryEventFilteredUsers(body);
+      System.out.println(result);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling RumAudienceManagementApi#queryEventFilteredUsers");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}