Skip to content

Commit 9cdf308

Browse files
committed
rename structs for consistency
1 parent a69cdf2 commit 9cdf308

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ pub mod versioned {
9494

9595
/// A Spark Connect server definition.
9696
#[serde(default)]
97-
pub server: ServerConfigWrapper,
97+
pub server: SparkConnectServerConfigWrapper,
9898

9999
/// Spark Connect executor properties.
100100
#[serde(default, skip_serializing_if = "Option::is_none")]
@@ -103,15 +103,15 @@ pub mod versioned {
103103

104104
/// This struct i
105105
#[derive(Clone, Debug, Default, JsonSchema, PartialEq, Serialize, Deserialize)]
106-
pub struct ServerConfigWrapper {
106+
pub struct SparkConnectServerConfigWrapper {
107107
#[serde(flatten)]
108108
pub config: Option<CommonConfiguration<ServerConfigFragment, JavaCommonConfig>>,
109109

110-
pub role_config: ServerRoleConfig,
110+
pub role_config: SparkConnectServerRoleConfig,
111111
}
112112

113113
#[derive(Clone, Debug, JsonSchema, PartialEq, Serialize, Deserialize)]
114-
pub struct ServerRoleConfig {
114+
pub struct SparkConnectServerRoleConfig {
115115
/// This field controls which [ListenerClass](DOCS_BASE_URL_PLACEHOLDER/listener-operator/listenerclass.html) is used to expose the Spark services.
116116
#[serde(default = "default_listener_class")]
117117
pub listener_class: String,
@@ -287,9 +287,9 @@ impl v1alpha1::SparkConnectServer {
287287
}
288288
}
289289

290-
impl Default for v1alpha1::ServerRoleConfig {
290+
impl Default for v1alpha1::SparkConnectServerRoleConfig {
291291
fn default() -> Self {
292-
v1alpha1::ServerRoleConfig {
292+
v1alpha1::SparkConnectServerRoleConfig {
293293
listener_class: default_listener_class(),
294294
}
295295
}

rust/operator-binary/src/connect/server.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -625,7 +625,7 @@ fn dummy_role_group_ref(
625625

626626
pub(crate) fn build_listener(
627627
scs: &v1alpha1::SparkConnectServer,
628-
role_config: &v1alpha1::ServerRoleConfig,
628+
role_config: &v1alpha1::SparkConnectServerRoleConfig,
629629
resolved_product_image: &ResolvedProductImage,
630630
) -> Result<listener::v1alpha1::Listener, Error> {
631631
let listener_name = dummy_role_group_ref(scs).object_name();

0 commit comments

Comments
 (0)