Skip to content

Commit

Permalink
Merge pull request #3801 from MDeLuise/feature/protobuf-compiled
Browse files Browse the repository at this point in the history
Feature provide compiled version of protobuf payload
  • Loading branch information
Coduz authored Jul 19, 2023
2 parents 3dfb95d + 8613eea commit 99c93c9
Show file tree
Hide file tree
Showing 21 changed files with 13,858 additions and 160 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,4 +28,7 @@

<!-- Ignore the about.html file -->
<suppress checks="FileTabCharacter" files="about\.html"/>

<!-- Ignore protobuf compiled files -->
<suppress checks=".*" files="KuraPayloadProto\.java"/>
</suppressions>
23 changes: 0 additions & 23 deletions client/gateway/profile/kura/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -95,35 +95,12 @@

<build>
<plugins>

<plugin>
<groupId>com.github.os72</groupId>
<artifactId>protoc-jar-maven-plugin</artifactId>
<executions>
<execution>
<phase>generate-sources</phase>
<goals>
<goal>run</goal>
</goals>
<configuration>
<protocArtifact>com.google.protobuf:protoc:${protobuf.version}:exe</protocArtifact>
<protocVersion>${protobuf.version}</protocVersion>
<includeMavenTypes>transitive</includeMavenTypes>
<inputDirectories>
<include>src/main/protobuf</include>
</inputDirectories>
</configuration>
</execution>
</executions>
</plugin>

<plugin>
<artifactId>maven-javadoc-plugin</artifactId>
<configuration>
<excludePackageNames>org.eclipse.kapua.gateway.client.kura.payload</excludePackageNames>
</configuration>
</plugin>

</plugins>
</build>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,17 +12,17 @@
*******************************************************************************/
package org.eclipse.kapua.client.gateway.kura;

import java.nio.ByteBuffer;
import java.time.Instant;
import java.util.Map;
import java.util.Objects;

import org.eclipse.kapua.client.gateway.BinaryPayloadCodec;
import org.eclipse.kapua.client.gateway.Payload;
import org.eclipse.kapua.client.gateway.kura.internal.Metrics;
import org.eclipse.kapua.client.gateway.kura.proto.KuraPayloadProto;
import org.eclipse.kapua.client.gateway.kura.proto.KuraPayloadProto.KuraPayload;
import org.eclipse.kapua.client.gateway.spi.util.Buffers;
import org.eclipse.kapua.gateway.client.kura.payload.KuraPayloadProto;
import org.eclipse.kapua.gateway.client.kura.payload.KuraPayloadProto.KuraPayload;

import java.nio.ByteBuffer;
import java.time.Instant;
import java.util.Map;
import java.util.Objects;

public class KuraBinaryPayloadCodec implements BinaryPayloadCodec {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,14 @@
*******************************************************************************/
package org.eclipse.kapua.client.gateway.kura;

import org.eclipse.kapua.client.gateway.kura.internal.Metrics;
import org.eclipse.kapua.client.gateway.kura.proto.KuraPayloadProto.KuraPayload;
import org.eclipse.kapua.client.gateway.mqtt.MqttModuleContext;
import org.eclipse.kapua.client.gateway.spi.Module;
import org.eclipse.kapua.client.gateway.spi.ModuleContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.nio.ByteBuffer;
import java.util.Collection;
import java.util.Collections;
Expand All @@ -23,14 +31,6 @@
import java.util.Set;
import java.util.TreeSet;

import org.eclipse.kapua.client.gateway.kura.internal.Metrics;
import org.eclipse.kapua.client.gateway.mqtt.MqttModuleContext;
import org.eclipse.kapua.client.gateway.spi.Module;
import org.eclipse.kapua.client.gateway.spi.ModuleContext;
import org.eclipse.kapua.gateway.client.kura.payload.KuraPayloadProto.KuraPayload;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class KuraBirthCertificateModule implements Module {

private static final Logger logger = LoggerFactory.getLogger(KuraBirthCertificateModule.class);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,18 +12,17 @@
*******************************************************************************/
package org.eclipse.kapua.client.gateway.kura.internal;

import com.google.protobuf.ByteString;
import org.eclipse.kapua.client.gateway.kura.proto.KuraPayloadProto.KuraPayload;
import org.eclipse.kapua.client.gateway.kura.proto.KuraPayloadProto.KuraPayload.KuraMetric;
import org.eclipse.kapua.client.gateway.kura.proto.KuraPayloadProto.KuraPayload.KuraMetric.ValueType;

import java.nio.ByteBuffer;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.TreeMap;

import org.eclipse.kapua.gateway.client.kura.payload.KuraPayloadProto.KuraPayload;
import org.eclipse.kapua.gateway.client.kura.payload.KuraPayloadProto.KuraPayload.KuraMetric;
import org.eclipse.kapua.gateway.client.kura.payload.KuraPayloadProto.KuraPayload.KuraMetric.ValueType;

import com.google.protobuf.ByteString;

public final class Metrics {

private Metrics() {
Expand Down
Loading

0 comments on commit 99c93c9

Please sign in to comment.