pub struct CIVisibilityPipelinesAPI { /* private fields */ }
Expand description
Search or aggregate your CI Visibility pipeline events and send them to your Datadog site over HTTP. See the CI Pipeline Visibility in Datadog page for more information.
Implementations§
Source§impl CIVisibilityPipelinesAPI
impl CIVisibilityPipelinesAPI
pub fn new() -> Self
Sourcepub fn with_config(config: Configuration) -> Self
pub fn with_config(config: Configuration) -> Self
Examples found in repository?
12async fn main() {
13 let body = CIAppPipelineEventsRequest::new()
14 .filter(
15 CIAppPipelinesQueryFilter::new()
16 .from("now-15m".to_string())
17 .query("@ci.provider.name:github AND @ci.status:error".to_string())
18 .to("now".to_string()),
19 )
20 .options(CIAppQueryOptions::new().timezone("GMT".to_string()))
21 .page(CIAppQueryPageOptions::new().limit(5))
22 .sort(CIAppSort::TIMESTAMP_ASCENDING);
23 let configuration = datadog::Configuration::new();
24 let api = CIVisibilityPipelinesAPI::with_config(configuration);
25 let resp = api
26 .search_ci_app_pipeline_events(
27 SearchCIAppPipelineEventsOptionalParams::default().body(body),
28 )
29 .await;
30 if let Ok(value) = resp {
31 println!("{:#?}", value);
32 } else {
33 println!("{:#?}", resp.unwrap_err());
34 }
35}
More examples
14async fn main() {
15 let body = CIAppPipelineEventsRequest::new()
16 .filter(
17 CIAppPipelinesQueryFilter::new()
18 .from("now-30s".to_string())
19 .to("now".to_string()),
20 )
21 .options(CIAppQueryOptions::new().timezone("GMT".to_string()))
22 .page(CIAppQueryPageOptions::new().limit(2))
23 .sort(CIAppSort::TIMESTAMP_ASCENDING);
24 let configuration = datadog::Configuration::new();
25 let api = CIVisibilityPipelinesAPI::with_config(configuration);
26 let response = api.search_ci_app_pipeline_events_with_pagination(
27 SearchCIAppPipelineEventsOptionalParams::default().body(body),
28 );
29 pin_mut!(response);
30 while let Some(resp) = response.next().await {
31 if let Ok(value) = resp {
32 println!("{:#?}", value);
33 } else {
34 println!("{:#?}", resp.unwrap_err());
35 }
36 }
37}
10async fn main() {
11 let configuration = datadog::Configuration::new();
12 let api = CIVisibilityPipelinesAPI::with_config(configuration);
13 let response = api.list_ci_app_pipeline_events_with_pagination(
14 ListCIAppPipelineEventsOptionalParams::default()
15 .filter_from(
16 DateTime::parse_from_rfc3339("2021-11-11T11:10:41+00:00")
17 .expect("Failed to parse datetime")
18 .with_timezone(&Utc),
19 )
20 .filter_to(
21 DateTime::parse_from_rfc3339("2021-11-11T11:11:11+00:00")
22 .expect("Failed to parse datetime")
23 .with_timezone(&Utc),
24 )
25 .page_limit(2),
26 );
27 pin_mut!(response);
28 while let Some(resp) = response.next().await {
29 if let Ok(value) = resp {
30 println!("{:#?}", value);
31 } else {
32 println!("{:#?}", resp.unwrap_err());
33 }
34 }
35}
8async fn main() {
9 let configuration = datadog::Configuration::new();
10 let api = CIVisibilityPipelinesAPI::with_config(configuration);
11 let resp = api
12 .list_ci_app_pipeline_events(
13 ListCIAppPipelineEventsOptionalParams::default()
14 .filter_query("@ci.provider.name:circleci".to_string())
15 .filter_from(
16 DateTime::parse_from_rfc3339("2021-11-11T10:41:11+00:00")
17 .expect("Failed to parse datetime")
18 .with_timezone(&Utc),
19 )
20 .filter_to(
21 DateTime::parse_from_rfc3339("2021-11-11T11:11:11+00:00")
22 .expect("Failed to parse datetime")
23 .with_timezone(&Utc),
24 )
25 .page_limit(5),
26 )
27 .await;
28 if let Ok(value) = resp {
29 println!("{:#?}", value);
30 } else {
31 println!("{:#?}", resp.unwrap_err());
32 }
33}
14async fn main() {
15 let body = CIAppPipelinesAggregateRequest::new()
16 .compute(vec![CIAppCompute::new(
17 CIAppAggregationFunction::PERCENTILE_90,
18 )
19 .metric("@duration".to_string())
20 .type_(CIAppComputeType::TOTAL)])
21 .filter(
22 CIAppPipelinesQueryFilter::new()
23 .from("now-15m".to_string())
24 .query("@ci.provider.name:(gitlab OR github)".to_string())
25 .to("now".to_string()),
26 )
27 .group_by(vec![CIAppPipelinesGroupBy::new("@ci.status".to_string())
28 .limit(10)
29 .total(CIAppGroupByTotal::CIAppGroupByTotalBoolean(false))])
30 .options(CIAppQueryOptions::new().timezone("GMT".to_string()));
31 let configuration = datadog::Configuration::new();
32 let api = CIVisibilityPipelinesAPI::with_config(configuration);
33 let resp = api.aggregate_ci_app_pipeline_events(body).await;
34 if let Ok(value) = resp {
35 println!("{:#?}", value);
36 } else {
37 println!("{:#?}", resp.unwrap_err());
38 }
39}
15async fn main() {
16 let body = CIAppCreatePipelineEventRequest::new().data(
17 CIAppCreatePipelineEventRequestData::new()
18 .attributes(CIAppCreatePipelineEventRequestAttributes::new(
19 CIAppCreatePipelineEventRequestAttributesResource::CIAppPipelineEventJob(Box::new(
20 CIAppPipelineEventJob::new(
21 DateTime::parse_from_rfc3339("2021-11-11T11:10:41+00:00")
22 .expect("Failed to parse datetime")
23 .with_timezone(&Utc),
24 "cf9456de-8b9e-4c27-aa79-27b1e78c1a33".to_string(),
25 CIAppPipelineEventJobLevel::JOB,
26 "Build image".to_string(),
27 "Deploy to AWS".to_string(),
28 "3eacb6f3-ff04-4e10-8a9c-46e6d054024a".to_string(),
29 DateTime::parse_from_rfc3339("2021-11-11T11:09:11+00:00")
30 .expect("Failed to parse datetime")
31 .with_timezone(&Utc),
32 CIAppPipelineEventJobStatus::ERROR,
33 "https://my-ci-provider.example/jobs/my-jobs/run/1".to_string(),
34 ),
35 )),
36 ))
37 .type_(CIAppCreatePipelineEventRequestDataType::CIPIPELINE_RESOURCE_REQUEST),
38 );
39 let configuration = datadog::Configuration::new();
40 let api = CIVisibilityPipelinesAPI::with_config(configuration);
41 let resp = api.create_ci_app_pipeline_event(body).await;
42 if let Ok(value) = resp {
43 println!("{:#?}", value);
44 } else {
45 println!("{:#?}", resp.unwrap_err());
46 }
47}
pub fn with_client_and_config( config: Configuration, client: ClientWithMiddleware, ) -> Self
Sourcepub async fn aggregate_ci_app_pipeline_events(
&self,
body: CIAppPipelinesAggregateRequest,
) -> Result<CIAppPipelinesAnalyticsAggregateResponse, Error<AggregateCIAppPipelineEventsError>>
pub async fn aggregate_ci_app_pipeline_events( &self, body: CIAppPipelinesAggregateRequest, ) -> Result<CIAppPipelinesAnalyticsAggregateResponse, Error<AggregateCIAppPipelineEventsError>>
Use this API endpoint to aggregate CI Visibility pipeline events into buckets of computed metrics and timeseries.
Examples found in repository?
14async fn main() {
15 let body = CIAppPipelinesAggregateRequest::new()
16 .compute(vec![CIAppCompute::new(
17 CIAppAggregationFunction::PERCENTILE_90,
18 )
19 .metric("@duration".to_string())
20 .type_(CIAppComputeType::TOTAL)])
21 .filter(
22 CIAppPipelinesQueryFilter::new()
23 .from("now-15m".to_string())
24 .query("@ci.provider.name:(gitlab OR github)".to_string())
25 .to("now".to_string()),
26 )
27 .group_by(vec![CIAppPipelinesGroupBy::new("@ci.status".to_string())
28 .limit(10)
29 .total(CIAppGroupByTotal::CIAppGroupByTotalBoolean(false))])
30 .options(CIAppQueryOptions::new().timezone("GMT".to_string()));
31 let configuration = datadog::Configuration::new();
32 let api = CIVisibilityPipelinesAPI::with_config(configuration);
33 let resp = api.aggregate_ci_app_pipeline_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_ci_app_pipeline_events_with_http_info(
&self,
body: CIAppPipelinesAggregateRequest,
) -> Result<ResponseContent<CIAppPipelinesAnalyticsAggregateResponse>, Error<AggregateCIAppPipelineEventsError>>
pub async fn aggregate_ci_app_pipeline_events_with_http_info( &self, body: CIAppPipelinesAggregateRequest, ) -> Result<ResponseContent<CIAppPipelinesAnalyticsAggregateResponse>, Error<AggregateCIAppPipelineEventsError>>
Use this API endpoint to aggregate CI Visibility pipeline events into buckets of computed metrics and timeseries.
Sourcepub async fn create_ci_app_pipeline_event(
&self,
body: CIAppCreatePipelineEventRequest,
) -> Result<BTreeMap<String, Value>, Error<CreateCIAppPipelineEventError>>
pub async fn create_ci_app_pipeline_event( &self, body: CIAppCreatePipelineEventRequest, ) -> Result<BTreeMap<String, Value>, Error<CreateCIAppPipelineEventError>>
Send your pipeline event to your Datadog platform over HTTP. For details about how pipeline executions are modeled and what execution types we support, see Pipeline Data Model And Execution Types.
Pipeline events can be submitted with a timestamp that is up to 18 hours in the past.
Examples found in repository?
15async fn main() {
16 let body = CIAppCreatePipelineEventRequest::new().data(
17 CIAppCreatePipelineEventRequestData::new()
18 .attributes(CIAppCreatePipelineEventRequestAttributes::new(
19 CIAppCreatePipelineEventRequestAttributesResource::CIAppPipelineEventJob(Box::new(
20 CIAppPipelineEventJob::new(
21 DateTime::parse_from_rfc3339("2021-11-11T11:10:41+00:00")
22 .expect("Failed to parse datetime")
23 .with_timezone(&Utc),
24 "cf9456de-8b9e-4c27-aa79-27b1e78c1a33".to_string(),
25 CIAppPipelineEventJobLevel::JOB,
26 "Build image".to_string(),
27 "Deploy to AWS".to_string(),
28 "3eacb6f3-ff04-4e10-8a9c-46e6d054024a".to_string(),
29 DateTime::parse_from_rfc3339("2021-11-11T11:09:11+00:00")
30 .expect("Failed to parse datetime")
31 .with_timezone(&Utc),
32 CIAppPipelineEventJobStatus::ERROR,
33 "https://my-ci-provider.example/jobs/my-jobs/run/1".to_string(),
34 ),
35 )),
36 ))
37 .type_(CIAppCreatePipelineEventRequestDataType::CIPIPELINE_RESOURCE_REQUEST),
38 );
39 let configuration = datadog::Configuration::new();
40 let api = CIVisibilityPipelinesAPI::with_config(configuration);
41 let resp = api.create_ci_app_pipeline_event(body).await;
42 if let Ok(value) = resp {
43 println!("{:#?}", value);
44 } else {
45 println!("{:#?}", resp.unwrap_err());
46 }
47}
More examples
17async fn main() {
18 let body = CIAppCreatePipelineEventRequest::new().data(
19 CIAppCreatePipelineEventRequestData::new()
20 .attributes(CIAppCreatePipelineEventRequestAttributes::new(
21 CIAppCreatePipelineEventRequestAttributesResource::CIAppPipelineEventPipeline(
22 Box::new(
23 CIAppPipelineEventPipeline::CIAppPipelineEventInProgressPipeline(Box::new(
24 CIAppPipelineEventInProgressPipeline::new(
25 CIAppPipelineEventPipelineLevel::PIPELINE,
26 "Deploy to AWS".to_string(),
27 false,
28 DateTime::parse_from_rfc3339("2021-11-11T11:09:11+00:00")
29 .expect("Failed to parse datetime")
30 .with_timezone(&Utc),
31 CIAppPipelineEventPipelineInProgressStatus::RUNNING,
32 "3eacb6f3-ff04-4e10-8a9c-46e6d054024a".to_string(),
33 "https://my-ci-provider.example/pipelines/my-pipeline/run/1"
34 .to_string(),
35 )
36 .git(Some(CIAppGitInfo::new(
37 "john.doe@email.com".to_string(),
38 "https://github.com/DataDog/datadog-agent".to_string(),
39 "7f263865994b76066c4612fd1965215e7dcb4cd2".to_string(),
40 ))),
41 )),
42 ),
43 ),
44 ))
45 .type_(CIAppCreatePipelineEventRequestDataType::CIPIPELINE_RESOURCE_REQUEST),
46 );
47 let configuration = datadog::Configuration::new();
48 let api = CIVisibilityPipelinesAPI::with_config(configuration);
49 let resp = api.create_ci_app_pipeline_event(body).await;
50 if let Ok(value) = resp {
51 println!("{:#?}", value);
52 } else {
53 println!("{:#?}", resp.unwrap_err());
54 }
55}
17async fn main() {
18 let body = CIAppCreatePipelineEventRequest::new().data(
19 CIAppCreatePipelineEventRequestData::new()
20 .attributes(CIAppCreatePipelineEventRequestAttributes::new(
21 CIAppCreatePipelineEventRequestAttributesResource::CIAppPipelineEventPipeline(
22 Box::new(
23 CIAppPipelineEventPipeline::CIAppPipelineEventFinishedPipeline(Box::new(
24 CIAppPipelineEventFinishedPipeline::new(
25 DateTime::parse_from_rfc3339("2021-11-11T11:10:41+00:00")
26 .expect("Failed to parse datetime")
27 .with_timezone(&Utc),
28 CIAppPipelineEventPipelineLevel::PIPELINE,
29 "Deploy to AWS".to_string(),
30 false,
31 DateTime::parse_from_rfc3339("2021-11-11T11:09:11+00:00")
32 .expect("Failed to parse datetime")
33 .with_timezone(&Utc),
34 CIAppPipelineEventPipelineStatus::SUCCESS,
35 "3eacb6f3-ff04-4e10-8a9c-46e6d054024a".to_string(),
36 "https://my-ci-provider.example/pipelines/my-pipeline/run/1"
37 .to_string(),
38 )
39 .git(Some(CIAppGitInfo::new(
40 "john.doe@email.com".to_string(),
41 "https://github.com/DataDog/datadog-agent".to_string(),
42 "7f263865994b76066c4612fd1965215e7dcb4cd2".to_string(),
43 ))),
44 )),
45 ),
46 ),
47 ))
48 .type_(CIAppCreatePipelineEventRequestDataType::CIPIPELINE_RESOURCE_REQUEST),
49 );
50 let configuration = datadog::Configuration::new();
51 let api = CIVisibilityPipelinesAPI::with_config(configuration);
52 let resp = api.create_ci_app_pipeline_event(body).await;
53 if let Ok(value) = resp {
54 println!("{:#?}", value);
55 } else {
56 println!("{:#?}", resp.unwrap_err());
57 }
58}
18async fn main() {
19 let body =
20 CIAppCreatePipelineEventRequest
21 ::new().data(
22 CIAppCreatePipelineEventRequestData::new()
23 .attributes(
24 CIAppCreatePipelineEventRequestAttributes::new(
25 CIAppCreatePipelineEventRequestAttributesResource::CIAppPipelineEventPipeline(
26 Box::new(
27 CIAppPipelineEventPipeline::CIAppPipelineEventFinishedPipeline(
28 Box::new(
29 CIAppPipelineEventFinishedPipeline::new(
30 DateTime::parse_from_rfc3339("2021-11-11T11:10:41+00:00")
31 .expect("Failed to parse datetime")
32 .with_timezone(&Utc),
33 CIAppPipelineEventPipelineLevel::PIPELINE,
34 "Deploy to AWS".to_string(),
35 false,
36 DateTime::parse_from_rfc3339("2021-11-11T11:09:11+00:00")
37 .expect("Failed to parse datetime")
38 .with_timezone(&Utc),
39 CIAppPipelineEventPipelineStatus::SUCCESS,
40 "3eacb6f3-ff04-4e10-8a9c-46e6d054024a".to_string(),
41 "https://my-ci-provider.example/pipelines/my-pipeline/run/1".to_string(),
42 ).git(
43 Some(
44 CIAppGitInfo::new(
45 "john.doe@email.com".to_string(),
46 "https://github.com/DataDog/datadog-agent".to_string(),
47 "7f263865994b76066c4612fd1965215e7dcb4cd2".to_string(),
48 ),
49 ),
50 ),
51 ),
52 ),
53 ),
54 ),
55 ).provider_name("example-provider".to_string()),
56 )
57 .type_(CIAppCreatePipelineEventRequestDataType::CIPIPELINE_RESOURCE_REQUEST),
58 );
59 let configuration = datadog::Configuration::new();
60 let api = CIVisibilityPipelinesAPI::with_config(configuration);
61 let resp = api.create_ci_app_pipeline_event(body).await;
62 if let Ok(value) = resp {
63 println!("{:#?}", value);
64 } else {
65 println!("{:#?}", resp.unwrap_err());
66 }
67}
Sourcepub async fn create_ci_app_pipeline_event_with_http_info(
&self,
body: CIAppCreatePipelineEventRequest,
) -> Result<ResponseContent<BTreeMap<String, Value>>, Error<CreateCIAppPipelineEventError>>
pub async fn create_ci_app_pipeline_event_with_http_info( &self, body: CIAppCreatePipelineEventRequest, ) -> Result<ResponseContent<BTreeMap<String, Value>>, Error<CreateCIAppPipelineEventError>>
Send your pipeline event to your Datadog platform over HTTP. For details about how pipeline executions are modeled and what execution types we support, see Pipeline Data Model And Execution Types.
Pipeline events can be submitted with a timestamp that is up to 18 hours in the past.
Sourcepub async fn list_ci_app_pipeline_events(
&self,
params: ListCIAppPipelineEventsOptionalParams,
) -> Result<CIAppPipelineEventsResponse, Error<ListCIAppPipelineEventsError>>
pub async fn list_ci_app_pipeline_events( &self, params: ListCIAppPipelineEventsOptionalParams, ) -> Result<CIAppPipelineEventsResponse, Error<ListCIAppPipelineEventsError>>
List endpoint returns CI Visibility pipeline events that match a search query. Results are paginated similarly to logs.
Use this endpoint to see your latest pipeline events.
Examples found in repository?
8async fn main() {
9 let configuration = datadog::Configuration::new();
10 let api = CIVisibilityPipelinesAPI::with_config(configuration);
11 let resp = api
12 .list_ci_app_pipeline_events(
13 ListCIAppPipelineEventsOptionalParams::default()
14 .filter_query("@ci.provider.name:circleci".to_string())
15 .filter_from(
16 DateTime::parse_from_rfc3339("2021-11-11T10:41:11+00:00")
17 .expect("Failed to parse datetime")
18 .with_timezone(&Utc),
19 )
20 .filter_to(
21 DateTime::parse_from_rfc3339("2021-11-11T11:11:11+00:00")
22 .expect("Failed to parse datetime")
23 .with_timezone(&Utc),
24 )
25 .page_limit(5),
26 )
27 .await;
28 if let Ok(value) = resp {
29 println!("{:#?}", value);
30 } else {
31 println!("{:#?}", resp.unwrap_err());
32 }
33}
Sourcepub fn list_ci_app_pipeline_events_with_pagination(
&self,
params: ListCIAppPipelineEventsOptionalParams,
) -> impl Stream<Item = Result<CIAppPipelineEvent, Error<ListCIAppPipelineEventsError>>> + '_
pub fn list_ci_app_pipeline_events_with_pagination( &self, params: ListCIAppPipelineEventsOptionalParams, ) -> impl Stream<Item = Result<CIAppPipelineEvent, Error<ListCIAppPipelineEventsError>>> + '_
Examples found in repository?
10async fn main() {
11 let configuration = datadog::Configuration::new();
12 let api = CIVisibilityPipelinesAPI::with_config(configuration);
13 let response = api.list_ci_app_pipeline_events_with_pagination(
14 ListCIAppPipelineEventsOptionalParams::default()
15 .filter_from(
16 DateTime::parse_from_rfc3339("2021-11-11T11:10:41+00:00")
17 .expect("Failed to parse datetime")
18 .with_timezone(&Utc),
19 )
20 .filter_to(
21 DateTime::parse_from_rfc3339("2021-11-11T11:11:11+00:00")
22 .expect("Failed to parse datetime")
23 .with_timezone(&Utc),
24 )
25 .page_limit(2),
26 );
27 pin_mut!(response);
28 while let Some(resp) = response.next().await {
29 if let Ok(value) = resp {
30 println!("{:#?}", value);
31 } else {
32 println!("{:#?}", resp.unwrap_err());
33 }
34 }
35}
Sourcepub async fn list_ci_app_pipeline_events_with_http_info(
&self,
params: ListCIAppPipelineEventsOptionalParams,
) -> Result<ResponseContent<CIAppPipelineEventsResponse>, Error<ListCIAppPipelineEventsError>>
pub async fn list_ci_app_pipeline_events_with_http_info( &self, params: ListCIAppPipelineEventsOptionalParams, ) -> Result<ResponseContent<CIAppPipelineEventsResponse>, Error<ListCIAppPipelineEventsError>>
List endpoint returns CI Visibility pipeline events that match a search query. Results are paginated similarly to logs.
Use this endpoint to see your latest pipeline events.
Sourcepub async fn search_ci_app_pipeline_events(
&self,
params: SearchCIAppPipelineEventsOptionalParams,
) -> Result<CIAppPipelineEventsResponse, Error<SearchCIAppPipelineEventsError>>
pub async fn search_ci_app_pipeline_events( &self, params: SearchCIAppPipelineEventsOptionalParams, ) -> Result<CIAppPipelineEventsResponse, Error<SearchCIAppPipelineEventsError>>
List endpoint returns CI Visibility pipeline events that match a search query. Results are paginated similarly to logs.
Use this endpoint to build complex events filtering and search.
Examples found in repository?
12async fn main() {
13 let body = CIAppPipelineEventsRequest::new()
14 .filter(
15 CIAppPipelinesQueryFilter::new()
16 .from("now-15m".to_string())
17 .query("@ci.provider.name:github AND @ci.status:error".to_string())
18 .to("now".to_string()),
19 )
20 .options(CIAppQueryOptions::new().timezone("GMT".to_string()))
21 .page(CIAppQueryPageOptions::new().limit(5))
22 .sort(CIAppSort::TIMESTAMP_ASCENDING);
23 let configuration = datadog::Configuration::new();
24 let api = CIVisibilityPipelinesAPI::with_config(configuration);
25 let resp = api
26 .search_ci_app_pipeline_events(
27 SearchCIAppPipelineEventsOptionalParams::default().body(body),
28 )
29 .await;
30 if let Ok(value) = resp {
31 println!("{:#?}", value);
32 } else {
33 println!("{:#?}", resp.unwrap_err());
34 }
35}
Sourcepub fn search_ci_app_pipeline_events_with_pagination(
&self,
params: SearchCIAppPipelineEventsOptionalParams,
) -> impl Stream<Item = Result<CIAppPipelineEvent, Error<SearchCIAppPipelineEventsError>>> + '_
pub fn search_ci_app_pipeline_events_with_pagination( &self, params: SearchCIAppPipelineEventsOptionalParams, ) -> impl Stream<Item = Result<CIAppPipelineEvent, Error<SearchCIAppPipelineEventsError>>> + '_
Examples found in repository?
14async fn main() {
15 let body = CIAppPipelineEventsRequest::new()
16 .filter(
17 CIAppPipelinesQueryFilter::new()
18 .from("now-30s".to_string())
19 .to("now".to_string()),
20 )
21 .options(CIAppQueryOptions::new().timezone("GMT".to_string()))
22 .page(CIAppQueryPageOptions::new().limit(2))
23 .sort(CIAppSort::TIMESTAMP_ASCENDING);
24 let configuration = datadog::Configuration::new();
25 let api = CIVisibilityPipelinesAPI::with_config(configuration);
26 let response = api.search_ci_app_pipeline_events_with_pagination(
27 SearchCIAppPipelineEventsOptionalParams::default().body(body),
28 );
29 pin_mut!(response);
30 while let Some(resp) = response.next().await {
31 if let Ok(value) = resp {
32 println!("{:#?}", value);
33 } else {
34 println!("{:#?}", resp.unwrap_err());
35 }
36 }
37}
Sourcepub async fn search_ci_app_pipeline_events_with_http_info(
&self,
params: SearchCIAppPipelineEventsOptionalParams,
) -> Result<ResponseContent<CIAppPipelineEventsResponse>, Error<SearchCIAppPipelineEventsError>>
pub async fn search_ci_app_pipeline_events_with_http_info( &self, params: SearchCIAppPipelineEventsOptionalParams, ) -> Result<ResponseContent<CIAppPipelineEventsResponse>, Error<SearchCIAppPipelineEventsError>>
List endpoint returns CI Visibility pipeline events that match a search query. Results are paginated similarly to logs.
Use this endpoint to build complex events filtering and search.
Trait Implementations§
Source§impl Clone for CIVisibilityPipelinesAPI
impl Clone for CIVisibilityPipelinesAPI
Source§fn clone(&self) -> CIVisibilityPipelinesAPI
fn clone(&self) -> CIVisibilityPipelinesAPI
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read more