@Test public void testIsNodeOwnedByFenzo() { assertThat(KubeUtil.isNodeOwnedByFenzo(FARZONES, newNodeInZone(FARZONE_A))).isFalse(); assertThat(KubeUtil.isNodeOwnedByFenzo(FARZONES, newNodeInZoneWithTaints(NOT_FARZONE, TAINT_SCHEDULER_FENZO))).isTrue(); assertThat(KubeUtil.isNodeOwnedByFenzo(FARZONES, newNodeInZoneWithTaints(FARZONE_A, TAINT_SCHEDULER_FENZO))).isFalse(); assertThat(KubeUtil.isNodeOwnedByFenzo(FARZONES, newNodeWithoutZone(TAINT_SCHEDULER_OTHER))).isFalse(); assertThat(KubeUtil.isNodeOwnedByFenzo(FARZONES, newNodeWithoutZone(TAINT_SCHEDULER_FENZO))).isTrue(); }
public static boolean isNodeOwnedByFenzo(List<String> farzones, V1Node node) { if (isFarzoneNode(farzones, node)) { logger.debug("Not owned by fenzo (farzone node): {}", node.getMetadata().getName()); return false; } if (!hasFenzoSchedulerTaint(node)) { logger.debug("Not owned by fenzo (non Fenzo scheduler taint): {}", node.getMetadata().getName()); return false; } logger.debug("Owned by fenzo"); return true; }
KubeUtil { public static boolean isNodeOwnedByFenzo(List<String> farzones, V1Node node) { if (isFarzoneNode(farzones, node)) { logger.debug("Not owned by fenzo (farzone node): {}", node.getMetadata().getName()); return false; } if (!hasFenzoSchedulerTaint(node)) { logger.debug("Not owned by fenzo (non Fenzo scheduler taint): {}", node.getMetadata().getName()); return false; } logger.debug("Owned by fenzo"); return true; } }
KubeUtil { public static boolean isNodeOwnedByFenzo(List<String> farzones, V1Node node) { if (isFarzoneNode(farzones, node)) { logger.debug("Not owned by fenzo (farzone node): {}", node.getMetadata().getName()); return false; } if (!hasFenzoSchedulerTaint(node)) { logger.debug("Not owned by fenzo (non Fenzo scheduler taint): {}", node.getMetadata().getName()); return false; } logger.debug("Owned by fenzo"); return true; }  }
KubeUtil { public static boolean isNodeOwnedByFenzo(List<String> farzones, V1Node node) { if (isFarzoneNode(farzones, node)) { logger.debug("Not owned by fenzo (farzone node): {}", node.getMetadata().getName()); return false; } if (!hasFenzoSchedulerTaint(node)) { logger.debug("Not owned by fenzo (non Fenzo scheduler taint): {}", node.getMetadata().getName()); return false; } logger.debug("Owned by fenzo"); return true; }  static int estimatePodSize(V1Pod v1Pod); static boolean isPodPhaseTerminal(String phase); static Optional<Long> findFinishedTimestamp(V1Pod pod); static Optional<TitusExecutorDetails> getTitusExecutorDetails(V1Pod pod); static Optional<V1ContainerState> findContainerState(V1Pod pod); static Optional<V1ContainerStateTerminated> findTerminatedContainerStatus(V1Pod pod); static String formatV1ContainerState(V1ContainerState containerState); static Optional<String> findFarzoneId(DirectKubeConfiguration configuration, Job job); static boolean isOwnedByKubeScheduler(V1Pod v1Pod); static Optional<String> getNodeIpV4Address(V1Node node); static Map<String, String> createPodAnnotations(
            Job<?> job,
            Task task,
            byte[] containerInfoData,
            Map<String, String> passthroughAttributes,
            boolean includeJobDescriptor
    ); static Map<String, String> createPodAnnotationsFromJobParameters(Job<?> job); static boolean isNodeOwnedByFenzo(List<String> farzones, V1Node node); static boolean hasFenzoSchedulerTaint(V1Node node); static boolean isFarzoneNode(List<String> farzones, V1Node node); static String toErrorDetails(Throwable e); static Mono<T> toReact(KubeFunction<ApiCallback<T>, Call> handler); static String getMetadataName(V1ObjectMeta metadata); static Optional<V1NodeCondition> findNodeCondition(V1Node node, String type); static boolean hasUninitializedTaint(V1Node node); }
KubeUtil { public static boolean isNodeOwnedByFenzo(List<String> farzones, V1Node node) { if (isFarzoneNode(farzones, node)) { logger.debug("Not owned by fenzo (farzone node): {}", node.getMetadata().getName()); return false; } if (!hasFenzoSchedulerTaint(node)) { logger.debug("Not owned by fenzo (non Fenzo scheduler taint): {}", node.getMetadata().getName()); return false; } logger.debug("Owned by fenzo"); return true; }  static int estimatePodSize(V1Pod v1Pod); static boolean isPodPhaseTerminal(String phase); static Optional<Long> findFinishedTimestamp(V1Pod pod); static Optional<TitusExecutorDetails> getTitusExecutorDetails(V1Pod pod); static Optional<V1ContainerState> findContainerState(V1Pod pod); static Optional<V1ContainerStateTerminated> findTerminatedContainerStatus(V1Pod pod); static String formatV1ContainerState(V1ContainerState containerState); static Optional<String> findFarzoneId(DirectKubeConfiguration configuration, Job job); static boolean isOwnedByKubeScheduler(V1Pod v1Pod); static Optional<String> getNodeIpV4Address(V1Node node); static Map<String, String> createPodAnnotations(
            Job<?> job,
            Task task,
            byte[] containerInfoData,
            Map<String, String> passthroughAttributes,
            boolean includeJobDescriptor
    ); static Map<String, String> createPodAnnotationsFromJobParameters(Job<?> job); static boolean isNodeOwnedByFenzo(List<String> farzones, V1Node node); static boolean hasFenzoSchedulerTaint(V1Node node); static boolean isFarzoneNode(List<String> farzones, V1Node node); static String toErrorDetails(Throwable e); static Mono<T> toReact(KubeFunction<ApiCallback<T>, Call> handler); static String getMetadataName(V1ObjectMeta metadata); static Optional<V1NodeCondition> findNodeCondition(V1Node node, String type); static boolean hasUninitializedTaint(V1Node node); static final String TYPE_INTERNAL_IP; }