pub struct RUMAPI { /* private fields */ }
Expand description
Manage your Real User Monitoring (RUM) applications, and search or aggregate your RUM events over HTTP. See the RUM & Session Replay page for more information
Implementations§
Source§impl RUMAPI
impl RUMAPI
pub fn new() -> Self
Sourcepub fn with_config(config: Configuration) -> Self
pub fn with_config(config: Configuration) -> Self
Examples found in repository?
More examples
7async fn main() {
8 let configuration = datadog::Configuration::new();
9 let api = RUMAPI::with_config(configuration);
10 let resp = api
11 .list_rum_events(ListRUMEventsOptionalParams::default())
12 .await;
13 if let Ok(value) = resp {
14 println!("{:#?}", value);
15 } else {
16 println!("{:#?}", resp.unwrap_err());
17 }
18}
9async fn main() {
10 let configuration = datadog::Configuration::new();
11 let api = RUMAPI::with_config(configuration);
12 let response =
13 api.list_rum_events_with_pagination(ListRUMEventsOptionalParams::default().page_limit(2));
14 pin_mut!(response);
15 while let Some(resp) = response.next().await {
16 if let Ok(value) = resp {
17 println!("{:#?}", value);
18 } else {
19 println!("{:#?}", resp.unwrap_err());
20 }
21 }
22}
6async fn main() {
7 // there is a valid "rum_application" in the system
8 let rum_application_data_id = std::env::var("RUM_APPLICATION_DATA_ID").unwrap();
9 let configuration = datadog::Configuration::new();
10 let api = RUMAPI::with_config(configuration);
11 let resp = api
12 .get_rum_application(rum_application_data_id.clone())
13 .await;
14 if let Ok(value) = resp {
15 println!("{:#?}", value);
16 } else {
17 println!("{:#?}", resp.unwrap_err());
18 }
19}
6async fn main() {
7 // there is a valid "rum_application" in the system
8 let rum_application_data_id = std::env::var("RUM_APPLICATION_DATA_ID").unwrap();
9 let configuration = datadog::Configuration::new();
10 let api = RUMAPI::with_config(configuration);
11 let resp = api
12 .delete_rum_application(rum_application_data_id.clone())
13 .await;
14 if let Ok(value) = resp {
15 println!("{:#?}", value);
16 } else {
17 println!("{:#?}", resp.unwrap_err());
18 }
19}
10async fn main() {
11 let body = RUMApplicationCreateRequest::new(RUMApplicationCreate::new(
12 RUMApplicationCreateAttributes::new("test-rum-5c67ebb32077e1d9".to_string())
13 .type_("ios".to_string()),
14 RUMApplicationCreateType::RUM_APPLICATION_CREATE,
15 ));
16 let configuration = datadog::Configuration::new();
17 let api = RUMAPI::with_config(configuration);
18 let resp = api.create_rum_application(body).await;
19 if let Ok(value) = resp {
20 println!("{:#?}", value);
21 } else {
22 println!("{:#?}", resp.unwrap_err());
23 }
24}
pub fn with_client_and_config( config: Configuration, client: ClientWithMiddleware, ) -> Self
Sourcepub async fn aggregate_rum_events(
&self,
body: RUMAggregateRequest,
) -> Result<RUMAnalyticsAggregateResponse, Error<AggregateRUMEventsError>>
pub async fn aggregate_rum_events( &self, body: RUMAggregateRequest, ) -> Result<RUMAnalyticsAggregateResponse, Error<AggregateRUMEventsError>>
The API endpoint to aggregate RUM events into buckets of computed metrics and timeseries.
Examples found in repository?
15async fn main() {
16 let body = RUMAggregateRequest::new()
17 .compute(vec![RUMCompute::new(RUMAggregationFunction::PERCENTILE_90)
18 .metric("@view.time_spent".to_string())
19 .type_(RUMComputeType::TOTAL)])
20 .filter(
21 RUMQueryFilter::new()
22 .from("now-15m".to_string())
23 .query("@type:view AND @session.type:user".to_string())
24 .to("now".to_string()),
25 )
26 .group_by(vec![RUMGroupBy::new("@view.time_spent".to_string())
27 .limit(10)
28 .total(RUMGroupByTotal::RUMGroupByTotalBoolean(false))])
29 .options(RUMQueryOptions::new().timezone("GMT".to_string()))
30 .page(RUMQueryPageOptions::new().limit(25));
31 let configuration = datadog::Configuration::new();
32 let api = RUMAPI::with_config(configuration);
33 let resp = api.aggregate_rum_events(body).await;
34 if let Ok(value) = resp {
35 println!("{:#?}", value);
36 } else {
37 println!("{:#?}", resp.unwrap_err());
38 }
39}
Sourcepub async fn aggregate_rum_events_with_http_info(
&self,
body: RUMAggregateRequest,
) -> Result<ResponseContent<RUMAnalyticsAggregateResponse>, Error<AggregateRUMEventsError>>
pub async fn aggregate_rum_events_with_http_info( &self, body: RUMAggregateRequest, ) -> Result<ResponseContent<RUMAnalyticsAggregateResponse>, Error<AggregateRUMEventsError>>
The API endpoint to aggregate RUM events into buckets of computed metrics and timeseries.
Sourcepub async fn create_rum_application(
&self,
body: RUMApplicationCreateRequest,
) -> Result<RUMApplicationResponse, Error<CreateRUMApplicationError>>
pub async fn create_rum_application( &self, body: RUMApplicationCreateRequest, ) -> Result<RUMApplicationResponse, Error<CreateRUMApplicationError>>
Create a new RUM application in your organization.
Examples found in repository?
10async fn main() {
11 let body = RUMApplicationCreateRequest::new(RUMApplicationCreate::new(
12 RUMApplicationCreateAttributes::new("test-rum-5c67ebb32077e1d9".to_string())
13 .type_("ios".to_string()),
14 RUMApplicationCreateType::RUM_APPLICATION_CREATE,
15 ));
16 let configuration = datadog::Configuration::new();
17 let api = RUMAPI::with_config(configuration);
18 let resp = api.create_rum_application(body).await;
19 if let Ok(value) = resp {
20 println!("{:#?}", value);
21 } else {
22 println!("{:#?}", resp.unwrap_err());
23 }
24}
Sourcepub async fn create_rum_application_with_http_info(
&self,
body: RUMApplicationCreateRequest,
) -> Result<ResponseContent<RUMApplicationResponse>, Error<CreateRUMApplicationError>>
pub async fn create_rum_application_with_http_info( &self, body: RUMApplicationCreateRequest, ) -> Result<ResponseContent<RUMApplicationResponse>, Error<CreateRUMApplicationError>>
Create a new RUM application in your organization.
Sourcepub async fn delete_rum_application(
&self,
id: String,
) -> Result<(), Error<DeleteRUMApplicationError>>
pub async fn delete_rum_application( &self, id: String, ) -> Result<(), Error<DeleteRUMApplicationError>>
Delete an existing RUM application in your organization.
Examples found in repository?
6async fn main() {
7 // there is a valid "rum_application" in the system
8 let rum_application_data_id = std::env::var("RUM_APPLICATION_DATA_ID").unwrap();
9 let configuration = datadog::Configuration::new();
10 let api = RUMAPI::with_config(configuration);
11 let resp = api
12 .delete_rum_application(rum_application_data_id.clone())
13 .await;
14 if let Ok(value) = resp {
15 println!("{:#?}", value);
16 } else {
17 println!("{:#?}", resp.unwrap_err());
18 }
19}
Sourcepub async fn delete_rum_application_with_http_info(
&self,
id: String,
) -> Result<ResponseContent<()>, Error<DeleteRUMApplicationError>>
pub async fn delete_rum_application_with_http_info( &self, id: String, ) -> Result<ResponseContent<()>, Error<DeleteRUMApplicationError>>
Delete an existing RUM application in your organization.
Sourcepub async fn get_rum_application(
&self,
id: String,
) -> Result<RUMApplicationResponse, Error<GetRUMApplicationError>>
pub async fn get_rum_application( &self, id: String, ) -> Result<RUMApplicationResponse, Error<GetRUMApplicationError>>
Get the RUM application with given ID in your organization.
Examples found in repository?
6async fn main() {
7 // there is a valid "rum_application" in the system
8 let rum_application_data_id = std::env::var("RUM_APPLICATION_DATA_ID").unwrap();
9 let configuration = datadog::Configuration::new();
10 let api = RUMAPI::with_config(configuration);
11 let resp = api
12 .get_rum_application(rum_application_data_id.clone())
13 .await;
14 if let Ok(value) = resp {
15 println!("{:#?}", value);
16 } else {
17 println!("{:#?}", resp.unwrap_err());
18 }
19}
Sourcepub async fn get_rum_application_with_http_info(
&self,
id: String,
) -> Result<ResponseContent<RUMApplicationResponse>, Error<GetRUMApplicationError>>
pub async fn get_rum_application_with_http_info( &self, id: String, ) -> Result<ResponseContent<RUMApplicationResponse>, Error<GetRUMApplicationError>>
Get the RUM application with given ID in your organization.
Sourcepub async fn get_rum_applications(
&self,
) -> Result<RUMApplicationsResponse, Error<GetRUMApplicationsError>>
pub async fn get_rum_applications( &self, ) -> Result<RUMApplicationsResponse, Error<GetRUMApplicationsError>>
List all the RUM applications in your organization.
Sourcepub async fn get_rum_applications_with_http_info(
&self,
) -> Result<ResponseContent<RUMApplicationsResponse>, Error<GetRUMApplicationsError>>
pub async fn get_rum_applications_with_http_info( &self, ) -> Result<ResponseContent<RUMApplicationsResponse>, Error<GetRUMApplicationsError>>
List all the RUM applications in your organization.
Sourcepub async fn list_rum_events(
&self,
params: ListRUMEventsOptionalParams,
) -> Result<RUMEventsResponse, Error<ListRUMEventsError>>
pub async fn list_rum_events( &self, params: ListRUMEventsOptionalParams, ) -> Result<RUMEventsResponse, Error<ListRUMEventsError>>
List endpoint returns events that match a RUM search query. Results are paginated.
Use this endpoint to see your latest RUM events.
Examples found in repository?
7async fn main() {
8 let configuration = datadog::Configuration::new();
9 let api = RUMAPI::with_config(configuration);
10 let resp = api
11 .list_rum_events(ListRUMEventsOptionalParams::default())
12 .await;
13 if let Ok(value) = resp {
14 println!("{:#?}", value);
15 } else {
16 println!("{:#?}", resp.unwrap_err());
17 }
18}
Sourcepub fn list_rum_events_with_pagination(
&self,
params: ListRUMEventsOptionalParams,
) -> impl Stream<Item = Result<RUMEvent, Error<ListRUMEventsError>>> + '_
pub fn list_rum_events_with_pagination( &self, params: ListRUMEventsOptionalParams, ) -> impl Stream<Item = Result<RUMEvent, Error<ListRUMEventsError>>> + '_
Examples found in repository?
9async fn main() {
10 let configuration = datadog::Configuration::new();
11 let api = RUMAPI::with_config(configuration);
12 let response =
13 api.list_rum_events_with_pagination(ListRUMEventsOptionalParams::default().page_limit(2));
14 pin_mut!(response);
15 while let Some(resp) = response.next().await {
16 if let Ok(value) = resp {
17 println!("{:#?}", value);
18 } else {
19 println!("{:#?}", resp.unwrap_err());
20 }
21 }
22}
Sourcepub async fn list_rum_events_with_http_info(
&self,
params: ListRUMEventsOptionalParams,
) -> Result<ResponseContent<RUMEventsResponse>, Error<ListRUMEventsError>>
pub async fn list_rum_events_with_http_info( &self, params: ListRUMEventsOptionalParams, ) -> Result<ResponseContent<RUMEventsResponse>, Error<ListRUMEventsError>>
List endpoint returns events that match a RUM search query. Results are paginated.
Use this endpoint to see your latest RUM events.
Sourcepub async fn search_rum_events(
&self,
body: RUMSearchEventsRequest,
) -> Result<RUMEventsResponse, Error<SearchRUMEventsError>>
pub async fn search_rum_events( &self, body: RUMSearchEventsRequest, ) -> Result<RUMEventsResponse, Error<SearchRUMEventsError>>
List endpoint returns RUM events that match a RUM search query. Results are paginated.
Use this endpoint to build complex RUM events filtering and search.
Examples found in repository?
11async fn main() {
12 let body = RUMSearchEventsRequest::new()
13 .filter(
14 RUMQueryFilter::new()
15 .from("now-15m".to_string())
16 .query("@type:session AND @session.type:user".to_string())
17 .to("now".to_string()),
18 )
19 .options(
20 RUMQueryOptions::new()
21 .time_offset(0)
22 .timezone("GMT".to_string()),
23 )
24 .page(RUMQueryPageOptions::new().limit(25))
25 .sort(RUMSort::TIMESTAMP_ASCENDING);
26 let configuration = datadog::Configuration::new();
27 let api = RUMAPI::with_config(configuration);
28 let resp = api.search_rum_events(body).await;
29 if let Ok(value) = resp {
30 println!("{:#?}", value);
31 } else {
32 println!("{:#?}", resp.unwrap_err());
33 }
34}
Sourcepub fn search_rum_events_with_pagination(
&self,
body: RUMSearchEventsRequest,
) -> impl Stream<Item = Result<RUMEvent, Error<SearchRUMEventsError>>> + '_
pub fn search_rum_events_with_pagination( &self, body: RUMSearchEventsRequest, ) -> impl Stream<Item = Result<RUMEvent, Error<SearchRUMEventsError>>> + '_
Examples found in repository?
13async fn main() {
14 let body = RUMSearchEventsRequest::new()
15 .filter(
16 RUMQueryFilter::new()
17 .from("now-15m".to_string())
18 .query("@type:session AND @session.type:user".to_string())
19 .to("now".to_string()),
20 )
21 .options(
22 RUMQueryOptions::new()
23 .time_offset(0)
24 .timezone("GMT".to_string()),
25 )
26 .page(RUMQueryPageOptions::new().limit(2))
27 .sort(RUMSort::TIMESTAMP_ASCENDING);
28 let configuration = datadog::Configuration::new();
29 let api = RUMAPI::with_config(configuration);
30 let response = api.search_rum_events_with_pagination(body);
31 pin_mut!(response);
32 while let Some(resp) = response.next().await {
33 if let Ok(value) = resp {
34 println!("{:#?}", value);
35 } else {
36 println!("{:#?}", resp.unwrap_err());
37 }
38 }
39}
Sourcepub async fn search_rum_events_with_http_info(
&self,
body: RUMSearchEventsRequest,
) -> Result<ResponseContent<RUMEventsResponse>, Error<SearchRUMEventsError>>
pub async fn search_rum_events_with_http_info( &self, body: RUMSearchEventsRequest, ) -> Result<ResponseContent<RUMEventsResponse>, Error<SearchRUMEventsError>>
List endpoint returns RUM events that match a RUM search query. Results are paginated.
Use this endpoint to build complex RUM events filtering and search.
Sourcepub async fn update_rum_application(
&self,
id: String,
body: RUMApplicationUpdateRequest,
) -> Result<RUMApplicationResponse, Error<UpdateRUMApplicationError>>
pub async fn update_rum_application( &self, id: String, body: RUMApplicationUpdateRequest, ) -> Result<RUMApplicationResponse, Error<UpdateRUMApplicationError>>
Update the RUM application with given ID in your organization.
Examples found in repository?
10async fn main() {
11 // there is a valid "rum_application" in the system
12 let rum_application_data_id = std::env::var("RUM_APPLICATION_DATA_ID").unwrap();
13 let body = RUMApplicationUpdateRequest::new(
14 RUMApplicationUpdate::new(
15 rum_application_data_id.clone(),
16 RUMApplicationUpdateType::RUM_APPLICATION_UPDATE,
17 )
18 .attributes(
19 RUMApplicationUpdateAttributes::new()
20 .name("updated_name_for_my_existing_rum_application".to_string())
21 .type_("browser".to_string()),
22 ),
23 );
24 let configuration = datadog::Configuration::new();
25 let api = RUMAPI::with_config(configuration);
26 let resp = api
27 .update_rum_application(rum_application_data_id.clone(), body)
28 .await;
29 if let Ok(value) = resp {
30 println!("{:#?}", value);
31 } else {
32 println!("{:#?}", resp.unwrap_err());
33 }
34}
Sourcepub async fn update_rum_application_with_http_info(
&self,
id: String,
body: RUMApplicationUpdateRequest,
) -> Result<ResponseContent<RUMApplicationResponse>, Error<UpdateRUMApplicationError>>
pub async fn update_rum_application_with_http_info( &self, id: String, body: RUMApplicationUpdateRequest, ) -> Result<ResponseContent<RUMApplicationResponse>, Error<UpdateRUMApplicationError>>
Update the RUM application with given ID in your organization.