datadog_api_client::datadogV2::api::api_ci_visibility_pipelines

Struct CIVisibilityPipelinesAPI

Source 
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

Source

pub fn new() -> Self

Source

pub fn with_config(config: Configuration) -> Self

Examples found in repository?
examples/v2_ci-visibility-pipelines_SearchCIAppPipelineEvents.rs (line 24)
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
Hide additional examples
examples/v2_ci-visibility-pipelines_SearchCIAppPipelineEvents_3246135003.rs (line 25)
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}
examples/v2_ci-visibility-pipelines_ListCIAppPipelineEvents_1270618359.rs (line 12)
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}
examples/v2_ci-visibility-pipelines_ListCIAppPipelineEvents.rs (line 10)
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}
examples/v2_ci-visibility-pipelines_AggregateCIAppPipelineEvents.rs (line 32)
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}
examples/v2_ci-visibility-pipelines_CreateCIAppPipelineEvent_129899466.rs (line 40)
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}
Additional examples can be found in:
Source

pub fn with_client_and_config( config: Configuration, client: ClientWithMiddleware, ) -> Self

Source

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?
examples/v2_ci-visibility-pipelines_AggregateCIAppPipelineEvents.rs (line 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}
Source

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.

Source

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?
examples/v2_ci-visibility-pipelines_CreateCIAppPipelineEvent_129899466.rs (line 41)
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
Hide additional examples
examples/v2_ci-visibility-pipelines_CreateCIAppPipelineEvent_2341150096.rs (line 49)
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}
examples/v2_ci-visibility-pipelines_CreateCIAppPipelineEvent.rs (line 52)
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}
examples/v2_ci-visibility-pipelines_CreateCIAppPipelineEvent_819339921.rs (line 61)
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}
Source

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.

Source

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?
examples/v2_ci-visibility-pipelines_ListCIAppPipelineEvents.rs (lines 12-26)
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}
Source

pub fn list_ci_app_pipeline_events_with_pagination( &self, params: ListCIAppPipelineEventsOptionalParams, ) -> impl Stream<Item = Result<CIAppPipelineEvent, Error<ListCIAppPipelineEventsError>>> + '_

Examples found in repository?
examples/v2_ci-visibility-pipelines_ListCIAppPipelineEvents_1270618359.rs (lines 13-26)
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}
Source

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.

Source

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?
examples/v2_ci-visibility-pipelines_SearchCIAppPipelineEvents.rs (lines 26-28)
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}
Source

pub fn search_ci_app_pipeline_events_with_pagination( &self, params: SearchCIAppPipelineEventsOptionalParams, ) -> impl Stream<Item = Result<CIAppPipelineEvent, Error<SearchCIAppPipelineEventsError>>> + '_

Examples found in repository?
examples/v2_ci-visibility-pipelines_SearchCIAppPipelineEvents_3246135003.rs (lines 26-28)
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}
Source

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

Source§

fn clone(&self) -> CIVisibilityPipelinesAPI

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for CIVisibilityPipelinesAPI

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl Default for CIVisibilityPipelinesAPI

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,