Skip to content
Snippets Groups Projects
Commit cfad1501 authored by Vasilis Katopodis's avatar Vasilis Katopodis
Browse files

Add runAddPolicy.js test. Add remote-dev building params

parent aefd6f2b
No related branches found
No related tags found
2 merge requests!142Release TeraFlowSDN 2.1,!121Add Policy component serializer extensions
Showing
with 3827 additions and 627 deletions
...@@ -7,7 +7,7 @@ export TFS_REGISTRY_IMAGE="http://localhost:32000/tfs/" ...@@ -7,7 +7,7 @@ export TFS_REGISTRY_IMAGE="http://localhost:32000/tfs/"
# interdomain slice pathcomp dlt # interdomain slice pathcomp dlt
# dbscanserving opticalattackmitigator opticalattackdetector # dbscanserving opticalattackmitigator opticalattackdetector
# l3_attackmitigator l3_centralizedattackdetector l3_distributedattackdetector # l3_attackmitigator l3_centralizedattackdetector l3_distributedattackdetector
export TFS_COMPONENTS="context device automation monitoring pathcomp service slice compute webui" export TFS_COMPONENTS="context device automation monitoring pathcomp service slice compute webui policy"
# Set the tag you want to use for your images. # Set the tag you want to use for your images.
export TFS_IMAGE_TAG="dev" export TFS_IMAGE_TAG="dev"
......
...@@ -51,6 +51,7 @@ RUN microdnf install curl ca-certificates ${JAVA_PACKAGE} \ ...@@ -51,6 +51,7 @@ RUN microdnf install curl ca-certificates ${JAVA_PACKAGE} \
&& chmod 540 /deployments/run-java.sh \ && chmod 540 /deployments/run-java.sh \
&& echo "securerandom.source=file:/dev/urandom" >> /etc/alternatives/jre/conf/security/java.security && echo "securerandom.source=file:/dev/urandom" >> /etc/alternatives/jre/conf/security/java.security
ENV QUARKUS_LAUNCH_DEVMODE="true"
# Configure the JAVA_OPTIONS, you can add -XshowSettings:vm to also display the heap size. # Configure the JAVA_OPTIONS, you can add -XshowSettings:vm to also display the heap size.
ENV JAVA_OPTIONS="-Dquarkus.http.host=0.0.0.0 -Djava.util.logging.manager=org.jboss.logmanager.LogManager" ENV JAVA_OPTIONS="-Dquarkus.http.host=0.0.0.0 -Djava.util.logging.manager=org.jboss.logmanager.LogManager"
# We make four distinct layers so if there are application changes the library layers can be re-used # We make four distinct layers so if there are application changes the library layers can be re-used
......
...@@ -58,8 +58,8 @@ public class PolicyRuleConditionValidator { ...@@ -58,8 +58,8 @@ public class PolicyRuleConditionValidator {
return isDeviceIdValid; return isDeviceIdValid;
} }
public Uni<Boolean> validateServiceId(ServiceId serviceId) { public Uni<Boolean> validateServiceId(ServiceId serviceId, List<String> deviceIds) {
final var isServiceIdValid = isServiceIdValid(serviceId); final var isServiceIdValid = isServiceIdValid(serviceId, deviceIds);
isServiceIdValid isServiceIdValid
.subscribe() .subscribe()
...@@ -101,14 +101,27 @@ public class PolicyRuleConditionValidator { ...@@ -101,14 +101,27 @@ public class PolicyRuleConditionValidator {
return deviceDeviceId.equals(deviceId); return deviceDeviceId.equals(deviceId);
} }
private Uni<Boolean> isServiceIdValid(ServiceId serviceId) { public Uni<Boolean> isServiceIdValid(ServiceId serviceId, List<String> deviceIds) {
return contextService return contextService
.getService(serviceId) .getService(serviceId)
.onFailure()
.recoverWithItem((Service) null)
.onItem() .onItem()
.transform(service -> checkIfServiceIdExists(service, serviceId)); .transform(service -> checkIfServiceIsValid(service, serviceId, deviceIds));
}
private boolean checkIfServiceIsValid(
Service service, ServiceId serviceId, List<String> deviceIds) {
return (checkIfServiceIdExists(service, serviceId)
&& checkIfServicesDeviceIdsExist(service, deviceIds));
} }
private boolean checkIfServiceIdExists(Service service, ServiceId serviceId) { private boolean checkIfServiceIdExists(Service service, ServiceId serviceId) {
if (service == null) {
return false;
}
final var serviceServiceIdServiceId = service.getServiceId(); final var serviceServiceIdServiceId = service.getServiceId();
final var serviceServiceIdContextId = serviceServiceIdServiceId.getContextId(); final var serviceServiceIdContextId = serviceServiceIdServiceId.getContextId();
final var serviceServiceIdId = serviceServiceIdServiceId.getId(); final var serviceServiceIdId = serviceServiceIdServiceId.getId();
...@@ -117,14 +130,11 @@ public class PolicyRuleConditionValidator { ...@@ -117,14 +130,11 @@ public class PolicyRuleConditionValidator {
&& serviceServiceIdId.equals(serviceId.getId()); && serviceServiceIdId.equals(serviceId.getId());
} }
public Uni<Boolean> isServicesDeviceIdsValid(ServiceId serviceId, List<String> deviceIds) { private boolean checkIfServicesDeviceIdsExist(Service service, List<String> deviceIds) {
return contextService if (deviceIds.isEmpty()) {
.getService(serviceId) return true;
.onItem()
.transform(service -> checkIfServicesDeviceIdsExist(service, deviceIds));
} }
private boolean checkIfServicesDeviceIdsExist(Service service, List<String> deviceIds) {
List<String> serviceDeviceIds = new ArrayList<>(); List<String> serviceDeviceIds = new ArrayList<>();
for (EndPointId serviceEndPointId : service.getServiceEndPointIds()) { for (EndPointId serviceEndPointId : service.getServiceEndPointIds()) {
serviceDeviceIds.add(serviceEndPointId.getDeviceId()); serviceDeviceIds.add(serviceEndPointId.getDeviceId());
...@@ -133,6 +143,13 @@ public class PolicyRuleConditionValidator { ...@@ -133,6 +143,13 @@ public class PolicyRuleConditionValidator {
return deviceIds.containsAll(serviceDeviceIds); return deviceIds.containsAll(serviceDeviceIds);
} }
public Uni<Boolean> isServicesDeviceIdsValid(ServiceId serviceId, List<String> deviceIds) {
return contextService
.getService(serviceId)
.onItem()
.transform(service -> checkIfServicesDeviceIdsExist(service, deviceIds));
}
private Uni<Boolean> isUpdatedPolicyRuleIdValid(String updatedPolicyRuleId) { private Uni<Boolean> isUpdatedPolicyRuleIdValid(String updatedPolicyRuleId) {
return contextService return contextService
.getPolicyRule(updatedPolicyRuleId) .getPolicyRule(updatedPolicyRuleId)
......
...@@ -160,23 +160,27 @@ public class PolicyServiceImpl implements PolicyService { ...@@ -160,23 +160,27 @@ public class PolicyServiceImpl implements PolicyService {
final var policyRuleBasic = policyRuleService.getPolicyRuleBasic(); final var policyRuleBasic = policyRuleService.getPolicyRuleBasic();
if (!policyRuleBasic.areArgumentsValid()) { if (!policyRuleBasic.areArgumentsValid()) {
LOGGER.error(policyRuleService.getExeceptionMessage()); LOGGER.error(policyRuleService.getExeceptionMessage());
setPolicyRuleServiceToContext( final var policyRuleState =
policyRuleService,
new PolicyRuleState( new PolicyRuleState(
PolicyRuleStateEnum.POLICY_FAILED, policyRuleBasic.getExeceptionMessage())); PolicyRuleStateEnum.POLICY_FAILED, policyRuleBasic.getExeceptionMessage());
return Uni.createFrom().item(policyRuleBasic.getPolicyRuleState()); return Uni.createFrom().item(policyRuleState);
} }
policyRuleBasic.setPolicyRuleState(INSERTED_POLICYRULE_STATE); final var serviceId = policyRuleService.getServiceId();
policyRuleService.setPolicyRuleBasic(policyRuleBasic); final var deviceIds = policyRuleService.getDeviceIds();
final var policyRuleTypeService = new PolicyRuleTypeService(policyRuleService);
final var policyRule = new PolicyRule(policyRuleTypeService);
contextService return policyRuleConditionValidator
.setPolicyRule(policyRule) .isServiceIdValid(serviceId, deviceIds)
.subscribe() .onItem()
.with(id -> validateService(policyRuleService)); .transform(
return Uni.createFrom().item(policyRuleBasic.getPolicyRuleState()); isService -> {
if (!isService) {
return new PolicyRuleState(
PolicyRuleStateEnum.POLICY_FAILED,
String.format(INVALID_MESSAGE, "Service with id: " + serviceId.getId()));
}
return VALIDATED_POLICYRULE_STATE;
});
} }
@Override @Override
...@@ -195,24 +199,27 @@ public class PolicyServiceImpl implements PolicyService { ...@@ -195,24 +199,27 @@ public class PolicyServiceImpl implements PolicyService {
final var policyRuleBasic = policyRuleService.getPolicyRuleBasic(); final var policyRuleBasic = policyRuleService.getPolicyRuleBasic();
if (!policyRuleBasic.areArgumentsValid()) { if (!policyRuleBasic.areArgumentsValid()) {
LOGGER.error(policyRuleService.getExeceptionMessage()); LOGGER.error(policyRuleService.getExeceptionMessage());
setPolicyRuleServiceToContext( final var policyRuleState =
policyRuleService,
new PolicyRuleState( new PolicyRuleState(
PolicyRuleStateEnum.POLICY_FAILED, policyRuleBasic.getExeceptionMessage())); PolicyRuleStateEnum.POLICY_FAILED, policyRuleBasic.getExeceptionMessage());
return Uni.createFrom().item(policyRuleBasic.getPolicyRuleState()); return Uni.createFrom().item(policyRuleState);
} }
policyRuleBasic.setPolicyRuleState(UPDATED_POLICYRULE_STATE); final var serviceId = policyRuleService.getServiceId();
policyRuleService.setPolicyRuleBasic(policyRuleBasic); final var deviceIds = policyRuleService.getDeviceIds();
final var policyRuleTypeService = new PolicyRuleTypeService(policyRuleService);
final var policyRule = new PolicyRule(policyRuleTypeService);
contextService
.setPolicyRule(policyRule)
.subscribe()
.with(id -> validateUpdatedPolicyService(policyRuleService));
return Uni.createFrom().item(policyRuleBasic.getPolicyRuleState()); return policyRuleConditionValidator
.isServiceIdValid(serviceId, deviceIds)
.onItem()
.transform(
isService -> {
if (!isService) {
return new PolicyRuleState(
PolicyRuleStateEnum.POLICY_FAILED,
String.format(INVALID_MESSAGE, "Service with id: " + serviceId.getId()));
}
return UPDATED_POLICYRULE_STATE;
});
} }
@Override @Override
...@@ -650,7 +657,7 @@ public class PolicyServiceImpl implements PolicyService { ...@@ -650,7 +657,7 @@ public class PolicyServiceImpl implements PolicyService {
final var policyRuleBasic = policyRuleService.getPolicyRuleBasic(); final var policyRuleBasic = policyRuleService.getPolicyRuleBasic();
Boolean isServiceIdValid = Boolean isServiceIdValid =
policyRuleConditionValidator.validateServiceId(serviceId).await().indefinitely(); policyRuleConditionValidator.validateServiceId(serviceId, deviceIds).await().indefinitely();
if (!isServiceIdValid) { if (!isServiceIdValid) {
String message = String message =
......
...@@ -13,6 +13,11 @@ ...@@ -13,6 +13,11 @@
# limitations under the License. # limitations under the License.
quarkus: quarkus:
package:
type: mutable-jar
live-reload:
password: 1234
url: http://0.0.0.0:8080
banner: banner:
path: teraflow-policy-banner.txt path: teraflow-policy-banner.txt
grpc: grpc:
...@@ -23,6 +28,9 @@ quarkus: ...@@ -23,6 +28,9 @@ quarkus:
context: context:
host: ${quarkus.kubernetes.env.vars.context-service-host} host: ${quarkus.kubernetes.env.vars.context-service-host}
port: 1010 port: 1010
context_policy:
host: ${quarkus.kubernetes.env.vars.context-service-host}
port: 1010
monitoring: monitoring:
host: ${quarkus.kubernetes.env.vars.monitoring-service-host} host: ${quarkus.kubernetes.env.vars.monitoring-service-host}
port: 7070 port: 7070
......
...@@ -31,6 +31,10 @@ public final class KpiSampleTypes { ...@@ -31,6 +31,10 @@ public final class KpiSampleTypes {
* <code>KPISAMPLETYPE_PACKETS_RECEIVED = 102;</code> * <code>KPISAMPLETYPE_PACKETS_RECEIVED = 102;</code>
*/ */
KPISAMPLETYPE_PACKETS_RECEIVED(102), KPISAMPLETYPE_PACKETS_RECEIVED(102),
/**
* <code>KPISAMPLETYPE_PACKETS_DROPPED = 103;</code>
*/
KPISAMPLETYPE_PACKETS_DROPPED(103),
/** /**
* <code>KPISAMPLETYPE_BYTES_TRANSMITTED = 201;</code> * <code>KPISAMPLETYPE_BYTES_TRANSMITTED = 201;</code>
*/ */
...@@ -39,6 +43,50 @@ public final class KpiSampleTypes { ...@@ -39,6 +43,50 @@ public final class KpiSampleTypes {
* <code>KPISAMPLETYPE_BYTES_RECEIVED = 202;</code> * <code>KPISAMPLETYPE_BYTES_RECEIVED = 202;</code>
*/ */
KPISAMPLETYPE_BYTES_RECEIVED(202), KPISAMPLETYPE_BYTES_RECEIVED(202),
/**
* <code>KPISAMPLETYPE_BYTES_DROPPED = 203;</code>
*/
KPISAMPLETYPE_BYTES_DROPPED(203),
/**
* <pre>
*. can be used by both optical and L3 without any issue
* </pre>
*
* <code>KPISAMPLETYPE_ML_CONFIDENCE = 401;</code>
*/
KPISAMPLETYPE_ML_CONFIDENCE(401),
/**
* <pre>
*. can be used by both optical and L3 without any issue
* </pre>
*
* <code>KPISAMPLETYPE_OPTICAL_SECURITY_STATUS = 501;</code>
*/
KPISAMPLETYPE_OPTICAL_SECURITY_STATUS(501),
/**
* <code>KPISAMPLETYPE_L3_UNIQUE_ATTACK_CONNS = 601;</code>
*/
KPISAMPLETYPE_L3_UNIQUE_ATTACK_CONNS(601),
/**
* <code>KPISAMPLETYPE_L3_TOTAL_DROPPED_PACKTS = 602;</code>
*/
KPISAMPLETYPE_L3_TOTAL_DROPPED_PACKTS(602),
/**
* <code>KPISAMPLETYPE_L3_UNIQUE_ATTACKERS = 603;</code>
*/
KPISAMPLETYPE_L3_UNIQUE_ATTACKERS(603),
/**
* <code>KPISAMPLETYPE_L3_UNIQUE_COMPROMISED_CLIENTS = 604;</code>
*/
KPISAMPLETYPE_L3_UNIQUE_COMPROMISED_CLIENTS(604),
/**
* <code>KPISAMPLETYPE_L3_SECURITY_STATUS_CRYPTO = 605;</code>
*/
KPISAMPLETYPE_L3_SECURITY_STATUS_CRYPTO(605),
/**
* <code>KPISAMPLETYPE_SERVICE_LATENCY_MS = 701;</code>
*/
KPISAMPLETYPE_SERVICE_LATENCY_MS(701),
UNRECOGNIZED(-1), UNRECOGNIZED(-1),
; ;
...@@ -54,6 +102,10 @@ public final class KpiSampleTypes { ...@@ -54,6 +102,10 @@ public final class KpiSampleTypes {
* <code>KPISAMPLETYPE_PACKETS_RECEIVED = 102;</code> * <code>KPISAMPLETYPE_PACKETS_RECEIVED = 102;</code>
*/ */
public static final int KPISAMPLETYPE_PACKETS_RECEIVED_VALUE = 102; public static final int KPISAMPLETYPE_PACKETS_RECEIVED_VALUE = 102;
/**
* <code>KPISAMPLETYPE_PACKETS_DROPPED = 103;</code>
*/
public static final int KPISAMPLETYPE_PACKETS_DROPPED_VALUE = 103;
/** /**
* <code>KPISAMPLETYPE_BYTES_TRANSMITTED = 201;</code> * <code>KPISAMPLETYPE_BYTES_TRANSMITTED = 201;</code>
*/ */
...@@ -62,6 +114,50 @@ public final class KpiSampleTypes { ...@@ -62,6 +114,50 @@ public final class KpiSampleTypes {
* <code>KPISAMPLETYPE_BYTES_RECEIVED = 202;</code> * <code>KPISAMPLETYPE_BYTES_RECEIVED = 202;</code>
*/ */
public static final int KPISAMPLETYPE_BYTES_RECEIVED_VALUE = 202; public static final int KPISAMPLETYPE_BYTES_RECEIVED_VALUE = 202;
/**
* <code>KPISAMPLETYPE_BYTES_DROPPED = 203;</code>
*/
public static final int KPISAMPLETYPE_BYTES_DROPPED_VALUE = 203;
/**
* <pre>
*. can be used by both optical and L3 without any issue
* </pre>
*
* <code>KPISAMPLETYPE_ML_CONFIDENCE = 401;</code>
*/
public static final int KPISAMPLETYPE_ML_CONFIDENCE_VALUE = 401;
/**
* <pre>
*. can be used by both optical and L3 without any issue
* </pre>
*
* <code>KPISAMPLETYPE_OPTICAL_SECURITY_STATUS = 501;</code>
*/
public static final int KPISAMPLETYPE_OPTICAL_SECURITY_STATUS_VALUE = 501;
/**
* <code>KPISAMPLETYPE_L3_UNIQUE_ATTACK_CONNS = 601;</code>
*/
public static final int KPISAMPLETYPE_L3_UNIQUE_ATTACK_CONNS_VALUE = 601;
/**
* <code>KPISAMPLETYPE_L3_TOTAL_DROPPED_PACKTS = 602;</code>
*/
public static final int KPISAMPLETYPE_L3_TOTAL_DROPPED_PACKTS_VALUE = 602;
/**
* <code>KPISAMPLETYPE_L3_UNIQUE_ATTACKERS = 603;</code>
*/
public static final int KPISAMPLETYPE_L3_UNIQUE_ATTACKERS_VALUE = 603;
/**
* <code>KPISAMPLETYPE_L3_UNIQUE_COMPROMISED_CLIENTS = 604;</code>
*/
public static final int KPISAMPLETYPE_L3_UNIQUE_COMPROMISED_CLIENTS_VALUE = 604;
/**
* <code>KPISAMPLETYPE_L3_SECURITY_STATUS_CRYPTO = 605;</code>
*/
public static final int KPISAMPLETYPE_L3_SECURITY_STATUS_CRYPTO_VALUE = 605;
/**
* <code>KPISAMPLETYPE_SERVICE_LATENCY_MS = 701;</code>
*/
public static final int KPISAMPLETYPE_SERVICE_LATENCY_MS_VALUE = 701;
public final int getNumber() { public final int getNumber() {
...@@ -91,8 +187,18 @@ public final class KpiSampleTypes { ...@@ -91,8 +187,18 @@ public final class KpiSampleTypes {
case 0: return KPISAMPLETYPE_UNKNOWN; case 0: return KPISAMPLETYPE_UNKNOWN;
case 101: return KPISAMPLETYPE_PACKETS_TRANSMITTED; case 101: return KPISAMPLETYPE_PACKETS_TRANSMITTED;
case 102: return KPISAMPLETYPE_PACKETS_RECEIVED; case 102: return KPISAMPLETYPE_PACKETS_RECEIVED;
case 103: return KPISAMPLETYPE_PACKETS_DROPPED;
case 201: return KPISAMPLETYPE_BYTES_TRANSMITTED; case 201: return KPISAMPLETYPE_BYTES_TRANSMITTED;
case 202: return KPISAMPLETYPE_BYTES_RECEIVED; case 202: return KPISAMPLETYPE_BYTES_RECEIVED;
case 203: return KPISAMPLETYPE_BYTES_DROPPED;
case 401: return KPISAMPLETYPE_ML_CONFIDENCE;
case 501: return KPISAMPLETYPE_OPTICAL_SECURITY_STATUS;
case 601: return KPISAMPLETYPE_L3_UNIQUE_ATTACK_CONNS;
case 602: return KPISAMPLETYPE_L3_TOTAL_DROPPED_PACKTS;
case 603: return KPISAMPLETYPE_L3_UNIQUE_ATTACKERS;
case 604: return KPISAMPLETYPE_L3_UNIQUE_COMPROMISED_CLIENTS;
case 605: return KPISAMPLETYPE_L3_SECURITY_STATUS_CRYPTO;
case 701: return KPISAMPLETYPE_SERVICE_LATENCY_MS;
default: return null; default: return null;
} }
} }
...@@ -159,12 +265,22 @@ public final class KpiSampleTypes { ...@@ -159,12 +265,22 @@ public final class KpiSampleTypes {
static { static {
java.lang.String[] descriptorData = { java.lang.String[] descriptorData = {
"\n\026kpi_sample_types.proto\022\020kpi_sample_typ" + "\n\026kpi_sample_types.proto\022\020kpi_sample_typ" +
"es*\276\001\n\rKpiSampleType\022\031\n\025KPISAMPLETYPE_UN" + "es*\327\004\n\rKpiSampleType\022\031\n\025KPISAMPLETYPE_UN" +
"KNOWN\020\000\022%\n!KPISAMPLETYPE_PACKETS_TRANSMI" + "KNOWN\020\000\022%\n!KPISAMPLETYPE_PACKETS_TRANSMI" +
"TTED\020e\022\"\n\036KPISAMPLETYPE_PACKETS_RECEIVED" + "TTED\020e\022\"\n\036KPISAMPLETYPE_PACKETS_RECEIVED" +
"\020f\022$\n\037KPISAMPLETYPE_BYTES_TRANSMITTED\020\311\001" + "\020f\022!\n\035KPISAMPLETYPE_PACKETS_DROPPED\020g\022$\n" +
"\022!\n\034KPISAMPLETYPE_BYTES_RECEIVED\020\312\001b\006pro" + "\037KPISAMPLETYPE_BYTES_TRANSMITTED\020\311\001\022!\n\034K" +
"to3" "PISAMPLETYPE_BYTES_RECEIVED\020\312\001\022 \n\033KPISAM" +
"PLETYPE_BYTES_DROPPED\020\313\001\022 \n\033KPISAMPLETYP" +
"E_ML_CONFIDENCE\020\221\003\022*\n%KPISAMPLETYPE_OPTI" +
"CAL_SECURITY_STATUS\020\365\003\022)\n$KPISAMPLETYPE_" +
"L3_UNIQUE_ATTACK_CONNS\020\331\004\022*\n%KPISAMPLETY" +
"PE_L3_TOTAL_DROPPED_PACKTS\020\332\004\022&\n!KPISAMP" +
"LETYPE_L3_UNIQUE_ATTACKERS\020\333\004\0220\n+KPISAMP" +
"LETYPE_L3_UNIQUE_COMPROMISED_CLIENTS\020\334\004\022" +
",\n\'KPISAMPLETYPE_L3_SECURITY_STATUS_CRYP" +
"TO\020\335\004\022%\n KPISAMPLETYPE_SERVICE_LATENCY_M" +
"S\020\275\005b\006proto3"
}; };
descriptor = com.google.protobuf.Descriptors.FileDescriptor descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData, .internalBuildGeneratedFileFrom(descriptorData,
......
...@@ -20,7 +20,7 @@ public interface MonitoringService extends MutinyService { ...@@ -20,7 +20,7 @@ public interface MonitoringService extends MutinyService {
io.smallrye.mutiny.Uni<context.ContextOuterClass.Empty> monitorKpi(monitoring.Monitoring.MonitorKpiRequest request); io.smallrye.mutiny.Uni<context.ContextOuterClass.Empty> monitorKpi(monitoring.Monitoring.MonitorKpiRequest request);
io.smallrye.mutiny.Uni<monitoring.Monitoring.KpiList> queryKpiData(monitoring.Monitoring.KpiQuery request); io.smallrye.mutiny.Uni<monitoring.Monitoring.RawKpiTable> queryKpiData(monitoring.Monitoring.KpiQuery request);
io.smallrye.mutiny.Uni<monitoring.Monitoring.SubsDescriptor> getSubsDescriptor(monitoring.Monitoring.SubscriptionID request); io.smallrye.mutiny.Uni<monitoring.Monitoring.SubsDescriptor> getSubsDescriptor(monitoring.Monitoring.SubscriptionID request);
......
...@@ -64,7 +64,7 @@ public class MonitoringServiceBean extends MutinyMonitoringServiceGrpc.Monitorin ...@@ -64,7 +64,7 @@ public class MonitoringServiceBean extends MutinyMonitoringServiceGrpc.Monitorin
} }
} }
@Override @Override
public io.smallrye.mutiny.Uni<monitoring.Monitoring.KpiList> queryKpiData(monitoring.Monitoring.KpiQuery request) { public io.smallrye.mutiny.Uni<monitoring.Monitoring.RawKpiTable> queryKpiData(monitoring.Monitoring.KpiQuery request) {
try { try {
return delegate.queryKpiData(request); return delegate.queryKpiData(request);
} catch (UnsupportedOperationException e) { } catch (UnsupportedOperationException e) {
......
...@@ -45,7 +45,7 @@ public class MonitoringServiceClient implements MonitoringService, MutinyClient< ...@@ -45,7 +45,7 @@ public class MonitoringServiceClient implements MonitoringService, MutinyClient<
return stub.monitorKpi(request); return stub.monitorKpi(request);
} }
@Override @Override
public io.smallrye.mutiny.Uni<monitoring.Monitoring.KpiList> queryKpiData(monitoring.Monitoring.KpiQuery request) { public io.smallrye.mutiny.Uni<monitoring.Monitoring.RawKpiTable> queryKpiData(monitoring.Monitoring.KpiQuery request) {
return stub.queryKpiData(request); return stub.queryKpiData(request);
} }
@Override @Override
......
...@@ -66,7 +66,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim ...@@ -66,7 +66,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim
} }
public io.smallrye.mutiny.Uni<monitoring.Monitoring.KpiList> queryKpiData(monitoring.Monitoring.KpiQuery request) { public io.smallrye.mutiny.Uni<monitoring.Monitoring.RawKpiTable> queryKpiData(monitoring.Monitoring.KpiQuery request) {
return io.quarkus.grpc.runtime.ClientCalls.oneToOne(request, delegateStub::queryKpiData); return io.quarkus.grpc.runtime.ClientCalls.oneToOne(request, delegateStub::queryKpiData);
} }
...@@ -173,7 +173,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim ...@@ -173,7 +173,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim
} }
public io.smallrye.mutiny.Uni<monitoring.Monitoring.KpiList> queryKpiData(monitoring.Monitoring.KpiQuery request) { public io.smallrye.mutiny.Uni<monitoring.Monitoring.RawKpiTable> queryKpiData(monitoring.Monitoring.KpiQuery request) {
throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED); throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);
} }
...@@ -281,7 +281,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim ...@@ -281,7 +281,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim
asyncUnaryCall( asyncUnaryCall(
new MethodHandlers< new MethodHandlers<
monitoring.Monitoring.KpiQuery, monitoring.Monitoring.KpiQuery,
monitoring.Monitoring.KpiList>( monitoring.Monitoring.RawKpiTable>(
this, METHODID_QUERY_KPI_DATA, compression))) this, METHODID_QUERY_KPI_DATA, compression)))
.addMethod( .addMethod(
monitoring.MonitoringServiceGrpc.getSetKpiSubscriptionMethod(), monitoring.MonitoringServiceGrpc.getSetKpiSubscriptionMethod(),
...@@ -440,7 +440,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim ...@@ -440,7 +440,7 @@ public final class MutinyMonitoringServiceGrpc implements io.quarkus.grpc.runtim
break; break;
case METHODID_QUERY_KPI_DATA: case METHODID_QUERY_KPI_DATA:
io.quarkus.grpc.runtime.ServerCalls.oneToOne((monitoring.Monitoring.KpiQuery) request, io.quarkus.grpc.runtime.ServerCalls.oneToOne((monitoring.Monitoring.KpiQuery) request,
(io.grpc.stub.StreamObserver<monitoring.Monitoring.KpiList>) responseObserver, (io.grpc.stub.StreamObserver<monitoring.Monitoring.RawKpiTable>) responseObserver,
compression, compression,
serviceImpl::queryKpiData); serviceImpl::queryKpiData);
break; break;
......
This diff is collapsed.
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment