Skip to content

Commit de413d3

Browse files
committed
Cleaning up leftovers
1 parent 5ac30df commit de413d3

2 files changed

Lines changed: 0 additions & 39 deletions

File tree

rust/operator-binary/src/controller.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -450,7 +450,6 @@ pub async fn reconcile_hive(
450450

451451
let mut ss_cond_builder = StatefulSetConditionBuilder::default();
452452

453-
// TODO: You want to add service creation in this for loop
454453
// for each rg a service needs to be build for hive
455454
for (rolegroup_name, rolegroup_config) in metastore_config.iter() {
456455
let rolegroup = hive.metastore_rolegroup_ref(rolegroup_name);
@@ -755,7 +754,6 @@ fn build_metastore_rolegroup_config_map(
755754
/// The rolegroup [`Service`] is a headless service that allows direct access to the instances of a certain rolegroup
756755
///
757756
/// This is mostly useful for internal communication between peers, or for clients that perform client-side load balancing.
758-
// TODO: However it looks like I need to add it here as services will be created here by rolegroup
759757
fn build_rolegroup_service(
760758
hive: &v1alpha1::HiveCluster,
761759
resolved_product_image: &ResolvedProductImage,

rust/operator-binary/src/crd/mod.rs

Lines changed: 0 additions & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -299,29 +299,6 @@ impl v1alpha1::HiveCluster {
299299
}
300300
}
301301

302-
// TODO: Temporary solution until listener-operator is finished
303-
#[derive(Clone, Debug, Default, Display, Deserialize, Eq, JsonSchema, PartialEq, Serialize)]
304-
#[serde(rename_all = "PascalCase")]
305-
pub enum CurrentlySupportedListenerClasses {
306-
#[default]
307-
#[serde(rename = "cluster-internal")]
308-
ClusterInternal,
309-
#[serde(rename = "external-unstable")]
310-
ExternalUnstable,
311-
#[serde(rename = "external-stable")]
312-
ExternalStable,
313-
}
314-
315-
impl CurrentlySupportedListenerClasses {
316-
pub fn k8s_service_type(&self) -> String {
317-
match self {
318-
CurrentlySupportedListenerClasses::ClusterInternal => "ClusterIP".to_string(),
319-
CurrentlySupportedListenerClasses::ExternalUnstable => "NodePort".to_string(),
320-
CurrentlySupportedListenerClasses::ExternalStable => "LoadBalancer".to_string(),
321-
}
322-
}
323-
}
324-
325302
#[derive(Clone, Debug, Deserialize, Eq, JsonSchema, PartialEq, Serialize)]
326303
#[serde(rename_all = "camelCase")]
327304
pub struct HdfsConnection {
@@ -490,20 +467,6 @@ impl MetaStoreConfig {
490467
}
491468
}
492469

493-
// TODO: Temporary solution until listener-operator is finished
494-
#[derive(Clone, Debug, Display, Deserialize, Eq, JsonSchema, PartialEq, Serialize)]
495-
#[serde(rename_all = "PascalCase")]
496-
pub enum ServiceType {
497-
NodePort,
498-
ClusterIP,
499-
}
500-
501-
impl Default for ServiceType {
502-
fn default() -> Self {
503-
Self::NodePort
504-
}
505-
}
506-
507470
#[derive(
508471
Clone, Debug, Deserialize, Eq, Hash, JsonSchema, PartialEq, Serialize, Display, EnumString,
509472
)]

0 commit comments

Comments
 (0)