chore: 2026.09 Release

Merge request reports

Loading
+13 −0
Changes for src/main/java/org/etsi/osl/hypo/registry/kafka/outgoing/RegistryKafkaProducer.java: 13 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -86,6 +86,19 @@ public class RegistryKafkaProducer {
        logger.debugf(ApplicationProperties.PAYLOAD_S, responseMessage.toStringAsJson());
    }

    public void sendKubeConfigResponseMessage(
            VaultSecretResponseMessage responseMessage, Headers headers) {
        OutgoingKafkaRecordMetadata<Object> kafkaMetadata =
                OutgoingKafkaRecordMetadata.builder().withHeaders(headers).build();
        vaultSecretResponseMessageEmitter.send(Message.of(responseMessage, Metadata.of(kafkaMetadata)));

        logger.debugf(
                "Kube Conf Response data message with headers sent to KAFKA topic: %s",
                REGISTRY_RESPONSE_KUBE_CONF_CHANNEL);

        logger.debugf(ApplicationProperties.PAYLOAD_S, responseMessage.toStringAsJson());
    }

    public void sendOrganizationCredentialsResponseMessage(
            CloudEventRegistryOrganizationCredentialsResult responseMessage) {
        organizationCredentialsResultEmitter.send(responseMessage);
+2 −1
Changes for src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/KubeConfigRequest.java: 2 added lines, 1 removed line.
Original line number Diff line number Diff line
package org.etsi.osl.hypo.registry.model.kafka.incoming;

import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.JsonNode;
import java.util.List;
import lombok.Data;
import org.etsi.osl.hypo.registry.utils.JsonObjectWriter;
@@ -11,7 +12,7 @@ public class KubeConfigRequest implements KafkaRequestPayload {
    @JsonProperty(access = JsonProperty.Access.WRITE_ONLY)
    private String type;

    private ServiceOperationRequest serviceOperationRequest;
    private JsonNode serviceOperationRequest;
    private String kubernetesServiceID;
    private List<String> secretNames;

+2 −1
Changes for src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/RegistryURLRequest.java: 2 added lines, 1 removed line.
Original line number Diff line number Diff line
package org.etsi.osl.hypo.registry.model.kafka.incoming;

import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.JsonNode;
import lombok.Data;
import org.etsi.osl.hypo.registry.utils.JsonObjectWriter;

@@ -11,7 +12,7 @@ public class RegistryURLRequest implements KafkaRequestPayload {
    @JsonProperty(access = JsonProperty.Access.WRITE_ONLY)
    private String type;

    private ServiceOrderRequest serviceOrderRequest;
    private JsonNode serviceOrderRequest;
    private String url;
    private String schedulerNamespace;

+0 −18
Changes for src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/ServiceOperationRequest.java: 0 added lines, 18 removed lines.
Original line number Diff line number Diff line
package org.etsi.osl.hypo.registry.model.kafka.incoming;

import lombok.Data;
import org.etsi.osl.hypo.registry.utils.JsonObjectWriter;

@Data
public class ServiceOperationRequest {
    private String kogitoprocinstanceid;
    private String serviceOrderId;
    private String serviceId;
    private boolean activateService;
    private String servicePackageValuesYml;
    private String requestedCompletionDate;

    public String toStringAsJson() {
        return JsonObjectWriter.writeValueAsJsonString(this);
    }
}
+0 −22
Changes for src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/ServiceOrder.java: 0 added lines, 22 removed lines.
Original line number Diff line number Diff line
package org.etsi.osl.hypo.registry.model.kafka.incoming;

import lombok.Data;
import org.etsi.osl.hypo.registry.utils.JsonObjectWriter;

@Data
public class ServiceOrder {
    private String serviceOrderId;
    private String serviceId;
    private String servicePackageManager;
    private String serviceRepositoryURL;
    private String serviceArtifactIdentifier;
    private String serviceArtifactVersion;
    private String servicePackageValuesYml;
    private String clusterManager;
    private String clusterMetadata;
    private String requestedCompletionDate;

    public String toStringAsJson() {
        return JsonObjectWriter.writeValueAsJsonString(this);
    }
}
Loading
Loading