Loading src/main/java/org/etsi/osl/hypo/registry/kafka/outgoing/RegistryKafkaProducer.java +13 −0 Viewed 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 Loading @@ -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); Loading src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/KubeConfigRequest.java +2 −1 Viewed 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; Loading @@ -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; Loading src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/RegistryURLRequest.java +2 −1 Viewed 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; Loading @@ -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; Loading src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/ServiceOperationRequest.javadeleted 100644 → 0 +0 −18 Viewed 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); } } src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/ServiceOrder.javadeleted 100644 → 0 +0 −22 Viewed 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
src/main/java/org/etsi/osl/hypo/registry/kafka/outgoing/RegistryKafkaProducer.java +13 −0 Viewed 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 Loading @@ -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); Loading
src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/KubeConfigRequest.java +2 −1 Viewed 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; Loading @@ -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; Loading
src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/RegistryURLRequest.java +2 −1 Viewed 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; Loading @@ -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; Loading
src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/ServiceOperationRequest.javadeleted 100644 → 0 +0 −18 Viewed 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); } }
src/main/java/org/etsi/osl/hypo/registry/model/kafka/incoming/ServiceOrder.javadeleted 100644 → 0 +0 −22 Viewed 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); } }