kcr_flink_apache_org 3.20260114.63826

// WARNING: generated by kopium - manual changes will be overwritten
// kopium command: kopium --docs --derive=Default --derive=PartialEq --smart-derive-elision --filename crd-catalog/apache/flink-kubernetes-operator/flink.apache.org/v1beta1/flinksessionjobs.yaml
// kopium version: 0.22.5

#[allow(unused_imports)]
mod prelude {
    pub use kube::CustomResource;
    pub use serde::{Serialize, Deserialize};
}
use self::prelude::*;

#[derive(CustomResource, Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
#[kube(group = "flink.apache.org", version = "v1beta1", kind = "FlinkSessionJob", plural = "flinksessionjobs")]
#[kube(namespaced)]
#[kube(status = "FlinkSessionJobStatus")]
#[kube(schema = "disabled")]
#[kube(derive="Default")]
#[kube(derive="PartialEq")]
pub struct FlinkSessionJobSpec {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "deploymentName")]
    pub deployment_name: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "flinkConfiguration")]
    pub flink_configuration: Option<serde_json::Value>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub job: Option<FlinkSessionJobJob>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "restartNonce")]
    pub restart_nonce: Option<i64>,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobJob {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "allowNonRestoredState")]
    pub allow_non_restored_state: Option<bool>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub args: Option<Vec<String>>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "autoscalerResetNonce")]
    pub autoscaler_reset_nonce: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "checkpointTriggerNonce")]
    pub checkpoint_trigger_nonce: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "entryClass")]
    pub entry_class: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "initialSavepointPath")]
    pub initial_savepoint_path: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "jarURI")]
    pub jar_uri: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub parallelism: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "savepointRedeployNonce")]
    pub savepoint_redeploy_nonce: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "savepointTriggerNonce")]
    pub savepoint_trigger_nonce: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub state: Option<FlinkSessionJobJobState>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "upgradeMode")]
    pub upgrade_mode: Option<FlinkSessionJobJobUpgradeMode>,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobJobState {
    #[serde(rename = "running")]
    Running,
    #[serde(rename = "suspended")]
    Suspended,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobJobUpgradeMode {
    #[serde(rename = "last-state")]
    LastState,
    #[serde(rename = "savepoint")]
    Savepoint,
    #[serde(rename = "stateless")]
    Stateless,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatus {
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub error: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "jobStatus")]
    pub job_status: Option<FlinkSessionJobStatusJobStatus>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "lifecycleState")]
    pub lifecycle_state: Option<FlinkSessionJobStatusLifecycleState>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "observedGeneration")]
    pub observed_generation: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "reconciliationStatus")]
    pub reconciliation_status: Option<FlinkSessionJobStatusReconciliationStatus>,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatusJobStatus {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "checkpointInfo")]
    pub checkpoint_info: Option<FlinkSessionJobStatusJobStatusCheckpointInfo>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "jobId")]
    pub job_id: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "jobName")]
    pub job_name: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "savepointInfo")]
    pub savepoint_info: Option<FlinkSessionJobStatusJobStatusSavepointInfo>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "startTime")]
    pub start_time: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub state: Option<FlinkSessionJobStatusJobStatusState>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "updateTime")]
    pub update_time: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "upgradeSavepointPath")]
    pub upgrade_savepoint_path: Option<String>,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatusJobStatusCheckpointInfo {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "formatType")]
    pub format_type: Option<FlinkSessionJobStatusJobStatusCheckpointInfoFormatType>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "lastCheckpoint")]
    pub last_checkpoint: Option<FlinkSessionJobStatusJobStatusCheckpointInfoLastCheckpoint>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "lastPeriodicCheckpointTimestamp")]
    pub last_periodic_checkpoint_timestamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerId")]
    pub trigger_id: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerTimestamp")]
    pub trigger_timestamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerType")]
    pub trigger_type: Option<FlinkSessionJobStatusJobStatusCheckpointInfoTriggerType>,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusCheckpointInfoFormatType {
    #[serde(rename = "FULL")]
    Full,
    #[serde(rename = "INCREMENTAL")]
    Incremental,
    #[serde(rename = "UNKNOWN")]
    Unknown,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatusJobStatusCheckpointInfoLastCheckpoint {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "formatType")]
    pub format_type: Option<FlinkSessionJobStatusJobStatusCheckpointInfoLastCheckpointFormatType>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "timeStamp")]
    pub time_stamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerNonce")]
    pub trigger_nonce: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerType")]
    pub trigger_type: Option<FlinkSessionJobStatusJobStatusCheckpointInfoLastCheckpointTriggerType>,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusCheckpointInfoLastCheckpointFormatType {
    #[serde(rename = "FULL")]
    Full,
    #[serde(rename = "INCREMENTAL")]
    Incremental,
    #[serde(rename = "UNKNOWN")]
    Unknown,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusCheckpointInfoLastCheckpointTriggerType {
    #[serde(rename = "MANUAL")]
    Manual,
    #[serde(rename = "PERIODIC")]
    Periodic,
    #[serde(rename = "UNKNOWN")]
    Unknown,
    #[serde(rename = "UPGRADE")]
    Upgrade,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusCheckpointInfoTriggerType {
    #[serde(rename = "MANUAL")]
    Manual,
    #[serde(rename = "PERIODIC")]
    Periodic,
    #[serde(rename = "UNKNOWN")]
    Unknown,
    #[serde(rename = "UPGRADE")]
    Upgrade,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatusJobStatusSavepointInfo {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "formatType")]
    pub format_type: Option<FlinkSessionJobStatusJobStatusSavepointInfoFormatType>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "lastPeriodicSavepointTimestamp")]
    pub last_periodic_savepoint_timestamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "lastSavepoint")]
    pub last_savepoint: Option<FlinkSessionJobStatusJobStatusSavepointInfoLastSavepoint>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "savepointHistory")]
    pub savepoint_history: Option<Vec<FlinkSessionJobStatusJobStatusSavepointInfoSavepointHistory>>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerId")]
    pub trigger_id: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerTimestamp")]
    pub trigger_timestamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerType")]
    pub trigger_type: Option<FlinkSessionJobStatusJobStatusSavepointInfoTriggerType>,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusSavepointInfoFormatType {
    #[serde(rename = "CANONICAL")]
    Canonical,
    #[serde(rename = "NATIVE")]
    Native,
    #[serde(rename = "UNKNOWN")]
    Unknown,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatusJobStatusSavepointInfoLastSavepoint {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "formatType")]
    pub format_type: Option<FlinkSessionJobStatusJobStatusSavepointInfoLastSavepointFormatType>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub location: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "timeStamp")]
    pub time_stamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerNonce")]
    pub trigger_nonce: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerType")]
    pub trigger_type: Option<FlinkSessionJobStatusJobStatusSavepointInfoLastSavepointTriggerType>,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusSavepointInfoLastSavepointFormatType {
    #[serde(rename = "CANONICAL")]
    Canonical,
    #[serde(rename = "NATIVE")]
    Native,
    #[serde(rename = "UNKNOWN")]
    Unknown,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusSavepointInfoLastSavepointTriggerType {
    #[serde(rename = "MANUAL")]
    Manual,
    #[serde(rename = "PERIODIC")]
    Periodic,
    #[serde(rename = "UNKNOWN")]
    Unknown,
    #[serde(rename = "UPGRADE")]
    Upgrade,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatusJobStatusSavepointInfoSavepointHistory {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "formatType")]
    pub format_type: Option<FlinkSessionJobStatusJobStatusSavepointInfoSavepointHistoryFormatType>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub location: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "timeStamp")]
    pub time_stamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerNonce")]
    pub trigger_nonce: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "triggerType")]
    pub trigger_type: Option<FlinkSessionJobStatusJobStatusSavepointInfoSavepointHistoryTriggerType>,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusSavepointInfoSavepointHistoryFormatType {
    #[serde(rename = "CANONICAL")]
    Canonical,
    #[serde(rename = "NATIVE")]
    Native,
    #[serde(rename = "UNKNOWN")]
    Unknown,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusSavepointInfoSavepointHistoryTriggerType {
    #[serde(rename = "MANUAL")]
    Manual,
    #[serde(rename = "PERIODIC")]
    Periodic,
    #[serde(rename = "UNKNOWN")]
    Unknown,
    #[serde(rename = "UPGRADE")]
    Upgrade,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusSavepointInfoTriggerType {
    #[serde(rename = "MANUAL")]
    Manual,
    #[serde(rename = "PERIODIC")]
    Periodic,
    #[serde(rename = "UNKNOWN")]
    Unknown,
    #[serde(rename = "UPGRADE")]
    Upgrade,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusJobStatusState {
    #[serde(rename = "CANCELED")]
    Canceled,
    #[serde(rename = "CANCELLING")]
    Cancelling,
    #[serde(rename = "CREATED")]
    Created,
    #[serde(rename = "FAILED")]
    Failed,
    #[serde(rename = "FAILING")]
    Failing,
    #[serde(rename = "FINISHED")]
    Finished,
    #[serde(rename = "INITIALIZING")]
    Initializing,
    #[serde(rename = "RECONCILING")]
    Reconciling,
    #[serde(rename = "RESTARTING")]
    Restarting,
    #[serde(rename = "RUNNING")]
    Running,
    #[serde(rename = "SUSPENDED")]
    Suspended,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusLifecycleState {
    #[serde(rename = "CREATED")]
    Created,
    #[serde(rename = "DELETED")]
    Deleted,
    #[serde(rename = "DELETING")]
    Deleting,
    #[serde(rename = "DEPLOYED")]
    Deployed,
    #[serde(rename = "FAILED")]
    Failed,
    #[serde(rename = "ROLLED_BACK")]
    RolledBack,
    #[serde(rename = "ROLLING_BACK")]
    RollingBack,
    #[serde(rename = "STABLE")]
    Stable,
    #[serde(rename = "SUSPENDED")]
    Suspended,
    #[serde(rename = "UPGRADING")]
    Upgrading,
}

#[derive(Serialize, Deserialize, Clone, Debug, Default, PartialEq)]
pub struct FlinkSessionJobStatusReconciliationStatus {
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "lastReconciledSpec")]
    pub last_reconciled_spec: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "lastStableSpec")]
    pub last_stable_spec: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none", rename = "reconciliationTimestamp")]
    pub reconciliation_timestamp: Option<i64>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub state: Option<FlinkSessionJobStatusReconciliationStatusState>,
}

#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
pub enum FlinkSessionJobStatusReconciliationStatusState {
    #[serde(rename = "DEPLOYED")]
    Deployed,
    #[serde(rename = "ROLLED_BACK")]
    RolledBack,
    #[serde(rename = "ROLLING_BACK")]
    RollingBack,
    #[serde(rename = "UPGRADING")]
    Upgrading,
}