diff --git a/nexus/pt/src/flow_model.rs b/nexus/pt/src/flow_model.rs index 54c4863fad..021af81bbf 100644 --- a/nexus/pt/src/flow_model.rs +++ b/nexus/pt/src/flow_model.rs @@ -11,43 +11,6 @@ pub struct FlowJobTableMapping { pub exclude: Vec, } -#[derive(Debug, PartialEq, Eq, Serialize, Deserialize, Clone)] -pub enum FlowSyncMode { - Avro, - SQL, -} - -impl FlowSyncMode { - pub fn parse_string(s: &str) -> Result { - match s { - "avro" => Ok(FlowSyncMode::Avro), - "sql" => Ok(FlowSyncMode::SQL), - _ => Err(format!("{} is not a valid FlowSyncMode", s)), - } - } -} - -impl std::str::FromStr for FlowSyncMode { - type Err = String; - - fn from_str(s: &str) -> Result { - match s { - "avro" => Ok(FlowSyncMode::Avro), - "default" => Ok(FlowSyncMode::SQL), - _ => Err(format!("{} is not a valid FlowSyncMode", s)), - } - } -} - -impl ToString for FlowSyncMode { - fn to_string(&self) -> String { - match self { - FlowSyncMode::Avro => "avro".to_string(), - FlowSyncMode::SQL => "default".to_string(), - } - } -} - #[derive(Debug, PartialEq, Eq, Serialize, Deserialize, Clone)] pub struct FlowJob { pub name: String,