Skip to content

Commit 1c070a8

Browse files
authored
Merge pull request #329 from oracle/service_helper_refactoring
Add unit tests for ServiceHelper and refactor
2 parents bade38e + 40615c3 commit 1c070a8

File tree

7 files changed

+1150
-856
lines changed

7 files changed

+1150
-856
lines changed

operator/src/main/java/oracle/kubernetes/operator/helpers/HealthCheckHelper.java

Lines changed: 9 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,6 @@ public class HealthCheckHelper {
7575

7676
private static final String DOMAIN_UID_LABEL = "weblogic.domainUID";
7777
private static final String MINIMUM_K8S_VERSION = "v1.7.5";
78-
private static final String DOMAIN_IMAGE = "store/oracle/weblogic:12.2.1.3";
7978
private static final String READ_WRITE_MANY_ACCESS = "ReadWriteMany";
8079

8180
/**
@@ -138,9 +137,8 @@ public void performNonSecurityChecks() throws ApiException {
138137
* Verify Access.
139138
*
140139
* @param version Kubernetes version
141-
* @throws ApiException exception for k8s API
142140
*/
143-
public void performSecurityChecks(KubernetesVersion version) throws ApiException {
141+
public void performSecurityChecks(KubernetesVersion version) {
144142

145143
// Validate namespace
146144
if (DEFAULT_NAMESPACE.equals(operatorNamespace)) {
@@ -258,6 +256,10 @@ public KubernetesVersion(int major, int minor) {
258256
this.minor = minor;
259257
}
260258

259+
boolean isPublishNotReadyAddressesSupported() {
260+
return this.major > 1 || (this.major == 1 && this.minor >= 8);
261+
}
262+
261263
@Override
262264
public boolean equals(Object o) {
263265
return this == o || o instanceof KubernetesVersion && equals((KubernetesVersion) o);
@@ -282,14 +284,13 @@ public String toString() {
282284
* Verify the k8s version.
283285
*
284286
* @return Major and minor version information
285-
* @throws ApiException exception for k8s API
286287
*/
287-
public KubernetesVersion performK8sVersionCheck() throws ApiException {
288+
public KubernetesVersion performK8sVersionCheck() {
288289

289290
// k8s version must be 1.7.5 or greater
290291
LOGGER.info(MessageKeys.VERIFY_K8S_MIN_VERSION);
291292
boolean k8sMinVersion = true;
292-
VersionInfo info = null;
293+
VersionInfo info;
293294

294295
int major = 0;
295296
int minor = 0;
@@ -419,12 +420,8 @@ private void verifyPersistentVolume(HashMap<String, Domain> domainUIDMap) throws
419420
}
420421
}
421422

422-
/**
423-
* Perform health checks against a running Admin server.
424-
*
425-
* @throws ApiException exception for k8s API
426-
*/
427-
private void verifyAdminServer(HashMap<String, Domain> domainUIDMap) throws ApiException {
423+
/** Perform health checks against a running Admin server. */
424+
private void verifyAdminServer(HashMap<String, Domain> domainUIDMap) {
428425

429426
for (Domain domain : domainUIDMap.values()) {
430427
if (isAdminServerRunning(domain)) {

0 commit comments

Comments
 (0)