Loading Dockerfile +2 −2 Original line number Diff line number Diff line Loading @@ -2,5 +2,5 @@ FROM ibm-semeru-runtimes:open-17.0.7_7-jdk MAINTAINER openslice.io RUN mkdir /opt/shareclasses RUN mkdir -p /opt/openslice/lib/ COPY target/org.etsi.osl.cridge-1.3.0-exec.jar /opt/openslice/lib/ CMD ["java", "-Xshareclasses:cacheDir=/opt/shareclasses", "-jar", "/opt/openslice/lib/org.etsi.osl.cridge-1.3.0-exec.jar"] COPY target/org.etsi.osl.cridge-1.4.0-exec.jar /opt/openslice/lib/ CMD ["java", "-Xshareclasses:cacheDir=/opt/shareclasses", "-jar", "/opt/openslice/lib/org.etsi.osl.cridge-1.4.0-exec.jar"] pom.xml +1 −1 Original line number Diff line number Diff line Loading @@ -5,7 +5,7 @@ <parent> <groupId>org.etsi.osl</groupId> <artifactId>org.etsi.osl.main</artifactId> <version>2025Q4</version> <version>2026Q2</version> <relativePath>../org.etsi.osl.main</relativePath> </parent> Loading src/main/java/org/etsi/osl/cridge/WatcherService.java +21 −1 Original line number Diff line number Diff line Loading @@ -3,6 +3,7 @@ package org.etsi.osl.cridge; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Optional; import org.etsi.osl.domain.model.kubernetes.KubernetesCRDV1; import org.etsi.osl.tmf.ri639.model.Resource; import org.etsi.osl.tmf.ri639.model.ResourceCreate; Loading @@ -18,6 +19,7 @@ import org.springframework.context.event.EventListener; import org.springframework.stereotype.Service; import io.fabric8.kubernetes.api.model.GenericKubernetesResource; import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition; import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinitionVersion; import io.fabric8.kubernetes.client.Watch; import io.fabric8.kubernetes.client.Watcher; import io.fabric8.kubernetes.client.WatcherException; Loading Loading @@ -197,12 +199,30 @@ public class WatcherService { } protected void createCRDSharedIndexInformer(CustomResourceDefinition crd) { Optional<CustomResourceDefinitionVersion> storageAndServed = crd.getSpec().getVersions() .stream() .filter(v -> Boolean.TRUE.equals(v.getStorage()) && Boolean.TRUE.equals(v.getServed())) .findFirst(); Optional<CustomResourceDefinitionVersion> anyServed = crd.getSpec().getVersions() .stream() .filter(v -> Boolean.TRUE.equals(v.getServed())) .findFirst(); CustomResourceDefinitionVersion versionToUse = storageAndServed.orElseGet(() -> anyServed.orElse(null)); if (versionToUse == null) { logger.error("Cannot create createCRDSharedIndexInformer. No served version found in kind: {}", crd.getSpec().getNames().getKind()); return; } ResourceDefinitionContext context = new ResourceDefinitionContext.Builder() .withGroup(crd.getSpec().getGroup()) .withVersion(crd.getSpec().getVersions().get(0).getName()) .withVersion(versionToUse.getName()) .withKind(crd.getSpec().getNames().getKind()) .withPlural(crd.getSpec().getNames().getPlural()).build(); try { int a = kubernetesClientResource.getKubernetesClient().genericKubernetesResources(context).list().getItems().size(); } catch (Exception e) { Loading Loading
Dockerfile +2 −2 Original line number Diff line number Diff line Loading @@ -2,5 +2,5 @@ FROM ibm-semeru-runtimes:open-17.0.7_7-jdk MAINTAINER openslice.io RUN mkdir /opt/shareclasses RUN mkdir -p /opt/openslice/lib/ COPY target/org.etsi.osl.cridge-1.3.0-exec.jar /opt/openslice/lib/ CMD ["java", "-Xshareclasses:cacheDir=/opt/shareclasses", "-jar", "/opt/openslice/lib/org.etsi.osl.cridge-1.3.0-exec.jar"] COPY target/org.etsi.osl.cridge-1.4.0-exec.jar /opt/openslice/lib/ CMD ["java", "-Xshareclasses:cacheDir=/opt/shareclasses", "-jar", "/opt/openslice/lib/org.etsi.osl.cridge-1.4.0-exec.jar"]
pom.xml +1 −1 Original line number Diff line number Diff line Loading @@ -5,7 +5,7 @@ <parent> <groupId>org.etsi.osl</groupId> <artifactId>org.etsi.osl.main</artifactId> <version>2025Q4</version> <version>2026Q2</version> <relativePath>../org.etsi.osl.main</relativePath> </parent> Loading
src/main/java/org/etsi/osl/cridge/WatcherService.java +21 −1 Original line number Diff line number Diff line Loading @@ -3,6 +3,7 @@ package org.etsi.osl.cridge; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Optional; import org.etsi.osl.domain.model.kubernetes.KubernetesCRDV1; import org.etsi.osl.tmf.ri639.model.Resource; import org.etsi.osl.tmf.ri639.model.ResourceCreate; Loading @@ -18,6 +19,7 @@ import org.springframework.context.event.EventListener; import org.springframework.stereotype.Service; import io.fabric8.kubernetes.api.model.GenericKubernetesResource; import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition; import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinitionVersion; import io.fabric8.kubernetes.client.Watch; import io.fabric8.kubernetes.client.Watcher; import io.fabric8.kubernetes.client.WatcherException; Loading Loading @@ -197,12 +199,30 @@ public class WatcherService { } protected void createCRDSharedIndexInformer(CustomResourceDefinition crd) { Optional<CustomResourceDefinitionVersion> storageAndServed = crd.getSpec().getVersions() .stream() .filter(v -> Boolean.TRUE.equals(v.getStorage()) && Boolean.TRUE.equals(v.getServed())) .findFirst(); Optional<CustomResourceDefinitionVersion> anyServed = crd.getSpec().getVersions() .stream() .filter(v -> Boolean.TRUE.equals(v.getServed())) .findFirst(); CustomResourceDefinitionVersion versionToUse = storageAndServed.orElseGet(() -> anyServed.orElse(null)); if (versionToUse == null) { logger.error("Cannot create createCRDSharedIndexInformer. No served version found in kind: {}", crd.getSpec().getNames().getKind()); return; } ResourceDefinitionContext context = new ResourceDefinitionContext.Builder() .withGroup(crd.getSpec().getGroup()) .withVersion(crd.getSpec().getVersions().get(0).getName()) .withVersion(versionToUse.getName()) .withKind(crd.getSpec().getNames().getKind()) .withPlural(crd.getSpec().getNames().getPlural()).build(); try { int a = kubernetesClientResource.getKubernetesClient().genericKubernetesResources(context).list().getItems().size(); } catch (Exception e) { Loading