cognite/api/data_ingestion/
extpipes.rs

1use serde::Serialize;
2
3use crate::{
4    Create, DeleteWithIgnoreUnknownIds, FilterItems, IdentityList, Patch, Resource,
5    RetrieveWithIgnoreUnknownIds, Update, WithBasePath,
6};
7
8use crate::extpipes::*;
9
10/// Extraction pipelines represent applications and software running outside CDF.
11pub type ExtPipesResource = Resource<ExtPipe>;
12
13impl WithBasePath for ExtPipesResource {
14    const BASE_PATH: &'static str = "extpipes";
15}
16
17impl Create<AddExtPipe, ExtPipe> for ExtPipesResource {}
18impl<R> DeleteWithIgnoreUnknownIds<IdentityList<R>> for ExtPipesResource
19where
20    IdentityList<R>: Serialize,
21    R: Send + Sync,
22{
23}
24impl Update<Patch<PatchExtPipe>, ExtPipe> for ExtPipesResource {}
25impl<R> RetrieveWithIgnoreUnknownIds<IdentityList<R>, ExtPipe> for ExtPipesResource
26where
27    IdentityList<R>: Serialize,
28    R: Send + Sync,
29{
30}
31impl FilterItems<ExtPipeFilter, ExtPipe> for ExtPipesResource {}
32
33/// Extraction pipeline runs represent statuses related to an extraction pipeline.
34/// The supported statuses are: `success`, `failure`, and `seen`.
35///
36/// An extraction pipeline can be configured to create notifications when
37/// the state of the extraction pipeline changes.
38pub type ExtPipeRunsResource = Resource<ExtPipeRun>;
39
40impl WithBasePath for ExtPipeRunsResource {
41    const BASE_PATH: &'static str = "extpipes/runs";
42}
43
44impl Create<AddExtPipeRun, ExtPipeRun> for ExtPipeRunsResource {}
45impl FilterItems<ExtPipeRunFilter, ExtPipeRun> for ExtPipeRunsResource {}
cognite/api/data_ingestion/extpipes.rs

cognite/api/data_ingestion/
extpipes.rs
