Skip to content
Show whitespace changes
Inline Side-by-side
src/ztp/target/generated-sources/grpc/device/DeviceServiceGrpc.java
View file @ a324e412
......@@ -4,7 +4,8 @@ import static io.grpc.MethodDescriptor.generateFullMethodName;
/**
*/
@io.quarkus.grpc.common.Generated(value = "by gRPC proto compiler (version 1.38.1)", comments = "Source: device.proto")
@io.quarkus.grpc.common.Generated(value = "by gRPC proto compiler (version 1.55.1)", comments = "Source: device.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class DeviceServiceGrpc {
private DeviceServiceGrpc() {
......@@ -132,45 +133,52 @@ public final class DeviceServiceGrpc {
/**
*/
public static abstract class DeviceServiceImplBase implements io.grpc.BindableService {
public interface AsyncService {
/**
*/
public void addDevice(context.ContextOuterClass.Device request, io.grpc.stub.StreamObserver<context.ContextOuterClass.DeviceId> responseObserver) {
default void addDevice(context.ContextOuterClass.Device request, io.grpc.stub.StreamObserver<context.ContextOuterClass.DeviceId> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getAddDeviceMethod(), responseObserver);
}
/**
*/
public void configureDevice(context.ContextOuterClass.Device request, io.grpc.stub.StreamObserver<context.ContextOuterClass.DeviceId> responseObserver) {
default void configureDevice(context.ContextOuterClass.Device request, io.grpc.stub.StreamObserver<context.ContextOuterClass.DeviceId> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getConfigureDeviceMethod(), responseObserver);
}
/**
*/
public void deleteDevice(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
default void deleteDevice(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteDeviceMethod(), responseObserver);
}
/**
*/
public void getInitialConfig(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver<context.ContextOuterClass.DeviceConfig> responseObserver) {
default void getInitialConfig(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver<context.ContextOuterClass.DeviceConfig> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetInitialConfigMethod(), responseObserver);
}
/**
*/
public void monitorDeviceKpi(device.Device.MonitoringSettings request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
default void monitorDeviceKpi(device.Device.MonitoringSettings request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getMonitorDeviceKpiMethod(), responseObserver);
}
}
/**
* Base class for the server implementation of the service DeviceService.
*/
public static abstract class DeviceServiceImplBase implements io.grpc.BindableService, AsyncService {
@java.lang.Override
public io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()).addMethod(getAddDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Device, context.ContextOuterClass.DeviceId>(this, METHODID_ADD_DEVICE))).addMethod(getConfigureDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Device, context.ContextOuterClass.DeviceId>(this, METHODID_CONFIGURE_DEVICE))).addMethod(getDeleteDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.DeviceId, context.ContextOuterClass.Empty>(this, METHODID_DELETE_DEVICE))).addMethod(getGetInitialConfigMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.DeviceId, context.ContextOuterClass.DeviceConfig>(this, METHODID_GET_INITIAL_CONFIG))).addMethod(getMonitorDeviceKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<device.Device.MonitoringSettings, context.ContextOuterClass.Empty>(this, METHODID_MONITOR_DEVICE_KPI))).build();
return DeviceServiceGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service DeviceService.
*/
public static class DeviceServiceStub extends io.grpc.stub.AbstractAsyncStub<DeviceServiceStub> {
......@@ -215,6 +223,7 @@ public final class DeviceServiceGrpc {
}
/**
* A stub to allow clients to do synchronous rpc calls to service DeviceService.
*/
public static class DeviceServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub<DeviceServiceBlockingStub> {
......@@ -259,6 +268,7 @@ public final class DeviceServiceGrpc {
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service DeviceService.
*/
public static class DeviceServiceFutureStub extends io.grpc.stub.AbstractFutureStub<DeviceServiceFutureStub> {
......@@ -314,11 +324,11 @@ public final class DeviceServiceGrpc {
private static final class MethodHandlers<Req, Resp> implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
private final DeviceServiceImplBase serviceImpl;
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(DeviceServiceImplBase serviceImpl, int methodId) {
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
......@@ -357,6 +367,10 @@ public final class DeviceServiceGrpc {
}
}
public static io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()).addMethod(getAddDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Device, context.ContextOuterClass.DeviceId>(service, METHODID_ADD_DEVICE))).addMethod(getConfigureDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Device, context.ContextOuterClass.DeviceId>(service, METHODID_CONFIGURE_DEVICE))).addMethod(getDeleteDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.DeviceId, context.ContextOuterClass.Empty>(service, METHODID_DELETE_DEVICE))).addMethod(getGetInitialConfigMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.DeviceId, context.ContextOuterClass.DeviceConfig>(service, METHODID_GET_INITIAL_CONFIG))).addMethod(getMonitorDeviceKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<device.Device.MonitoringSettings, context.ContextOuterClass.Empty>(service, METHODID_MONITOR_DEVICE_KPI))).build();
}
private static abstract class DeviceServiceBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
DeviceServiceBaseDescriptorSupplier() {
......
src/ztp/target/generated-sources/grpc/kpi_sample_types/KpiSampleTypes.java
View file @ a324e412
......@@ -95,6 +95,38 @@ public final class KpiSampleTypes {
* <code>KPISAMPLETYPE_SERVICE_LATENCY_MS = 701;</code>
*/
KPISAMPLETYPE_SERVICE_LATENCY_MS(701),
/**
* <pre>
* output KPIs
* </pre>
*
* <code>KPISAMPLETYPE_PACKETS_TRANSMITTED_AGG_OUTPUT = 1101;</code>
*/
KPISAMPLETYPE_PACKETS_TRANSMITTED_AGG_OUTPUT(1101),
/**
* <code>KPISAMPLETYPE_PACKETS_RECEIVED_AGG_OUTPUT = 1102;</code>
*/
KPISAMPLETYPE_PACKETS_RECEIVED_AGG_OUTPUT(1102),
/**
* <code>KPISAMPLETYPE_PACKETS_DROPPED_AGG_OUTPUT = 1103;</code>
*/
KPISAMPLETYPE_PACKETS_DROPPED_AGG_OUTPUT(1103),
/**
* <code>KPISAMPLETYPE_BYTES_TRANSMITTED_AGG_OUTPUT = 1201;</code>
*/
KPISAMPLETYPE_BYTES_TRANSMITTED_AGG_OUTPUT(1201),
/**
* <code>KPISAMPLETYPE_BYTES_RECEIVED_AGG_OUTPUT = 1202;</code>
*/
KPISAMPLETYPE_BYTES_RECEIVED_AGG_OUTPUT(1202),
/**
* <code>KPISAMPLETYPE_BYTES_DROPPED_AGG_OUTPUT = 1203;</code>
*/
KPISAMPLETYPE_BYTES_DROPPED_AGG_OUTPUT(1203),
/**
* <code>KPISAMPLETYPE_SERVICE_LATENCY_MS_AGG_OUTPUT = 1701;</code>
*/
KPISAMPLETYPE_SERVICE_LATENCY_MS_AGG_OUTPUT(1701),
UNRECOGNIZED(-1);
/**
......@@ -190,6 +222,45 @@ public final class KpiSampleTypes {
*/
public static final int KPISAMPLETYPE_SERVICE_LATENCY_MS_VALUE = 701;
/**
* <pre>
* output KPIs
* </pre>
*
* <code>KPISAMPLETYPE_PACKETS_TRANSMITTED_AGG_OUTPUT = 1101;</code>
*/
public static final int KPISAMPLETYPE_PACKETS_TRANSMITTED_AGG_OUTPUT_VALUE = 1101;
/**
* <code>KPISAMPLETYPE_PACKETS_RECEIVED_AGG_OUTPUT = 1102;</code>
*/
public static final int KPISAMPLETYPE_PACKETS_RECEIVED_AGG_OUTPUT_VALUE = 1102;
/**
* <code>KPISAMPLETYPE_PACKETS_DROPPED_AGG_OUTPUT = 1103;</code>
*/
public static final int KPISAMPLETYPE_PACKETS_DROPPED_AGG_OUTPUT_VALUE = 1103;
/**
* <code>KPISAMPLETYPE_BYTES_TRANSMITTED_AGG_OUTPUT = 1201;</code>
*/
public static final int KPISAMPLETYPE_BYTES_TRANSMITTED_AGG_OUTPUT_VALUE = 1201;
/**
* <code>KPISAMPLETYPE_BYTES_RECEIVED_AGG_OUTPUT = 1202;</code>
*/
public static final int KPISAMPLETYPE_BYTES_RECEIVED_AGG_OUTPUT_VALUE = 1202;
/**
* <code>KPISAMPLETYPE_BYTES_DROPPED_AGG_OUTPUT = 1203;</code>
*/
public static final int KPISAMPLETYPE_BYTES_DROPPED_AGG_OUTPUT_VALUE = 1203;
/**
* <code>KPISAMPLETYPE_SERVICE_LATENCY_MS_AGG_OUTPUT = 1701;</code>
*/
public static final int KPISAMPLETYPE_SERVICE_LATENCY_MS_AGG_OUTPUT_VALUE = 1701;
public final int getNumber() {
if (this == UNRECOGNIZED) {
throw new java.lang.IllegalArgumentException("Can't get the number of an unknown enum value.");
......@@ -247,6 +318,20 @@ public final class KpiSampleTypes {
return KPISAMPLETYPE_L3_SECURITY_STATUS_CRYPTO;
case 701:
return KPISAMPLETYPE_SERVICE_LATENCY_MS;
case 1101:
return KPISAMPLETYPE_PACKETS_TRANSMITTED_AGG_OUTPUT;
case 1102:
return KPISAMPLETYPE_PACKETS_RECEIVED_AGG_OUTPUT;
case 1103:
return KPISAMPLETYPE_PACKETS_DROPPED_AGG_OUTPUT;
case 1201:
return KPISAMPLETYPE_BYTES_TRANSMITTED_AGG_OUTPUT;
case 1202:
return KPISAMPLETYPE_BYTES_RECEIVED_AGG_OUTPUT;
case 1203:
return KPISAMPLETYPE_BYTES_DROPPED_AGG_OUTPUT;
case 1701:
return KPISAMPLETYPE_SERVICE_LATENCY_MS_AGG_OUTPUT;
default:
return null;
}
......@@ -304,7 +389,7 @@ public final class KpiSampleTypes {
private static com.google.protobuf.Descriptors.FileDescriptor descriptor;
static {
java.lang.String[] descriptorData = { "\n\026kpi_sample_types.proto\022\020kpi_sample_typ" + "es*\260\005\n\rKpiSampleType\022\031\n\025KPISAMPLETYPE_UN" + "KNOWN\020\000\022%\n!KPISAMPLETYPE_PACKETS_TRANSMI" + "TTED\020e\022\"\n\036KPISAMPLETYPE_PACKETS_RECEIVED" + "\020f\022!\n\035KPISAMPLETYPE_PACKETS_DROPPED\020g\022$\n" + "\037KPISAMPLETYPE_BYTES_TRANSMITTED\020\311\001\022!\n\034K" + "PISAMPLETYPE_BYTES_RECEIVED\020\312\001\022 \n\033KPISAM" + "PLETYPE_BYTES_DROPPED\020\313\001\022+\n&KPISAMPLETYP" + "E_LINK_TOTAL_CAPACITY_GBPS\020\255\002\022*\n%KPISAMP" + "LETYPE_LINK_USED_CAPACITY_GBPS\020\256\002\022 \n\033KPI" + "SAMPLETYPE_ML_CONFIDENCE\020\221\003\022*\n%KPISAMPLE" + "TYPE_OPTICAL_SECURITY_STATUS\020\365\003\022)\n$KPISA" + "MPLETYPE_L3_UNIQUE_ATTACK_CONNS\020\331\004\022*\n%KP" + "ISAMPLETYPE_L3_TOTAL_DROPPED_PACKTS\020\332\004\022&" + "\n!KPISAMPLETYPE_L3_UNIQUE_ATTACKERS\020\333\004\0220" + "\n+KPISAMPLETYPE_L3_UNIQUE_COMPROMISED_CL" + "IENTS\020\334\004\022,\n\'KPISAMPLETYPE_L3_SECURITY_ST" + "ATUS_CRYPTO\020\335\004\022%\n KPISAMPLETYPE_SERVICE_" + "LATENCY_MS\020\275\005b\006proto3" };
java.lang.String[] descriptorData = { "\n\026kpi_sample_types.proto\022\020kpi_sample_typ" + "es*\200\010\n\rKpiSampleType\022\031\n\025KPISAMPLETYPE_UN" + "KNOWN\020\000\022%\n!KPISAMPLETYPE_PACKETS_TRANSMI" + "TTED\020e\022\"\n\036KPISAMPLETYPE_PACKETS_RECEIVED" + "\020f\022!\n\035KPISAMPLETYPE_PACKETS_DROPPED\020g\022$\n" + "\037KPISAMPLETYPE_BYTES_TRANSMITTED\020\311\001\022!\n\034K" + "PISAMPLETYPE_BYTES_RECEIVED\020\312\001\022 \n\033KPISAM" + "PLETYPE_BYTES_DROPPED\020\313\001\022+\n&KPISAMPLETYP" + "E_LINK_TOTAL_CAPACITY_GBPS\020\255\002\022*\n%KPISAMP" + "LETYPE_LINK_USED_CAPACITY_GBPS\020\256\002\022 \n\033KPI" + "SAMPLETYPE_ML_CONFIDENCE\020\221\003\022*\n%KPISAMPLE" + "TYPE_OPTICAL_SECURITY_STATUS\020\365\003\022)\n$KPISA" + "MPLETYPE_L3_UNIQUE_ATTACK_CONNS\020\331\004\022*\n%KP" + "ISAMPLETYPE_L3_TOTAL_DROPPED_PACKTS\020\332\004\022&" + "\n!KPISAMPLETYPE_L3_UNIQUE_ATTACKERS\020\333\004\0220" + "\n+KPISAMPLETYPE_L3_UNIQUE_COMPROMISED_CL" + "IENTS\020\334\004\022,\n\'KPISAMPLETYPE_L3_SECURITY_ST" + "ATUS_CRYPTO\020\335\004\022%\n KPISAMPLETYPE_SERVICE_" + "LATENCY_MS\020\275\005\0221\n,KPISAMPLETYPE_PACKETS_T" + "RANSMITTED_AGG_OUTPUT\020\315\010\022.\n)KPISAMPLETYP" + "E_PACKETS_RECEIVED_AGG_OUTPUT\020\316\010\022-\n(KPIS" + "AMPLETYPE_PACKETS_DROPPED_AGG_OUTPUT\020\317\010\022" + "/\n*KPISAMPLETYPE_BYTES_TRANSMITTED_AGG_O" + "UTPUT\020\261\t\022,\n\'KPISAMPLETYPE_BYTES_RECEIVED" + "_AGG_OUTPUT\020\262\t\022+\n&KPISAMPLETYPE_BYTES_DR" + "OPPED_AGG_OUTPUT\020\263\t\0220\n+KPISAMPLETYPE_SER" + "VICE_LATENCY_MS_AGG_OUTPUT\020\245\rb\006proto3" };
descriptor = com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(descriptorData, new com.google.protobuf.Descriptors.FileDescriptor[] {});
}
// @@protoc_insertion_point(outer_class_scope)
......
src/ztp/target/generated-sources/grpc/monitoring/Monitoring.java
View file @ a324e412
Source diff could not be displayed: it is too large. Options to address this: view the blob.
src/ztp/target/generated-sources/grpc/monitoring/MonitoringServiceGrpc.java
View file @ a324e412
......@@ -4,7 +4,8 @@ import static io.grpc.MethodDescriptor.generateFullMethodName;
/**
*/
@io.quarkus.grpc.common.Generated(value = "by gRPC proto compiler (version 1.38.1)", comments = "Source: monitoring.proto")
@io.quarkus.grpc.common.Generated(value = "by gRPC proto compiler (version 1.55.1)", comments = "Source: monitoring.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class MonitoringServiceGrpc {
private MonitoringServiceGrpc() {
......@@ -327,123 +328,130 @@ public final class MonitoringServiceGrpc {
/**
*/
public static abstract class MonitoringServiceImplBase implements io.grpc.BindableService {
public interface AsyncService {
/**
*/
public void setKpi(monitoring.Monitoring.KpiDescriptor request, io.grpc.stub.StreamObserver<monitoring.Monitoring.KpiId> responseObserver) {
default void setKpi(monitoring.Monitoring.KpiDescriptor request, io.grpc.stub.StreamObserver<monitoring.Monitoring.KpiId> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetKpiMethod(), responseObserver);
}
/**
*/
public void deleteKpi(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
default void deleteKpi(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteKpiMethod(), responseObserver);
}
/**
*/
public void getKpiDescriptor(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<monitoring.Monitoring.KpiDescriptor> responseObserver) {
default void getKpiDescriptor(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<monitoring.Monitoring.KpiDescriptor> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetKpiDescriptorMethod(), responseObserver);
}
/**
*/
public void getKpiDescriptorList(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<monitoring.Monitoring.KpiDescriptorList> responseObserver) {
default void getKpiDescriptorList(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<monitoring.Monitoring.KpiDescriptorList> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetKpiDescriptorListMethod(), responseObserver);
}
/**
*/
public void includeKpi(monitoring.Monitoring.Kpi request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
default void includeKpi(monitoring.Monitoring.Kpi request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getIncludeKpiMethod(), responseObserver);
}
/**
*/
public void monitorKpi(monitoring.Monitoring.MonitorKpiRequest request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
default void monitorKpi(monitoring.Monitoring.MonitorKpiRequest request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getMonitorKpiMethod(), responseObserver);
}
/**
*/
public void queryKpiData(monitoring.Monitoring.KpiQuery request, io.grpc.stub.StreamObserver<monitoring.Monitoring.RawKpiTable> responseObserver) {
default void queryKpiData(monitoring.Monitoring.KpiQuery request, io.grpc.stub.StreamObserver<monitoring.Monitoring.RawKpiTable> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getQueryKpiDataMethod(), responseObserver);
}
/**
*/
public void setKpiSubscription(monitoring.Monitoring.SubsDescriptor request, io.grpc.stub.StreamObserver<monitoring.Monitoring.SubsResponse> responseObserver) {
default void setKpiSubscription(monitoring.Monitoring.SubsDescriptor request, io.grpc.stub.StreamObserver<monitoring.Monitoring.SubsResponse> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetKpiSubscriptionMethod(), responseObserver);
}
/**
*/
public void getSubsDescriptor(monitoring.Monitoring.SubscriptionID request, io.grpc.stub.StreamObserver<monitoring.Monitoring.SubsDescriptor> responseObserver) {
default void getSubsDescriptor(monitoring.Monitoring.SubscriptionID request, io.grpc.stub.StreamObserver<monitoring.Monitoring.SubsDescriptor> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSubsDescriptorMethod(), responseObserver);
}
/**
*/
public void getSubscriptions(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<monitoring.Monitoring.SubsList> responseObserver) {
default void getSubscriptions(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<monitoring.Monitoring.SubsList> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSubscriptionsMethod(), responseObserver);
}
/**
*/
public void deleteSubscription(monitoring.Monitoring.SubscriptionID request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
default void deleteSubscription(monitoring.Monitoring.SubscriptionID request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteSubscriptionMethod(), responseObserver);
}
/**
*/
public void setKpiAlarm(monitoring.Monitoring.AlarmDescriptor request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmID> responseObserver) {
default void setKpiAlarm(monitoring.Monitoring.AlarmDescriptor request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmID> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetKpiAlarmMethod(), responseObserver);
}
/**
*/
public void getAlarms(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmList> responseObserver) {
default void getAlarms(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmList> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetAlarmsMethod(), responseObserver);
}
/**
*/
public void getAlarmDescriptor(monitoring.Monitoring.AlarmID request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmDescriptor> responseObserver) {
default void getAlarmDescriptor(monitoring.Monitoring.AlarmID request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmDescriptor> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetAlarmDescriptorMethod(), responseObserver);
}
/**
*/
public void getAlarmResponseStream(monitoring.Monitoring.AlarmSubscription request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmResponse> responseObserver) {
default void getAlarmResponseStream(monitoring.Monitoring.AlarmSubscription request, io.grpc.stub.StreamObserver<monitoring.Monitoring.AlarmResponse> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetAlarmResponseStreamMethod(), responseObserver);
}
/**
*/
public void deleteAlarm(monitoring.Monitoring.AlarmID request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
default void deleteAlarm(monitoring.Monitoring.AlarmID request, io.grpc.stub.StreamObserver<context.ContextOuterClass.Empty> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteAlarmMethod(), responseObserver);
}
/**
*/
public void getStreamKpi(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<monitoring.Monitoring.Kpi> responseObserver) {
default void getStreamKpi(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<monitoring.Monitoring.Kpi> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetStreamKpiMethod(), responseObserver);
}
/**
*/
public void getInstantKpi(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<monitoring.Monitoring.Kpi> responseObserver) {
default void getInstantKpi(monitoring.Monitoring.KpiId request, io.grpc.stub.StreamObserver<monitoring.Monitoring.Kpi> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetInstantKpiMethod(), responseObserver);
}
}
/**
* Base class for the server implementation of the service MonitoringService.
*/
public static abstract class MonitoringServiceImplBase implements io.grpc.BindableService, AsyncService {
@java.lang.Override
public io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()).addMethod(getSetKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiDescriptor, monitoring.Monitoring.KpiId>(this, METHODID_SET_KPI))).addMethod(getDeleteKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiId, context.ContextOuterClass.Empty>(this, METHODID_DELETE_KPI))).addMethod(getGetKpiDescriptorMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiId, monitoring.Monitoring.KpiDescriptor>(this, METHODID_GET_KPI_DESCRIPTOR))).addMethod(getGetKpiDescriptorListMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, monitoring.Monitoring.KpiDescriptorList>(this, METHODID_GET_KPI_DESCRIPTOR_LIST))).addMethod(getIncludeKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.Kpi, context.ContextOuterClass.Empty>(this, METHODID_INCLUDE_KPI))).addMethod(getMonitorKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.MonitorKpiRequest, context.ContextOuterClass.Empty>(this, METHODID_MONITOR_KPI))).addMethod(getQueryKpiDataMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiQuery, monitoring.Monitoring.RawKpiTable>(this, METHODID_QUERY_KPI_DATA))).addMethod(getSetKpiSubscriptionMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall(new MethodHandlers<monitoring.Monitoring.SubsDescriptor, monitoring.Monitoring.SubsResponse>(this, METHODID_SET_KPI_SUBSCRIPTION))).addMethod(getGetSubsDescriptorMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.SubscriptionID, monitoring.Monitoring.SubsDescriptor>(this, METHODID_GET_SUBS_DESCRIPTOR))).addMethod(getGetSubscriptionsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, monitoring.Monitoring.SubsList>(this, METHODID_GET_SUBSCRIPTIONS))).addMethod(getDeleteSubscriptionMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.SubscriptionID, context.ContextOuterClass.Empty>(this, METHODID_DELETE_SUBSCRIPTION))).addMethod(getSetKpiAlarmMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.AlarmDescriptor, monitoring.Monitoring.AlarmID>(this, METHODID_SET_KPI_ALARM))).addMethod(getGetAlarmsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, monitoring.Monitoring.AlarmList>(this, METHODID_GET_ALARMS))).addMethod(getGetAlarmDescriptorMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.AlarmID, monitoring.Monitoring.AlarmDescriptor>(this, METHODID_GET_ALARM_DESCRIPTOR))).addMethod(getGetAlarmResponseStreamMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall(new MethodHandlers<monitoring.Monitoring.AlarmSubscription, monitoring.Monitoring.AlarmResponse>(this, METHODID_GET_ALARM_RESPONSE_STREAM))).addMethod(getDeleteAlarmMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.AlarmID, context.ContextOuterClass.Empty>(this, METHODID_DELETE_ALARM))).addMethod(getGetStreamKpiMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall(new MethodHandlers<monitoring.Monitoring.KpiId, monitoring.Monitoring.Kpi>(this, METHODID_GET_STREAM_KPI))).addMethod(getGetInstantKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiId, monitoring.Monitoring.Kpi>(this, METHODID_GET_INSTANT_KPI))).build();
return MonitoringServiceGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service MonitoringService.
*/
public static class MonitoringServiceStub extends io.grpc.stub.AbstractAsyncStub<MonitoringServiceStub> {
......@@ -566,6 +574,7 @@ public final class MonitoringServiceGrpc {
}
/**
* A stub to allow clients to do synchronous rpc calls to service MonitoringService.
*/
public static class MonitoringServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub<MonitoringServiceBlockingStub> {
......@@ -688,6 +697,7 @@ public final class MonitoringServiceGrpc {
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service MonitoringService.
*/
public static class MonitoringServiceFutureStub extends io.grpc.stub.AbstractFutureStub<MonitoringServiceFutureStub> {
......@@ -829,11 +839,11 @@ public final class MonitoringServiceGrpc {
private static final class MethodHandlers<Req, Resp> implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
private final MonitoringServiceImplBase serviceImpl;
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(MonitoringServiceImplBase serviceImpl, int methodId) {
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
......@@ -911,6 +921,10 @@ public final class MonitoringServiceGrpc {
}
}
public static io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()).addMethod(getSetKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiDescriptor, monitoring.Monitoring.KpiId>(service, METHODID_SET_KPI))).addMethod(getDeleteKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiId, context.ContextOuterClass.Empty>(service, METHODID_DELETE_KPI))).addMethod(getGetKpiDescriptorMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiId, monitoring.Monitoring.KpiDescriptor>(service, METHODID_GET_KPI_DESCRIPTOR))).addMethod(getGetKpiDescriptorListMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, monitoring.Monitoring.KpiDescriptorList>(service, METHODID_GET_KPI_DESCRIPTOR_LIST))).addMethod(getIncludeKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.Kpi, context.ContextOuterClass.Empty>(service, METHODID_INCLUDE_KPI))).addMethod(getMonitorKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.MonitorKpiRequest, context.ContextOuterClass.Empty>(service, METHODID_MONITOR_KPI))).addMethod(getQueryKpiDataMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiQuery, monitoring.Monitoring.RawKpiTable>(service, METHODID_QUERY_KPI_DATA))).addMethod(getSetKpiSubscriptionMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall(new MethodHandlers<monitoring.Monitoring.SubsDescriptor, monitoring.Monitoring.SubsResponse>(service, METHODID_SET_KPI_SUBSCRIPTION))).addMethod(getGetSubsDescriptorMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.SubscriptionID, monitoring.Monitoring.SubsDescriptor>(service, METHODID_GET_SUBS_DESCRIPTOR))).addMethod(getGetSubscriptionsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, monitoring.Monitoring.SubsList>(service, METHODID_GET_SUBSCRIPTIONS))).addMethod(getDeleteSubscriptionMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.SubscriptionID, context.ContextOuterClass.Empty>(service, METHODID_DELETE_SUBSCRIPTION))).addMethod(getSetKpiAlarmMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.AlarmDescriptor, monitoring.Monitoring.AlarmID>(service, METHODID_SET_KPI_ALARM))).addMethod(getGetAlarmsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, monitoring.Monitoring.AlarmList>(service, METHODID_GET_ALARMS))).addMethod(getGetAlarmDescriptorMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.AlarmID, monitoring.Monitoring.AlarmDescriptor>(service, METHODID_GET_ALARM_DESCRIPTOR))).addMethod(getGetAlarmResponseStreamMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall(new MethodHandlers<monitoring.Monitoring.AlarmSubscription, monitoring.Monitoring.AlarmResponse>(service, METHODID_GET_ALARM_RESPONSE_STREAM))).addMethod(getDeleteAlarmMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.AlarmID, context.ContextOuterClass.Empty>(service, METHODID_DELETE_ALARM))).addMethod(getGetStreamKpiMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall(new MethodHandlers<monitoring.Monitoring.KpiId, monitoring.Monitoring.Kpi>(service, METHODID_GET_STREAM_KPI))).addMethod(getGetInstantKpiMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<monitoring.Monitoring.KpiId, monitoring.Monitoring.Kpi>(service, METHODID_GET_INSTANT_KPI))).build();
}
private static abstract class MonitoringServiceBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
MonitoringServiceBaseDescriptorSupplier() {
......
src/ztp/target/generated-sources/grpc/ztp/Ztp.java
View file @ a324e412
......@@ -322,70 +322,6 @@ public final class Ztp {
return new DeviceRoleId();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
return this.unknownFields;
}
private DeviceRoleId(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
this();
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder();
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
context.ContextOuterClass.Uuid.Builder subBuilder = null;
if (devRoleId_ != null) {
subBuilder = devRoleId_.toBuilder();
}
devRoleId_ = input.readMessage(context.ContextOuterClass.Uuid.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(devRoleId_);
devRoleId_ = subBuilder.buildPartial();
}
break;
}
case 18:
{
context.ContextOuterClass.DeviceId.Builder subBuilder = null;
if (devId_ != null) {
subBuilder = devId_.toBuilder();
}
devId_ = input.readMessage(context.ContextOuterClass.DeviceId.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(devId_);
devId_ = subBuilder.buildPartial();
}
break;
}
default:
{
if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) {
done = true;
}
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(this);
} finally {
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
return ztp.Ztp.internal_static_ztp_DeviceRoleId_descriptor;
}
......@@ -422,7 +358,7 @@ public final class Ztp {
*/
@java.lang.Override
public context.ContextOuterClass.UuidOrBuilder getDevRoleIdOrBuilder() {
return getDevRoleId();
return devRoleId_ == null ? context.ContextOuterClass.Uuid.getDefaultInstance() : devRoleId_;
}
public static final int DEVID_FIELD_NUMBER = 2;
......@@ -452,7 +388,7 @@ public final class Ztp {
*/
@java.lang.Override
public context.ContextOuterClass.DeviceIdOrBuilder getDevIdOrBuilder() {
return getDevId();
return devId_ == null ? context.ContextOuterClass.DeviceId.getDefaultInstance() : devId_;
}
private byte memoizedIsInitialized = -1;
......@@ -476,7 +412,7 @@ public final class Ztp {
if (devId_ != null) {
output.writeMessage(2, getDevId());
}
unknownFields.writeTo(output);
getUnknownFields().writeTo(output);
}
@java.lang.Override
......@@ -491,7 +427,7 @@ public final class Ztp {
if (devId_ != null) {
size += com.google.protobuf.CodedOutputStream.computeMessageSize(2, getDevId());
}
size += unknownFields.getSerializedSize();
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
......@@ -517,7 +453,7 @@ public final class Ztp {
if (!getDevId().equals(other.getDevId()))
return false;
}
if (!unknownFields.equals(other.unknownFields))
if (!getUnknownFields().equals(other.getUnknownFields()))
return false;
return true;
}
......@@ -537,7 +473,7 @@ public final class Ztp {
hash = (37 * hash) + DEVID_FIELD_NUMBER;
hash = (53 * hash) + getDevId().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
......@@ -631,32 +567,24 @@ public final class Ztp {
// Construct using ztp.Ztp.DeviceRoleId.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
maybeForceBuilderInitialization();
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
}
}
@java.lang.Override
public Builder clear() {
super.clear();
if (devRoleIdBuilder_ == null) {
devRoleId_ = null;
} else {
bitField0_ = 0;
devRoleId_ = null;
if (devRoleIdBuilder_ != null) {
devRoleIdBuilder_.dispose();
devRoleIdBuilder_ = null;
}
if (devIdBuilder_ == null) {
devId_ = null;
} else {
devId_ = null;
if (devIdBuilder_ != null) {
devIdBuilder_.dispose();
devIdBuilder_ = null;
}
return this;
......@@ -684,48 +612,21 @@ public final class Ztp {
@java.lang.Override
public ztp.Ztp.DeviceRoleId buildPartial() {
ztp.Ztp.DeviceRoleId result = new ztp.Ztp.DeviceRoleId(this);
if (devRoleIdBuilder_ == null) {
result.devRoleId_ = devRoleId_;
} else {
result.devRoleId_ = devRoleIdBuilder_.build();
}
if (devIdBuilder_ == null) {
result.devId_ = devId_;
} else {
result.devId_ = devIdBuilder_.build();
if (bitField0_ != 0) {
buildPartial0(result);
}
onBuilt();
return result;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
private void buildPartial0(ztp.Ztp.DeviceRoleId result) {
int from_bitField0_ = bitField0_;
if (((from_bitField0_ & 0x00000001) != 0)) {
result.devRoleId_ = devRoleIdBuilder_ == null ? devRoleId_ : devRoleIdBuilder_.build();
}
@java.lang.Override
public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
if (((from_bitField0_ & 0x00000002) != 0)) {
result.devId_ = devIdBuilder_ == null ? devId_ : devIdBuilder_.build();
}
@java.lang.Override
public Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
}
@java.lang.Override
public Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
......@@ -747,7 +648,7 @@ public final class Ztp {
if (other.hasDevId()) {
mergeDevId(other.getDevId());
}
this.mergeUnknownFields(other.unknownFields);
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
......@@ -759,20 +660,54 @@ public final class Ztp {
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException {
ztp.Ztp.DeviceRoleId parsedMessage = null;
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
input.readMessage(getDevRoleIdFieldBuilder().getBuilder(), extensionRegistry);
bitField0_ |= 0x00000001;
break;
}
// case 10
case 18:
{
input.readMessage(getDevIdFieldBuilder().getBuilder(), extensionRegistry);
bitField0_ |= 0x00000002;
break;
}
// case 18
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
// was an endgroup tag
done = true;
}
break;
}
}
// switch (tag)
}
// while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (ztp.Ztp.DeviceRoleId) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
onChanged();
}
// finally
return this;
}
private int bitField0_;
private context.ContextOuterClass.Uuid devRoleId_;
private com.google.protobuf.SingleFieldBuilderV3<context.ContextOuterClass.Uuid, context.ContextOuterClass.Uuid.Builder, context.ContextOuterClass.UuidOrBuilder> devRoleIdBuilder_;
......@@ -782,7 +717,7 @@ public final class Ztp {
* @return Whether the devRoleId field is set.
*/
public boolean hasDevRoleId() {
return devRoleIdBuilder_ != null || devRoleId_ != null;
return ((bitField0_ & 0x00000001) != 0);
}
/**
......@@ -806,10 +741,11 @@ public final class Ztp {
throw new NullPointerException();
}
devRoleId_ = value;
onChanged();
} else {
devRoleIdBuilder_.setMessage(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -819,10 +755,11 @@ public final class Ztp {
public Builder setDevRoleId(context.ContextOuterClass.Uuid.Builder builderForValue) {
if (devRoleIdBuilder_ == null) {
devRoleId_ = builderForValue.build();
onChanged();
} else {
devRoleIdBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -831,15 +768,16 @@ public final class Ztp {
*/
public Builder mergeDevRoleId(context.ContextOuterClass.Uuid value) {
if (devRoleIdBuilder_ == null) {
if (devRoleId_ != null) {
devRoleId_ = context.ContextOuterClass.Uuid.newBuilder(devRoleId_).mergeFrom(value).buildPartial();
if (((bitField0_ & 0x00000001) != 0) && devRoleId_ != null && devRoleId_ != context.ContextOuterClass.Uuid.getDefaultInstance()) {
getDevRoleIdBuilder().mergeFrom(value);
} else {
devRoleId_ = value;
}
onChanged();
} else {
devRoleIdBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -847,13 +785,13 @@ public final class Ztp {
* <code>.context.Uuid devRoleId = 1;</code>
*/
public Builder clearDevRoleId() {
if (devRoleIdBuilder_ == null) {
devRoleId_ = null;
onChanged();
} else {
bitField0_ = (bitField0_ & ~0x00000001);
devRoleId_ = null;
if (devRoleIdBuilder_ != null) {
devRoleIdBuilder_.dispose();
devRoleIdBuilder_ = null;
}
onChanged();
return this;
}
......@@ -861,6 +799,7 @@ public final class Ztp {
* <code>.context.Uuid devRoleId = 1;</code>
*/
public context.ContextOuterClass.Uuid.Builder getDevRoleIdBuilder() {
bitField0_ |= 0x00000001;
onChanged();
return getDevRoleIdFieldBuilder().getBuilder();
}
......@@ -896,7 +835,7 @@ public final class Ztp {
* @return Whether the devId field is set.
*/
public boolean hasDevId() {
return devIdBuilder_ != null || devId_ != null;
return ((bitField0_ & 0x00000002) != 0);
}
/**
......@@ -920,10 +859,11 @@ public final class Ztp {
throw new NullPointerException();
}
devId_ = value;
onChanged();
} else {
devIdBuilder_.setMessage(value);
}
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -933,10 +873,11 @@ public final class Ztp {
public Builder setDevId(context.ContextOuterClass.DeviceId.Builder builderForValue) {
if (devIdBuilder_ == null) {
devId_ = builderForValue.build();
onChanged();
} else {
devIdBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -945,15 +886,16 @@ public final class Ztp {
*/
public Builder mergeDevId(context.ContextOuterClass.DeviceId value) {
if (devIdBuilder_ == null) {
if (devId_ != null) {
devId_ = context.ContextOuterClass.DeviceId.newBuilder(devId_).mergeFrom(value).buildPartial();
if (((bitField0_ & 0x00000002) != 0) && devId_ != null && devId_ != context.ContextOuterClass.DeviceId.getDefaultInstance()) {
getDevIdBuilder().mergeFrom(value);
} else {
devId_ = value;
}
onChanged();
} else {
devIdBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -961,13 +903,13 @@ public final class Ztp {
* <code>.context.DeviceId devId = 2;</code>
*/
public Builder clearDevId() {
if (devIdBuilder_ == null) {
devId_ = null;
onChanged();
} else {
bitField0_ = (bitField0_ & ~0x00000002);
devId_ = null;
if (devIdBuilder_ != null) {
devIdBuilder_.dispose();
devIdBuilder_ = null;
}
onChanged();
return this;
}
......@@ -975,6 +917,7 @@ public final class Ztp {
* <code>.context.DeviceId devId = 2;</code>
*/
public context.ContextOuterClass.DeviceId.Builder getDevIdBuilder() {
bitField0_ |= 0x00000002;
onChanged();
return getDevIdFieldBuilder().getBuilder();
}
......@@ -1028,7 +971,17 @@ public final class Ztp {
@java.lang.Override
public DeviceRoleId parsePartialFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
return new DeviceRoleId(input, extensionRegistry);
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
......@@ -1103,63 +1056,6 @@ public final class Ztp {
return new DeviceRole();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
return this.unknownFields;
}
private DeviceRole(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
this();
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder();
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
ztp.Ztp.DeviceRoleId.Builder subBuilder = null;
if (devRoleId_ != null) {
subBuilder = devRoleId_.toBuilder();
}
devRoleId_ = input.readMessage(ztp.Ztp.DeviceRoleId.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(devRoleId_);
devRoleId_ = subBuilder.buildPartial();
}
break;
}
case 16:
{
int rawValue = input.readEnum();
devRoleType_ = rawValue;
break;
}
default:
{
if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) {
done = true;
}
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(this);
} finally {
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
return ztp.Ztp.internal_static_ztp_DeviceRole_descriptor;
}
......@@ -1196,12 +1092,12 @@ public final class Ztp {
*/
@java.lang.Override
public ztp.Ztp.DeviceRoleIdOrBuilder getDevRoleIdOrBuilder() {
return getDevRoleId();
return devRoleId_ == null ? ztp.Ztp.DeviceRoleId.getDefaultInstance() : devRoleId_;
}
public static final int DEVROLETYPE_FIELD_NUMBER = 2;
private int devRoleType_;
private int devRoleType_ = 0;
/**
* <code>.ztp.DeviceRoleType devRoleType = 2;</code>
......@@ -1218,8 +1114,7 @@ public final class Ztp {
*/
@java.lang.Override
public ztp.Ztp.DeviceRoleType getDevRoleType() {
@SuppressWarnings("deprecation")
ztp.Ztp.DeviceRoleType result = ztp.Ztp.DeviceRoleType.valueOf(devRoleType_);
ztp.Ztp.DeviceRoleType result = ztp.Ztp.DeviceRoleType.forNumber(devRoleType_);
return result == null ? ztp.Ztp.DeviceRoleType.UNRECOGNIZED : result;
}
......@@ -1244,7 +1139,7 @@ public final class Ztp {
if (devRoleType_ != ztp.Ztp.DeviceRoleType.NONE.getNumber()) {
output.writeEnum(2, devRoleType_);
}
unknownFields.writeTo(output);
getUnknownFields().writeTo(output);
}
@java.lang.Override
......@@ -1259,7 +1154,7 @@ public final class Ztp {
if (devRoleType_ != ztp.Ztp.DeviceRoleType.NONE.getNumber()) {
size += com.google.protobuf.CodedOutputStream.computeEnumSize(2, devRoleType_);
}
size += unknownFields.getSerializedSize();
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
......@@ -1281,7 +1176,7 @@ public final class Ztp {
}
if (devRoleType_ != other.devRoleType_)
return false;
if (!unknownFields.equals(other.unknownFields))
if (!getUnknownFields().equals(other.getUnknownFields()))
return false;
return true;
}
......@@ -1299,7 +1194,7 @@ public final class Ztp {
}
hash = (37 * hash) + DEVROLETYPE_FIELD_NUMBER;
hash = (53 * hash) + devRoleType_;
hash = (29 * hash) + unknownFields.hashCode();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
......@@ -1393,26 +1288,19 @@ public final class Ztp {
// Construct using ztp.Ztp.DeviceRole.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
maybeForceBuilderInitialization();
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
}
}
@java.lang.Override
public Builder clear() {
super.clear();
if (devRoleIdBuilder_ == null) {
devRoleId_ = null;
} else {
bitField0_ = 0;
devRoleId_ = null;
if (devRoleIdBuilder_ != null) {
devRoleIdBuilder_.dispose();
devRoleIdBuilder_ = null;
}
devRoleType_ = 0;
......@@ -1441,44 +1329,21 @@ public final class Ztp {
@java.lang.Override
public ztp.Ztp.DeviceRole buildPartial() {
ztp.Ztp.DeviceRole result = new ztp.Ztp.DeviceRole(this);
if (devRoleIdBuilder_ == null) {
result.devRoleId_ = devRoleId_;
} else {
result.devRoleId_ = devRoleIdBuilder_.build();
if (bitField0_ != 0) {
buildPartial0(result);
}
result.devRoleType_ = devRoleType_;
onBuilt();
return result;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
private void buildPartial0(ztp.Ztp.DeviceRole result) {
int from_bitField0_ = bitField0_;
if (((from_bitField0_ & 0x00000001) != 0)) {
result.devRoleId_ = devRoleIdBuilder_ == null ? devRoleId_ : devRoleIdBuilder_.build();
}
@java.lang.Override
public Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
if (((from_bitField0_ & 0x00000002) != 0)) {
result.devRoleType_ = devRoleType_;
}
@java.lang.Override
public Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
......@@ -1500,7 +1365,7 @@ public final class Ztp {
if (other.devRoleType_ != 0) {
setDevRoleTypeValue(other.getDevRoleTypeValue());
}
this.mergeUnknownFields(other.unknownFields);
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
......@@ -1512,20 +1377,54 @@ public final class Ztp {
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException {
ztp.Ztp.DeviceRole parsedMessage = null;
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
input.readMessage(getDevRoleIdFieldBuilder().getBuilder(), extensionRegistry);
bitField0_ |= 0x00000001;
break;
}
// case 10
case 16:
{
devRoleType_ = input.readEnum();
bitField0_ |= 0x00000002;
break;
}
// case 16
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
// was an endgroup tag
done = true;
}
break;
}
}
// switch (tag)
}
// while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (ztp.Ztp.DeviceRole) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
onChanged();
}
// finally
return this;
}
private int bitField0_;
private ztp.Ztp.DeviceRoleId devRoleId_;
private com.google.protobuf.SingleFieldBuilderV3<ztp.Ztp.DeviceRoleId, ztp.Ztp.DeviceRoleId.Builder, ztp.Ztp.DeviceRoleIdOrBuilder> devRoleIdBuilder_;
......@@ -1535,7 +1434,7 @@ public final class Ztp {
* @return Whether the devRoleId field is set.
*/
public boolean hasDevRoleId() {
return devRoleIdBuilder_ != null || devRoleId_ != null;
return ((bitField0_ & 0x00000001) != 0);
}
/**
......@@ -1559,10 +1458,11 @@ public final class Ztp {
throw new NullPointerException();
}
devRoleId_ = value;
onChanged();
} else {
devRoleIdBuilder_.setMessage(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -1572,10 +1472,11 @@ public final class Ztp {
public Builder setDevRoleId(ztp.Ztp.DeviceRoleId.Builder builderForValue) {
if (devRoleIdBuilder_ == null) {
devRoleId_ = builderForValue.build();
onChanged();
} else {
devRoleIdBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -1584,15 +1485,16 @@ public final class Ztp {
*/
public Builder mergeDevRoleId(ztp.Ztp.DeviceRoleId value) {
if (devRoleIdBuilder_ == null) {
if (devRoleId_ != null) {
devRoleId_ = ztp.Ztp.DeviceRoleId.newBuilder(devRoleId_).mergeFrom(value).buildPartial();
if (((bitField0_ & 0x00000001) != 0) && devRoleId_ != null && devRoleId_ != ztp.Ztp.DeviceRoleId.getDefaultInstance()) {
getDevRoleIdBuilder().mergeFrom(value);
} else {
devRoleId_ = value;
}
onChanged();
} else {
devRoleIdBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -1600,13 +1502,13 @@ public final class Ztp {
* <code>.ztp.DeviceRoleId devRoleId = 1;</code>
*/
public Builder clearDevRoleId() {
if (devRoleIdBuilder_ == null) {
devRoleId_ = null;
onChanged();
} else {
bitField0_ = (bitField0_ & ~0x00000001);
devRoleId_ = null;
if (devRoleIdBuilder_ != null) {
devRoleIdBuilder_.dispose();
devRoleIdBuilder_ = null;
}
onChanged();
return this;
}
......@@ -1614,6 +1516,7 @@ public final class Ztp {
* <code>.ztp.DeviceRoleId devRoleId = 1;</code>
*/
public ztp.Ztp.DeviceRoleId.Builder getDevRoleIdBuilder() {
bitField0_ |= 0x00000001;
onChanged();
return getDevRoleIdFieldBuilder().getBuilder();
}
......@@ -1658,6 +1561,7 @@ public final class Ztp {
*/
public Builder setDevRoleTypeValue(int value) {
devRoleType_ = value;
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -1668,8 +1572,7 @@ public final class Ztp {
*/
@java.lang.Override
public ztp.Ztp.DeviceRoleType getDevRoleType() {
@SuppressWarnings("deprecation")
ztp.Ztp.DeviceRoleType result = ztp.Ztp.DeviceRoleType.valueOf(devRoleType_);
ztp.Ztp.DeviceRoleType result = ztp.Ztp.DeviceRoleType.forNumber(devRoleType_);
return result == null ? ztp.Ztp.DeviceRoleType.UNRECOGNIZED : result;
}
......@@ -1682,6 +1585,7 @@ public final class Ztp {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00000002;
devRoleType_ = value.getNumber();
onChanged();
return this;
......@@ -1692,6 +1596,7 @@ public final class Ztp {
* @return This builder for chaining.
*/
public Builder clearDevRoleType() {
bitField0_ = (bitField0_ & ~0x00000002);
devRoleType_ = 0;
onChanged();
return this;
......@@ -1724,7 +1629,17 @@ public final class Ztp {
@java.lang.Override
public DeviceRole parsePartialFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
return new DeviceRole(input, extensionRegistry);
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
......@@ -1803,70 +1718,6 @@ public final class Ztp {
return new DeviceRoleConfig();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
return this.unknownFields;
}
private DeviceRoleConfig(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
this();
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder();
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
ztp.Ztp.DeviceRole.Builder subBuilder = null;
if (devRole_ != null) {
subBuilder = devRole_.toBuilder();
}
devRole_ = input.readMessage(ztp.Ztp.DeviceRole.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(devRole_);
devRole_ = subBuilder.buildPartial();
}
break;
}
case 18:
{
context.ContextOuterClass.DeviceConfig.Builder subBuilder = null;
if (devConfig_ != null) {
subBuilder = devConfig_.toBuilder();
}
devConfig_ = input.readMessage(context.ContextOuterClass.DeviceConfig.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(devConfig_);
devConfig_ = subBuilder.buildPartial();
}
break;
}
default:
{
if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) {
done = true;
}
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(this);
} finally {
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
return ztp.Ztp.internal_static_ztp_DeviceRoleConfig_descriptor;
}
......@@ -1903,7 +1754,7 @@ public final class Ztp {
*/
@java.lang.Override
public ztp.Ztp.DeviceRoleOrBuilder getDevRoleOrBuilder() {
return getDevRole();
return devRole_ == null ? ztp.Ztp.DeviceRole.getDefaultInstance() : devRole_;
}
public static final int DEVCONFIG_FIELD_NUMBER = 2;
......@@ -1933,7 +1784,7 @@ public final class Ztp {
*/
@java.lang.Override
public context.ContextOuterClass.DeviceConfigOrBuilder getDevConfigOrBuilder() {
return getDevConfig();
return devConfig_ == null ? context.ContextOuterClass.DeviceConfig.getDefaultInstance() : devConfig_;
}
private byte memoizedIsInitialized = -1;
......@@ -1957,7 +1808,7 @@ public final class Ztp {
if (devConfig_ != null) {
output.writeMessage(2, getDevConfig());
}
unknownFields.writeTo(output);
getUnknownFields().writeTo(output);
}
@java.lang.Override
......@@ -1972,7 +1823,7 @@ public final class Ztp {
if (devConfig_ != null) {
size += com.google.protobuf.CodedOutputStream.computeMessageSize(2, getDevConfig());
}
size += unknownFields.getSerializedSize();
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
......@@ -1998,7 +1849,7 @@ public final class Ztp {
if (!getDevConfig().equals(other.getDevConfig()))
return false;
}
if (!unknownFields.equals(other.unknownFields))
if (!getUnknownFields().equals(other.getUnknownFields()))
return false;
return true;
}
......@@ -2018,7 +1869,7 @@ public final class Ztp {
hash = (37 * hash) + DEVCONFIG_FIELD_NUMBER;
hash = (53 * hash) + getDevConfig().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
......@@ -2112,32 +1963,24 @@ public final class Ztp {
// Construct using ztp.Ztp.DeviceRoleConfig.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
maybeForceBuilderInitialization();
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
}
}
@java.lang.Override
public Builder clear() {
super.clear();
if (devRoleBuilder_ == null) {
devRole_ = null;
} else {
bitField0_ = 0;
devRole_ = null;
if (devRoleBuilder_ != null) {
devRoleBuilder_.dispose();
devRoleBuilder_ = null;
}
if (devConfigBuilder_ == null) {
devConfig_ = null;
} else {
devConfig_ = null;
if (devConfigBuilder_ != null) {
devConfigBuilder_.dispose();
devConfigBuilder_ = null;
}
return this;
......@@ -2165,48 +2008,21 @@ public final class Ztp {
@java.lang.Override
public ztp.Ztp.DeviceRoleConfig buildPartial() {
ztp.Ztp.DeviceRoleConfig result = new ztp.Ztp.DeviceRoleConfig(this);
if (devRoleBuilder_ == null) {
result.devRole_ = devRole_;
} else {
result.devRole_ = devRoleBuilder_.build();
}
if (devConfigBuilder_ == null) {
result.devConfig_ = devConfig_;
} else {
result.devConfig_ = devConfigBuilder_.build();
if (bitField0_ != 0) {
buildPartial0(result);
}
onBuilt();
return result;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
private void buildPartial0(ztp.Ztp.DeviceRoleConfig result) {
int from_bitField0_ = bitField0_;
if (((from_bitField0_ & 0x00000001) != 0)) {
result.devRole_ = devRoleBuilder_ == null ? devRole_ : devRoleBuilder_.build();
}
@java.lang.Override
public Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
if (((from_bitField0_ & 0x00000002) != 0)) {
result.devConfig_ = devConfigBuilder_ == null ? devConfig_ : devConfigBuilder_.build();
}
@java.lang.Override
public Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
......@@ -2228,7 +2044,7 @@ public final class Ztp {
if (other.hasDevConfig()) {
mergeDevConfig(other.getDevConfig());
}
this.mergeUnknownFields(other.unknownFields);
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
......@@ -2240,20 +2056,54 @@ public final class Ztp {
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException {
ztp.Ztp.DeviceRoleConfig parsedMessage = null;
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
input.readMessage(getDevRoleFieldBuilder().getBuilder(), extensionRegistry);
bitField0_ |= 0x00000001;
break;
}
// case 10
case 18:
{
input.readMessage(getDevConfigFieldBuilder().getBuilder(), extensionRegistry);
bitField0_ |= 0x00000002;
break;
}
// case 18
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
// was an endgroup tag
done = true;
}
break;
}
}
// switch (tag)
}
// while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (ztp.Ztp.DeviceRoleConfig) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
onChanged();
}
// finally
return this;
}
private int bitField0_;
private ztp.Ztp.DeviceRole devRole_;
private com.google.protobuf.SingleFieldBuilderV3<ztp.Ztp.DeviceRole, ztp.Ztp.DeviceRole.Builder, ztp.Ztp.DeviceRoleOrBuilder> devRoleBuilder_;
......@@ -2263,7 +2113,7 @@ public final class Ztp {
* @return Whether the devRole field is set.
*/
public boolean hasDevRole() {
return devRoleBuilder_ != null || devRole_ != null;
return ((bitField0_ & 0x00000001) != 0);
}
/**
......@@ -2287,10 +2137,11 @@ public final class Ztp {
throw new NullPointerException();
}
devRole_ = value;
onChanged();
} else {
devRoleBuilder_.setMessage(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -2300,10 +2151,11 @@ public final class Ztp {
public Builder setDevRole(ztp.Ztp.DeviceRole.Builder builderForValue) {
if (devRoleBuilder_ == null) {
devRole_ = builderForValue.build();
onChanged();
} else {
devRoleBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -2312,15 +2164,16 @@ public final class Ztp {
*/
public Builder mergeDevRole(ztp.Ztp.DeviceRole value) {
if (devRoleBuilder_ == null) {
if (devRole_ != null) {
devRole_ = ztp.Ztp.DeviceRole.newBuilder(devRole_).mergeFrom(value).buildPartial();
if (((bitField0_ & 0x00000001) != 0) && devRole_ != null && devRole_ != ztp.Ztp.DeviceRole.getDefaultInstance()) {
getDevRoleBuilder().mergeFrom(value);
} else {
devRole_ = value;
}
onChanged();
} else {
devRoleBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -2328,13 +2181,13 @@ public final class Ztp {
* <code>.ztp.DeviceRole devRole = 1;</code>
*/
public Builder clearDevRole() {
if (devRoleBuilder_ == null) {
devRole_ = null;
onChanged();
} else {
bitField0_ = (bitField0_ & ~0x00000001);
devRole_ = null;
if (devRoleBuilder_ != null) {
devRoleBuilder_.dispose();
devRoleBuilder_ = null;
}
onChanged();
return this;
}
......@@ -2342,6 +2195,7 @@ public final class Ztp {
* <code>.ztp.DeviceRole devRole = 1;</code>
*/
public ztp.Ztp.DeviceRole.Builder getDevRoleBuilder() {
bitField0_ |= 0x00000001;
onChanged();
return getDevRoleFieldBuilder().getBuilder();
}
......@@ -2377,7 +2231,7 @@ public final class Ztp {
* @return Whether the devConfig field is set.
*/
public boolean hasDevConfig() {
return devConfigBuilder_ != null || devConfig_ != null;
return ((bitField0_ & 0x00000002) != 0);
}
/**
......@@ -2401,10 +2255,11 @@ public final class Ztp {
throw new NullPointerException();
}
devConfig_ = value;
onChanged();
} else {
devConfigBuilder_.setMessage(value);
}
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -2414,10 +2269,11 @@ public final class Ztp {
public Builder setDevConfig(context.ContextOuterClass.DeviceConfig.Builder builderForValue) {
if (devConfigBuilder_ == null) {
devConfig_ = builderForValue.build();
onChanged();
} else {
devConfigBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -2426,15 +2282,16 @@ public final class Ztp {
*/
public Builder mergeDevConfig(context.ContextOuterClass.DeviceConfig value) {
if (devConfigBuilder_ == null) {
if (devConfig_ != null) {
devConfig_ = context.ContextOuterClass.DeviceConfig.newBuilder(devConfig_).mergeFrom(value).buildPartial();
if (((bitField0_ & 0x00000002) != 0) && devConfig_ != null && devConfig_ != context.ContextOuterClass.DeviceConfig.getDefaultInstance()) {
getDevConfigBuilder().mergeFrom(value);
} else {
devConfig_ = value;
}
onChanged();
} else {
devConfigBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -2442,13 +2299,13 @@ public final class Ztp {
* <code>.context.DeviceConfig devConfig = 2;</code>
*/
public Builder clearDevConfig() {
if (devConfigBuilder_ == null) {
devConfig_ = null;
onChanged();
} else {
bitField0_ = (bitField0_ & ~0x00000002);
devConfig_ = null;
if (devConfigBuilder_ != null) {
devConfigBuilder_.dispose();
devConfigBuilder_ = null;
}
onChanged();
return this;
}
......@@ -2456,6 +2313,7 @@ public final class Ztp {
* <code>.context.DeviceConfig devConfig = 2;</code>
*/
public context.ContextOuterClass.DeviceConfig.Builder getDevConfigBuilder() {
bitField0_ |= 0x00000002;
onChanged();
return getDevConfigFieldBuilder().getBuilder();
}
......@@ -2509,7 +2367,17 @@ public final class Ztp {
@java.lang.Override
public DeviceRoleConfig parsePartialFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
return new DeviceRoleConfig(input, extensionRegistry);
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
......@@ -2580,57 +2448,6 @@ public final class Ztp {
return new DeviceRoleList();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
return this.unknownFields;
}
private DeviceRoleList(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
this();
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
int mutable_bitField0_ = 0;
com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder();
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
if (!((mutable_bitField0_ & 0x00000001) != 0)) {
devRole_ = new java.util.ArrayList<ztp.Ztp.DeviceRole>();
mutable_bitField0_ |= 0x00000001;
}
devRole_.add(input.readMessage(ztp.Ztp.DeviceRole.parser(), extensionRegistry));
break;
}
default:
{
if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) {
done = true;
}
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(this);
} finally {
if (((mutable_bitField0_ & 0x00000001) != 0)) {
devRole_ = java.util.Collections.unmodifiableList(devRole_);
}
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
return ztp.Ztp.internal_static_ztp_DeviceRoleList_descriptor;
}
......@@ -2642,6 +2459,7 @@ public final class Ztp {
public static final int DEVROLE_FIELD_NUMBER = 1;
@SuppressWarnings("serial")
private java.util.List<ztp.Ztp.DeviceRole> devRole_;
/**
......@@ -2702,7 +2520,7 @@ public final class Ztp {
for (int i = 0; i < devRole_.size(); i++) {
output.writeMessage(1, devRole_.get(i));
}
unknownFields.writeTo(output);
getUnknownFields().writeTo(output);
}
@java.lang.Override
......@@ -2714,7 +2532,7 @@ public final class Ztp {
for (int i = 0; i < devRole_.size(); i++) {
size += com.google.protobuf.CodedOutputStream.computeMessageSize(1, devRole_.get(i));
}
size += unknownFields.getSerializedSize();
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
......@@ -2730,7 +2548,7 @@ public final class Ztp {
ztp.Ztp.DeviceRoleList other = (ztp.Ztp.DeviceRoleList) obj;
if (!getDevRoleList().equals(other.getDevRoleList()))
return false;
if (!unknownFields.equals(other.unknownFields))
if (!getUnknownFields().equals(other.getUnknownFields()))
return false;
return true;
}
......@@ -2746,7 +2564,7 @@ public final class Ztp {
hash = (37 * hash) + DEVROLE_FIELD_NUMBER;
hash = (53 * hash) + getDevRoleList().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
......@@ -2840,29 +2658,23 @@ public final class Ztp {
// Construct using ztp.Ztp.DeviceRoleList.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
maybeForceBuilderInitialization();
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
getDevRoleFieldBuilder();
}
}
@java.lang.Override
public Builder clear() {
super.clear();
bitField0_ = 0;
if (devRoleBuilder_ == null) {
devRole_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00000001);
} else {
devRole_ = null;
devRoleBuilder_.clear();
}
bitField0_ = (bitField0_ & ~0x00000001);
return this;
}
......@@ -2888,7 +2700,15 @@ public final class Ztp {
@java.lang.Override
public ztp.Ztp.DeviceRoleList buildPartial() {
ztp.Ztp.DeviceRoleList result = new ztp.Ztp.DeviceRoleList(this);
int from_bitField0_ = bitField0_;
buildPartialRepeatedFields(result);
if (bitField0_ != 0) {
buildPartial0(result);
}
onBuilt();
return result;
}
private void buildPartialRepeatedFields(ztp.Ztp.DeviceRoleList result) {
if (devRoleBuilder_ == null) {
if (((bitField0_ & 0x00000001) != 0)) {
devRole_ = java.util.Collections.unmodifiableList(devRole_);
......@@ -2898,38 +2718,10 @@ public final class Ztp {
} else {
result.devRole_ = devRoleBuilder_.build();
}
onBuilt();
return result;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
}
@java.lang.Override
public Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
}
@java.lang.Override
public Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.addRepeatedField(field, value);
private void buildPartial0(ztp.Ztp.DeviceRoleList result) {
int from_bitField0_ = bitField0_;
}
@java.lang.Override
......@@ -2969,7 +2761,7 @@ public final class Ztp {
}
}
}
this.mergeUnknownFields(other.unknownFields);
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
......@@ -2981,17 +2773,47 @@ public final class Ztp {
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException {
ztp.Ztp.DeviceRoleList parsedMessage = null;
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
ztp.Ztp.DeviceRole m = input.readMessage(ztp.Ztp.DeviceRole.parser(), extensionRegistry);
if (devRoleBuilder_ == null) {
ensureDevRoleIsMutable();
devRole_.add(m);
} else {
devRoleBuilder_.addMessage(m);
}
break;
}
// case 10
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
// was an endgroup tag
done = true;
}
break;
}
}
// switch (tag)
}
// while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (ztp.Ztp.DeviceRoleList) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
onChanged();
}
// finally
return this;
}
......@@ -3261,7 +3083,17 @@ public final class Ztp {
@java.lang.Override
public DeviceRoleList parsePartialFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
return new DeviceRoleList(input, extensionRegistry);
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
......@@ -3336,63 +3168,6 @@ public final class Ztp {
return new DeviceRoleState();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
return this.unknownFields;
}
private DeviceRoleState(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
this();
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder();
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
ztp.Ztp.DeviceRoleId.Builder subBuilder = null;
if (devRoleId_ != null) {
subBuilder = devRoleId_.toBuilder();
}
devRoleId_ = input.readMessage(ztp.Ztp.DeviceRoleId.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(devRoleId_);
devRoleId_ = subBuilder.buildPartial();
}
break;
}
case 16:
{
int rawValue = input.readEnum();
devRoleState_ = rawValue;
break;
}
default:
{
if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) {
done = true;
}
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(this);
} finally {
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
return ztp.Ztp.internal_static_ztp_DeviceRoleState_descriptor;
}
......@@ -3429,12 +3204,12 @@ public final class Ztp {
*/
@java.lang.Override
public ztp.Ztp.DeviceRoleIdOrBuilder getDevRoleIdOrBuilder() {
return getDevRoleId();
return devRoleId_ == null ? ztp.Ztp.DeviceRoleId.getDefaultInstance() : devRoleId_;
}
public static final int DEVROLESTATE_FIELD_NUMBER = 2;
private int devRoleState_;
private int devRoleState_ = 0;
/**
* <code>.ztp.ZtpDeviceState devRoleState = 2;</code>
......@@ -3451,8 +3226,7 @@ public final class Ztp {
*/
@java.lang.Override
public ztp.Ztp.ZtpDeviceState getDevRoleState() {
@SuppressWarnings("deprecation")
ztp.Ztp.ZtpDeviceState result = ztp.Ztp.ZtpDeviceState.valueOf(devRoleState_);
ztp.Ztp.ZtpDeviceState result = ztp.Ztp.ZtpDeviceState.forNumber(devRoleState_);
return result == null ? ztp.Ztp.ZtpDeviceState.UNRECOGNIZED : result;
}
......@@ -3477,7 +3251,7 @@ public final class Ztp {
if (devRoleState_ != ztp.Ztp.ZtpDeviceState.ZTP_DEV_STATE_UNDEFINED.getNumber()) {
output.writeEnum(2, devRoleState_);
}
unknownFields.writeTo(output);
getUnknownFields().writeTo(output);
}
@java.lang.Override
......@@ -3492,7 +3266,7 @@ public final class Ztp {
if (devRoleState_ != ztp.Ztp.ZtpDeviceState.ZTP_DEV_STATE_UNDEFINED.getNumber()) {
size += com.google.protobuf.CodedOutputStream.computeEnumSize(2, devRoleState_);
}
size += unknownFields.getSerializedSize();
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
......@@ -3514,7 +3288,7 @@ public final class Ztp {
}
if (devRoleState_ != other.devRoleState_)
return false;
if (!unknownFields.equals(other.unknownFields))
if (!getUnknownFields().equals(other.getUnknownFields()))
return false;
return true;
}
......@@ -3532,7 +3306,7 @@ public final class Ztp {
}
hash = (37 * hash) + DEVROLESTATE_FIELD_NUMBER;
hash = (53 * hash) + devRoleState_;
hash = (29 * hash) + unknownFields.hashCode();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
......@@ -3626,26 +3400,19 @@ public final class Ztp {
// Construct using ztp.Ztp.DeviceRoleState.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
maybeForceBuilderInitialization();
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
}
}
@java.lang.Override
public Builder clear() {
super.clear();
if (devRoleIdBuilder_ == null) {
devRoleId_ = null;
} else {
bitField0_ = 0;
devRoleId_ = null;
if (devRoleIdBuilder_ != null) {
devRoleIdBuilder_.dispose();
devRoleIdBuilder_ = null;
}
devRoleState_ = 0;
......@@ -3674,44 +3441,21 @@ public final class Ztp {
@java.lang.Override
public ztp.Ztp.DeviceRoleState buildPartial() {
ztp.Ztp.DeviceRoleState result = new ztp.Ztp.DeviceRoleState(this);
if (devRoleIdBuilder_ == null) {
result.devRoleId_ = devRoleId_;
} else {
result.devRoleId_ = devRoleIdBuilder_.build();
if (bitField0_ != 0) {
buildPartial0(result);
}
result.devRoleState_ = devRoleState_;
onBuilt();
return result;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
private void buildPartial0(ztp.Ztp.DeviceRoleState result) {
int from_bitField0_ = bitField0_;
if (((from_bitField0_ & 0x00000001) != 0)) {
result.devRoleId_ = devRoleIdBuilder_ == null ? devRoleId_ : devRoleIdBuilder_.build();
}
@java.lang.Override
public Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
if (((from_bitField0_ & 0x00000002) != 0)) {
result.devRoleState_ = devRoleState_;
}
@java.lang.Override
public Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
......@@ -3733,7 +3477,7 @@ public final class Ztp {
if (other.devRoleState_ != 0) {
setDevRoleStateValue(other.getDevRoleStateValue());
}
this.mergeUnknownFields(other.unknownFields);
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
......@@ -3745,20 +3489,54 @@ public final class Ztp {
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException {
ztp.Ztp.DeviceRoleState parsedMessage = null;
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
input.readMessage(getDevRoleIdFieldBuilder().getBuilder(), extensionRegistry);
bitField0_ |= 0x00000001;
break;
}
// case 10
case 16:
{
devRoleState_ = input.readEnum();
bitField0_ |= 0x00000002;
break;
}
// case 16
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
// was an endgroup tag
done = true;
}
break;
}
}
// switch (tag)
}
// while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (ztp.Ztp.DeviceRoleState) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
onChanged();
}
// finally
return this;
}
private int bitField0_;
private ztp.Ztp.DeviceRoleId devRoleId_;
private com.google.protobuf.SingleFieldBuilderV3<ztp.Ztp.DeviceRoleId, ztp.Ztp.DeviceRoleId.Builder, ztp.Ztp.DeviceRoleIdOrBuilder> devRoleIdBuilder_;
......@@ -3768,7 +3546,7 @@ public final class Ztp {
* @return Whether the devRoleId field is set.
*/
public boolean hasDevRoleId() {
return devRoleIdBuilder_ != null || devRoleId_ != null;
return ((bitField0_ & 0x00000001) != 0);
}
/**
......@@ -3792,10 +3570,11 @@ public final class Ztp {
throw new NullPointerException();
}
devRoleId_ = value;
onChanged();
} else {
devRoleIdBuilder_.setMessage(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -3805,10 +3584,11 @@ public final class Ztp {
public Builder setDevRoleId(ztp.Ztp.DeviceRoleId.Builder builderForValue) {
if (devRoleIdBuilder_ == null) {
devRoleId_ = builderForValue.build();
onChanged();
} else {
devRoleIdBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -3817,15 +3597,16 @@ public final class Ztp {
*/
public Builder mergeDevRoleId(ztp.Ztp.DeviceRoleId value) {
if (devRoleIdBuilder_ == null) {
if (devRoleId_ != null) {
devRoleId_ = ztp.Ztp.DeviceRoleId.newBuilder(devRoleId_).mergeFrom(value).buildPartial();
if (((bitField0_ & 0x00000001) != 0) && devRoleId_ != null && devRoleId_ != ztp.Ztp.DeviceRoleId.getDefaultInstance()) {
getDevRoleIdBuilder().mergeFrom(value);
} else {
devRoleId_ = value;
}
onChanged();
} else {
devRoleIdBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -3833,13 +3614,13 @@ public final class Ztp {
* <code>.ztp.DeviceRoleId devRoleId = 1;</code>
*/
public Builder clearDevRoleId() {
if (devRoleIdBuilder_ == null) {
devRoleId_ = null;
onChanged();
} else {
bitField0_ = (bitField0_ & ~0x00000001);
devRoleId_ = null;
if (devRoleIdBuilder_ != null) {
devRoleIdBuilder_.dispose();
devRoleIdBuilder_ = null;
}
onChanged();
return this;
}
......@@ -3847,6 +3628,7 @@ public final class Ztp {
* <code>.ztp.DeviceRoleId devRoleId = 1;</code>
*/
public ztp.Ztp.DeviceRoleId.Builder getDevRoleIdBuilder() {
bitField0_ |= 0x00000001;
onChanged();
return getDevRoleIdFieldBuilder().getBuilder();
}
......@@ -3891,6 +3673,7 @@ public final class Ztp {
*/
public Builder setDevRoleStateValue(int value) {
devRoleState_ = value;
bitField0_ |= 0x00000002;
onChanged();
return this;
}
......@@ -3901,8 +3684,7 @@ public final class Ztp {
*/
@java.lang.Override
public ztp.Ztp.ZtpDeviceState getDevRoleState() {
@SuppressWarnings("deprecation")
ztp.Ztp.ZtpDeviceState result = ztp.Ztp.ZtpDeviceState.valueOf(devRoleState_);
ztp.Ztp.ZtpDeviceState result = ztp.Ztp.ZtpDeviceState.forNumber(devRoleState_);
return result == null ? ztp.Ztp.ZtpDeviceState.UNRECOGNIZED : result;
}
......@@ -3915,6 +3697,7 @@ public final class Ztp {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00000002;
devRoleState_ = value.getNumber();
onChanged();
return this;
......@@ -3925,6 +3708,7 @@ public final class Ztp {
* @return This builder for chaining.
*/
public Builder clearDevRoleState() {
bitField0_ = (bitField0_ & ~0x00000002);
devRoleState_ = 0;
onChanged();
return this;
......@@ -3957,7 +3741,17 @@ public final class Ztp {
@java.lang.Override
public DeviceRoleState parsePartialFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
return new DeviceRoleState(input, extensionRegistry);
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
......@@ -4020,7 +3814,7 @@ public final class Ztp {
}
private DeviceDeletionResult() {
deleted_ = com.google.protobuf.LazyStringArrayList.EMPTY;
deleted_ = com.google.protobuf.LazyStringArrayList.emptyList();
}
@java.lang.Override
......@@ -4029,58 +3823,6 @@ public final class Ztp {
return new DeviceDeletionResult();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
return this.unknownFields;
}
private DeviceDeletionResult(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
this();
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
int mutable_bitField0_ = 0;
com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder();
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
java.lang.String s = input.readStringRequireUtf8();
if (!((mutable_bitField0_ & 0x00000001) != 0)) {
deleted_ = new com.google.protobuf.LazyStringArrayList();
mutable_bitField0_ |= 0x00000001;
}
deleted_.add(s);
break;
}
default:
{
if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) {
done = true;
}
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(this);
} finally {
if (((mutable_bitField0_ & 0x00000001) != 0)) {
deleted_ = deleted_.getUnmodifiableView();
}
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
return ztp.Ztp.internal_static_ztp_DeviceDeletionResult_descriptor;
}
......@@ -4092,7 +3834,8 @@ public final class Ztp {
public static final int DELETED_FIELD_NUMBER = 1;
private com.google.protobuf.LazyStringList deleted_;
@SuppressWarnings("serial")
private com.google.protobuf.LazyStringArrayList deleted_ = com.google.protobuf.LazyStringArrayList.emptyList();
/**
* <code>repeated string deleted = 1;</code>
......@@ -4146,7 +3889,7 @@ public final class Ztp {
for (int i = 0; i < deleted_.size(); i++) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 1, deleted_.getRaw(i));
}
unknownFields.writeTo(output);
getUnknownFields().writeTo(output);
}
@java.lang.Override
......@@ -4163,7 +3906,7 @@ public final class Ztp {
size += dataSize;
size += 1 * getDeletedList().size();
}
size += unknownFields.getSerializedSize();
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
......@@ -4179,7 +3922,7 @@ public final class Ztp {
ztp.Ztp.DeviceDeletionResult other = (ztp.Ztp.DeviceDeletionResult) obj;
if (!getDeletedList().equals(other.getDeletedList()))
return false;
if (!unknownFields.equals(other.unknownFields))
if (!getUnknownFields().equals(other.getUnknownFields()))
return false;
return true;
}
......@@ -4195,7 +3938,7 @@ public final class Ztp {
hash = (37 * hash) + DELETED_FIELD_NUMBER;
hash = (53 * hash) + getDeletedList().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
......@@ -4289,24 +4032,17 @@ public final class Ztp {
// Construct using ztp.Ztp.DeviceDeletionResult.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
maybeForceBuilderInitialization();
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
}
}
@java.lang.Override
public Builder clear() {
super.clear();
deleted_ = com.google.protobuf.LazyStringArrayList.EMPTY;
bitField0_ = (bitField0_ & ~0x00000001);
bitField0_ = 0;
deleted_ = com.google.protobuf.LazyStringArrayList.emptyList();
return this;
}
......@@ -4332,44 +4068,19 @@ public final class Ztp {
@java.lang.Override
public ztp.Ztp.DeviceDeletionResult buildPartial() {
ztp.Ztp.DeviceDeletionResult result = new ztp.Ztp.DeviceDeletionResult(this);
int from_bitField0_ = bitField0_;
if (((bitField0_ & 0x00000001) != 0)) {
deleted_ = deleted_.getUnmodifiableView();
bitField0_ = (bitField0_ & ~0x00000001);
if (bitField0_ != 0) {
buildPartial0(result);
}
result.deleted_ = deleted_;
onBuilt();
return result;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
}
@java.lang.Override
public Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
private void buildPartial0(ztp.Ztp.DeviceDeletionResult result) {
int from_bitField0_ = bitField0_;
if (((from_bitField0_ & 0x00000001) != 0)) {
deleted_.makeImmutable();
result.deleted_ = deleted_;
}
@java.lang.Override
public Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
......@@ -4388,14 +4099,14 @@ public final class Ztp {
if (!other.deleted_.isEmpty()) {
if (deleted_.isEmpty()) {
deleted_ = other.deleted_;
bitField0_ = (bitField0_ & ~0x00000001);
bitField0_ |= 0x00000001;
} else {
ensureDeletedIsMutable();
deleted_.addAll(other.deleted_);
}
onChanged();
}
this.mergeUnknownFields(other.unknownFields);
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
......@@ -4407,29 +4118,55 @@ public final class Ztp {
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException {
ztp.Ztp.DeviceDeletionResult parsedMessage = null;
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
boolean done = false;
while (!done) {
int tag = input.readTag();
switch(tag) {
case 0:
done = true;
break;
case 10:
{
java.lang.String s = input.readStringRequireUtf8();
ensureDeletedIsMutable();
deleted_.add(s);
break;
}
// case 10
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
// was an endgroup tag
done = true;
}
break;
}
}
// switch (tag)
}
// while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (ztp.Ztp.DeviceDeletionResult) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
onChanged();
}
// finally
return this;
}
private int bitField0_;
private com.google.protobuf.LazyStringList deleted_ = com.google.protobuf.LazyStringArrayList.EMPTY;
private com.google.protobuf.LazyStringArrayList deleted_ = com.google.protobuf.LazyStringArrayList.emptyList();
private void ensureDeletedIsMutable() {
if (!((bitField0_ & 0x00000001) != 0)) {
if (!deleted_.isModifiable()) {
deleted_ = new com.google.protobuf.LazyStringArrayList(deleted_);
bitField0_ |= 0x00000001;
}
bitField0_ |= 0x00000001;
}
/**
......@@ -4437,7 +4174,8 @@ public final class Ztp {
* @return A list containing the deleted.
*/
public com.google.protobuf.ProtocolStringList getDeletedList() {
return deleted_.getUnmodifiableView();
deleted_.makeImmutable();
return deleted_;
}
/**
......@@ -4478,6 +4216,7 @@ public final class Ztp {
}
ensureDeletedIsMutable();
deleted_.set(index, value);
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -4493,6 +4232,7 @@ public final class Ztp {
}
ensureDeletedIsMutable();
deleted_.add(value);
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -4505,6 +4245,7 @@ public final class Ztp {
public Builder addAllDeleted(java.lang.Iterable<java.lang.String> values) {
ensureDeletedIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(values, deleted_);
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -4514,8 +4255,9 @@ public final class Ztp {
* @return This builder for chaining.
*/
public Builder clearDeleted() {
deleted_ = com.google.protobuf.LazyStringArrayList.EMPTY;
deleted_ = com.google.protobuf.LazyStringArrayList.emptyList();
bitField0_ = (bitField0_ & ~0x00000001);
;
onChanged();
return this;
}
......@@ -4532,6 +4274,7 @@ public final class Ztp {
checkByteStringIsUtf8(value);
ensureDeletedIsMutable();
deleted_.add(value);
bitField0_ |= 0x00000001;
onChanged();
return this;
}
......@@ -4563,7 +4306,17 @@ public final class Ztp {
@java.lang.Override
public DeviceDeletionResult parsePartialFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException {
return new DeviceDeletionResult(input, extensionRegistry);
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e).setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
......
src/ztp/target/generated-sources/grpc/ztp/ZtpServiceGrpc.java
View file @ a324e412
......@@ -4,7 +4,8 @@ import static io.grpc.MethodDescriptor.generateFullMethodName;
/**
*/
@io.quarkus.grpc.common.Generated(value = "by gRPC proto compiler (version 1.38.1)", comments = "Source: ztp.proto")
@io.quarkus.grpc.common.Generated(value = "by gRPC proto compiler (version 1.55.1)", comments = "Source: ztp.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class ZtpServiceGrpc {
private ZtpServiceGrpc() {
......@@ -147,51 +148,58 @@ public final class ZtpServiceGrpc {
/**
*/
public static abstract class ZtpServiceImplBase implements io.grpc.BindableService {
public interface AsyncService {
/**
*/
public void ztpGetDeviceRole(ztp.Ztp.DeviceRoleId request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRole> responseObserver) {
default void ztpGetDeviceRole(ztp.Ztp.DeviceRoleId request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRole> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getZtpGetDeviceRoleMethod(), responseObserver);
}
/**
*/
public void ztpGetDeviceRolesByDeviceId(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleList> responseObserver) {
default void ztpGetDeviceRolesByDeviceId(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleList> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getZtpGetDeviceRolesByDeviceIdMethod(), responseObserver);
}
/**
*/
public void ztpAdd(ztp.Ztp.DeviceRole request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleState> responseObserver) {
default void ztpAdd(ztp.Ztp.DeviceRole request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleState> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getZtpAddMethod(), responseObserver);
}
/**
*/
public void ztpUpdate(ztp.Ztp.DeviceRoleConfig request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleState> responseObserver) {
default void ztpUpdate(ztp.Ztp.DeviceRoleConfig request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleState> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getZtpUpdateMethod(), responseObserver);
}
/**
*/
public void ztpDelete(ztp.Ztp.DeviceRole request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleState> responseObserver) {
default void ztpDelete(ztp.Ztp.DeviceRole request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceRoleState> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getZtpDeleteMethod(), responseObserver);
}
/**
*/
public void ztpDeleteAll(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceDeletionResult> responseObserver) {
default void ztpDeleteAll(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver<ztp.Ztp.DeviceDeletionResult> responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getZtpDeleteAllMethod(), responseObserver);
}
}
/**
* Base class for the server implementation of the service ZtpService.
*/
public static abstract class ZtpServiceImplBase implements io.grpc.BindableService, AsyncService {
@java.lang.Override
public io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()).addMethod(getZtpGetDeviceRoleMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRoleId, ztp.Ztp.DeviceRole>(this, METHODID_ZTP_GET_DEVICE_ROLE))).addMethod(getZtpGetDeviceRolesByDeviceIdMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.DeviceId, ztp.Ztp.DeviceRoleList>(this, METHODID_ZTP_GET_DEVICE_ROLES_BY_DEVICE_ID))).addMethod(getZtpAddMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRole, ztp.Ztp.DeviceRoleState>(this, METHODID_ZTP_ADD))).addMethod(getZtpUpdateMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRoleConfig, ztp.Ztp.DeviceRoleState>(this, METHODID_ZTP_UPDATE))).addMethod(getZtpDeleteMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRole, ztp.Ztp.DeviceRoleState>(this, METHODID_ZTP_DELETE))).addMethod(getZtpDeleteAllMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, ztp.Ztp.DeviceDeletionResult>(this, METHODID_ZTP_DELETE_ALL))).build();
return ZtpServiceGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service ZtpService.
*/
public static class ZtpServiceStub extends io.grpc.stub.AbstractAsyncStub<ZtpServiceStub> {
......@@ -242,6 +250,7 @@ public final class ZtpServiceGrpc {
}
/**
* A stub to allow clients to do synchronous rpc calls to service ZtpService.
*/
public static class ZtpServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub<ZtpServiceBlockingStub> {
......@@ -292,6 +301,7 @@ public final class ZtpServiceGrpc {
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service ZtpService.
*/
public static class ZtpServiceFutureStub extends io.grpc.stub.AbstractFutureStub<ZtpServiceFutureStub> {
......@@ -355,11 +365,11 @@ public final class ZtpServiceGrpc {
private static final class MethodHandlers<Req, Resp> implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
private final ZtpServiceImplBase serviceImpl;
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(ZtpServiceImplBase serviceImpl, int methodId) {
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
......@@ -401,6 +411,10 @@ public final class ZtpServiceGrpc {
}
}
public static io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()).addMethod(getZtpGetDeviceRoleMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRoleId, ztp.Ztp.DeviceRole>(service, METHODID_ZTP_GET_DEVICE_ROLE))).addMethod(getZtpGetDeviceRolesByDeviceIdMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.DeviceId, ztp.Ztp.DeviceRoleList>(service, METHODID_ZTP_GET_DEVICE_ROLES_BY_DEVICE_ID))).addMethod(getZtpAddMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRole, ztp.Ztp.DeviceRoleState>(service, METHODID_ZTP_ADD))).addMethod(getZtpUpdateMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRoleConfig, ztp.Ztp.DeviceRoleState>(service, METHODID_ZTP_UPDATE))).addMethod(getZtpDeleteMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<ztp.Ztp.DeviceRole, ztp.Ztp.DeviceRoleState>(service, METHODID_ZTP_DELETE))).addMethod(getZtpDeleteAllMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall(new MethodHandlers<context.ContextOuterClass.Empty, ztp.Ztp.DeviceDeletionResult>(service, METHODID_ZTP_DELETE_ALL))).build();
}
private static abstract class ZtpServiceBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ZtpServiceBaseDescriptorSupplier() {
......
src/ztp/target/kubernetes/kubernetes.yml
View file @ a324e412
......@@ -3,8 +3,8 @@ apiVersion: v1
kind: Service
metadata:
annotations:
app.quarkus.io/commit-id: 1fd284c73cf7d419152c8bc99644d0ed8955b355
app.quarkus.io/build-timestamp: 2024-04-08 - 17:36:46 +0000
app.quarkus.io/commit-id: 4a4c9dae464ba1919bca69eb213009c24385a759
app.quarkus.io/build-timestamp: 2025-04-10 - 15:54:11 +0000
prometheus.io/scrape: "true"
prometheus.io/path: /q/metrics
prometheus.io/port: "8080"
......@@ -37,8 +37,8 @@ apiVersion: apps/v1
kind: Deployment
metadata:
annotations:
app.quarkus.io/commit-id: 1fd284c73cf7d419152c8bc99644d0ed8955b355
app.quarkus.io/build-timestamp: 2024-04-08 - 17:36:46 +0000
app.quarkus.io/commit-id: 4a4c9dae464ba1919bca69eb213009c24385a759
app.quarkus.io/build-timestamp: 2025-04-10 - 15:54:11 +0000
prometheus.io/scrape: "true"
prometheus.io/path: /q/metrics
prometheus.io/port: "8080"
......@@ -57,8 +57,8 @@ spec:
template:
metadata:
annotations:
app.quarkus.io/commit-id: 1fd284c73cf7d419152c8bc99644d0ed8955b355
app.quarkus.io/build-timestamp: 2024-04-08 - 17:36:46 +0000
app.quarkus.io/commit-id: 4a4c9dae464ba1919bca69eb213009c24385a759
app.quarkus.io/build-timestamp: 2025-04-10 - 15:54:11 +0000
prometheus.io/scrape: "true"
prometheus.io/path: /q/metrics
prometheus.io/port: "8080"
......@@ -75,10 +75,10 @@ spec:
valueFrom:
fieldRef:
fieldPath: metadata.namespace
- name: DEVICE_SERVICE_HOST
value: deviceservice
- name: CONTEXT_SERVICE_HOST
value: contextservice
- name: DEVICE_SERVICE_HOST
value: deviceservice
image: labs.etsi.org:5050/tfs/controller/ztp:0.2.0
imagePullPolicy: Always
livenessProbe:
......