windmill_api/models/
materialized_partition.rs

1/*
2 * Windmill API
3 *
4 * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
5 *
6 * The version of the OpenAPI document: 1.744.0
7 * Contact: contact@windmill.dev
8 * Generated by: https://openapi-generator.tech
9 */
10
11use crate::models;
12use serde::{Deserialize, Serialize};
13
14#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
15pub struct MaterializedPartition {
16    #[serde(rename = "asset_kind")]
17    pub asset_kind: models::AssetKind,
18    #[serde(rename = "asset_path")]
19    pub asset_path: String,
20    #[serde(rename = "partition")]
21    pub partition: String,
22    #[serde(rename = "status")]
23    pub status: Status,
24    #[serde(rename = "snapshot_id", default, with = "::serde_with::rust::double_option", skip_serializing_if = "Option::is_none")]
25    pub snapshot_id: Option<Option<i64>>,
26    #[serde(rename = "row_count", default, with = "::serde_with::rust::double_option", skip_serializing_if = "Option::is_none")]
27    pub row_count: Option<Option<i64>>,
28    #[serde(rename = "job_id", default, with = "::serde_with::rust::double_option", skip_serializing_if = "Option::is_none")]
29    pub job_id: Option<Option<uuid::Uuid>>,
30    #[serde(rename = "materialized_at")]
31    pub materialized_at: String,
32    #[serde(rename = "error", default, with = "::serde_with::rust::double_option", skip_serializing_if = "Option::is_none")]
33    pub error: Option<Option<String>>,
34}
35
36impl MaterializedPartition {
37    pub fn new(asset_kind: models::AssetKind, asset_path: String, partition: String, status: Status, materialized_at: String) -> MaterializedPartition {
38        MaterializedPartition {
39            asset_kind,
40            asset_path,
41            partition,
42            status,
43            snapshot_id: None,
44            row_count: None,
45            job_id: None,
46            materialized_at,
47            error: None,
48        }
49    }
50}
51/// 
52#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
53pub enum Status {
54    #[serde(rename = "running")]
55    Running,
56    #[serde(rename = "materialized")]
57    Materialized,
58    #[serde(rename = "failed")]
59    Failed,
60}
61
62impl Default for Status {
63    fn default() -> Status {
64        Self::Running
65    }
66}
67
windmill_api/models/materialized_partition.rs

windmill_api/models/
materialized_partition.rs
