Skip to content

Commit 71abaee

Browse files
committed
refactor: use v2 JavaCommonConfig and remove local framework module
1 parent b96ea85 commit 71abaee

10 files changed

Lines changed: 283 additions & 581 deletions

File tree

Cargo.lock

Lines changed: 13 additions & 13 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.nix

Lines changed: 13 additions & 13 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 9 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -33,11 +33,12 @@ mod tests {
3333
api::core::v1::{PodAffinityTerm, PodAntiAffinity, WeightedPodAffinityTerm},
3434
apimachinery::pkg::apis::meta::v1::LabelSelector,
3535
},
36-
kube::runtime::reflector::ObjectRef,
37-
role_utils::RoleGroupRef,
3836
};
3937

40-
use crate::crd::{affinity::ZookeeperRole, v1alpha1};
38+
use crate::{
39+
crd::affinity::ZookeeperRole,
40+
zk_controller::test_support::{minimal_zk, validated_cluster},
41+
};
4142

4243
#[test]
4344
fn test_affinity_defaults() {
@@ -49,25 +50,12 @@ mod tests {
4950
spec:
5051
image:
5152
productVersion: 3.9.5
52-
clusterConfig:
53-
authentication:
54-
- authenticationClass: zk-client-tls
55-
tls:
56-
serverSecretClass: tls
57-
quorumSecretClass: tls
5853
servers:
5954
roleGroups:
6055
default:
6156
replicas: 3
6257
"#;
63-
let zk: v1alpha1::ZookeeperCluster =
64-
serde_yaml::from_str(input).expect("illegal test input");
65-
66-
let rolegroup_ref = RoleGroupRef {
67-
cluster: ObjectRef::from_obj(&zk),
68-
role: ZookeeperRole::Server.to_string(),
69-
role_group: "default".to_string(),
70-
};
58+
let zk = minimal_zk(input);
7159

7260
let expected: StackableAffinity = StackableAffinity {
7361
pod_affinity: None,
@@ -110,10 +98,10 @@ mod tests {
11098
node_selector: None,
11199
};
112100

113-
let affinity = zk
114-
.merged_config(&ZookeeperRole::Server, &rolegroup_ref)
115-
.unwrap()
116-
.affinity;
101+
let affinity = validated_cluster(&zk).role_group_configs[&ZookeeperRole::Server]["default"]
102+
.config
103+
.affinity
104+
.clone();
117105

118106
assert_eq!(affinity, expected);
119107
}

0 commit comments

Comments
 (0)