package cmvr.api; import static io.grpc.MethodDescriptor.generateFullMethodName; /** */ @javax.annotation.Generated( value = "by gRPC proto compiler (version 1.52.0)", comments = "Source: cmvr/api/system_service.proto") @io.grpc.stub.annotations.GrpcGenerated public final class SystemServiceGrpc { private SystemServiceGrpc() {} public static final String SERVICE_NAME = "cmvr.api.SystemService"; // Static method descriptors that strictly reflect the proto. private static volatile io.grpc.MethodDescriptor getGetSystemInfoMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetSystemInfo", requestType = cmvr.api.SystemCommand.GetSystemInfoCommand.Request.class, responseType = cmvr.api.SystemCommand.GetSystemInfoCommand.Feedback.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetSystemInfoMethod() { io.grpc.MethodDescriptor getGetSystemInfoMethod; if ((getGetSystemInfoMethod = SystemServiceGrpc.getGetSystemInfoMethod) == null) { synchronized (SystemServiceGrpc.class) { if ((getGetSystemInfoMethod = SystemServiceGrpc.getGetSystemInfoMethod) == null) { SystemServiceGrpc.getGetSystemInfoMethod = getGetSystemInfoMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSystemInfo")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( cmvr.api.SystemCommand.GetSystemInfoCommand.Request.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( cmvr.api.SystemCommand.GetSystemInfoCommand.Feedback.getDefaultInstance())) .setSchemaDescriptor(new SystemServiceMethodDescriptorSupplier("GetSystemInfo")) .build(); } } } return getGetSystemInfoMethod; } private static volatile io.grpc.MethodDescriptor getGetSystemStatusMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetSystemStatus", requestType = cmvr.api.SystemCommand.GetSystemStatusCommand.Request.class, responseType = cmvr.api.SystemCommand.GetSystemStatusCommand.Feedback.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetSystemStatusMethod() { io.grpc.MethodDescriptor getGetSystemStatusMethod; if ((getGetSystemStatusMethod = SystemServiceGrpc.getGetSystemStatusMethod) == null) { synchronized (SystemServiceGrpc.class) { if ((getGetSystemStatusMethod = SystemServiceGrpc.getGetSystemStatusMethod) == null) { SystemServiceGrpc.getGetSystemStatusMethod = getGetSystemStatusMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSystemStatus")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( cmvr.api.SystemCommand.GetSystemStatusCommand.Request.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( cmvr.api.SystemCommand.GetSystemStatusCommand.Feedback.getDefaultInstance())) .setSchemaDescriptor(new SystemServiceMethodDescriptorSupplier("GetSystemStatus")) .build(); } } } return getGetSystemStatusMethod; } /** * Creates a new async stub that supports all call types for the service */ public static SystemServiceStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { @java.lang.Override public SystemServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new SystemServiceStub(channel, callOptions); } }; return SystemServiceStub.newStub(factory, channel); } /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ public static SystemServiceBlockingStub newBlockingStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { @java.lang.Override public SystemServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new SystemServiceBlockingStub(channel, callOptions); } }; return SystemServiceBlockingStub.newStub(factory, channel); } /** * Creates a new ListenableFuture-style stub that supports unary calls on the service */ public static SystemServiceFutureStub newFutureStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { @java.lang.Override public SystemServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new SystemServiceFutureStub(channel, callOptions); } }; return SystemServiceFutureStub.newStub(factory, channel); } /** */ public static abstract class SystemServiceImplBase implements io.grpc.BindableService { /** */ public void getSystemInfo(cmvr.api.SystemCommand.GetSystemInfoCommand.Request request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSystemInfoMethod(), responseObserver); } /** */ public void getSystemStatus(cmvr.api.SystemCommand.GetSystemStatusCommand.Request request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSystemStatusMethod(), responseObserver); } @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( getGetSystemInfoMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< cmvr.api.SystemCommand.GetSystemInfoCommand.Request, cmvr.api.SystemCommand.GetSystemInfoCommand.Feedback>( this, METHODID_GET_SYSTEM_INFO))) .addMethod( getGetSystemStatusMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< cmvr.api.SystemCommand.GetSystemStatusCommand.Request, cmvr.api.SystemCommand.GetSystemStatusCommand.Feedback>( this, METHODID_GET_SYSTEM_STATUS))) .build(); } } /** */ public static final class SystemServiceStub extends io.grpc.stub.AbstractAsyncStub { private SystemServiceStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override protected SystemServiceStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new SystemServiceStub(channel, callOptions); } /** */ public void getSystemInfo(cmvr.api.SystemCommand.GetSystemInfoCommand.Request request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetSystemInfoMethod(), getCallOptions()), request, responseObserver); } /** */ public void getSystemStatus(cmvr.api.SystemCommand.GetSystemStatusCommand.Request request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetSystemStatusMethod(), getCallOptions()), request, responseObserver); } } /** */ public static final class SystemServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub { private SystemServiceBlockingStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override protected SystemServiceBlockingStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new SystemServiceBlockingStub(channel, callOptions); } /** */ public cmvr.api.SystemCommand.GetSystemInfoCommand.Feedback getSystemInfo(cmvr.api.SystemCommand.GetSystemInfoCommand.Request request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetSystemInfoMethod(), getCallOptions(), request); } /** */ public cmvr.api.SystemCommand.GetSystemStatusCommand.Feedback getSystemStatus(cmvr.api.SystemCommand.GetSystemStatusCommand.Request request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetSystemStatusMethod(), getCallOptions(), request); } } /** */ public static final class SystemServiceFutureStub extends io.grpc.stub.AbstractFutureStub { private SystemServiceFutureStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override protected SystemServiceFutureStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new SystemServiceFutureStub(channel, callOptions); } /** */ public com.google.common.util.concurrent.ListenableFuture getSystemInfo( cmvr.api.SystemCommand.GetSystemInfoCommand.Request request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetSystemInfoMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getSystemStatus( cmvr.api.SystemCommand.GetSystemStatusCommand.Request request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetSystemStatusMethod(), getCallOptions()), request); } } private static final int METHODID_GET_SYSTEM_INFO = 0; private static final int METHODID_GET_SYSTEM_STATUS = 1; private static final class MethodHandlers implements io.grpc.stub.ServerCalls.UnaryMethod, io.grpc.stub.ServerCalls.ServerStreamingMethod, io.grpc.stub.ServerCalls.ClientStreamingMethod, io.grpc.stub.ServerCalls.BidiStreamingMethod { private final SystemServiceImplBase serviceImpl; private final int methodId; MethodHandlers(SystemServiceImplBase serviceImpl, int methodId) { this.serviceImpl = serviceImpl; this.methodId = methodId; } @java.lang.Override @java.lang.SuppressWarnings("unchecked") public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_GET_SYSTEM_INFO: serviceImpl.getSystemInfo((cmvr.api.SystemCommand.GetSystemInfoCommand.Request) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_SYSTEM_STATUS: serviceImpl.getSystemStatus((cmvr.api.SystemCommand.GetSystemStatusCommand.Request) request, (io.grpc.stub.StreamObserver) responseObserver); break; default: throw new AssertionError(); } } @java.lang.Override @java.lang.SuppressWarnings("unchecked") public io.grpc.stub.StreamObserver invoke( io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { default: throw new AssertionError(); } } } private static abstract class SystemServiceBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { SystemServiceBaseDescriptorSupplier() {} @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { return cmvr.api.SystemServiceOuterClass.getDescriptor(); } @java.lang.Override public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { return getFileDescriptor().findServiceByName("SystemService"); } } private static final class SystemServiceFileDescriptorSupplier extends SystemServiceBaseDescriptorSupplier { SystemServiceFileDescriptorSupplier() {} } private static final class SystemServiceMethodDescriptorSupplier extends SystemServiceBaseDescriptorSupplier implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { private final String methodName; SystemServiceMethodDescriptorSupplier(String methodName) { this.methodName = methodName; } @java.lang.Override public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { return getServiceDescriptor().findMethodByName(methodName); } } private static volatile io.grpc.ServiceDescriptor serviceDescriptor; public static io.grpc.ServiceDescriptor getServiceDescriptor() { io.grpc.ServiceDescriptor result = serviceDescriptor; if (result == null) { synchronized (SystemServiceGrpc.class) { result = serviceDescriptor; if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) .setSchemaDescriptor(new SystemServiceFileDescriptorSupplier()) .addMethod(getGetSystemInfoMethod()) .addMethod(getGetSystemStatusMethod()) .build(); } } } return result; } }