{
- private LogViewServiceBlockingStub(io.grpc.Channel channel) {
- super(channel);
- }
-
- private LogViewServiceBlockingStub(io.grpc.Channel channel,
- io.grpc.CallOptions callOptions) {
- super(channel, callOptions);
- }
-
- @java.lang.Override
- protected LogViewServiceBlockingStub build(io.grpc.Channel channel,
- io.grpc.CallOptions callOptions) {
- return new LogViewServiceBlockingStub(channel, callOptions);
- }
-
- /**
- *
- **
- * roll view log
- *
- */
- public org.apache.dolphinscheduler.rpc.RetStrInfo rollViewLog(org.apache.dolphinscheduler.rpc.LogParameter request) {
- return blockingUnaryCall(
- getChannel(), getRollViewLogMethod(), getCallOptions(), request);
- }
-
- /**
- *
- **
- * view all log
- *
- */
- public org.apache.dolphinscheduler.rpc.RetStrInfo viewLog(org.apache.dolphinscheduler.rpc.PathParameter request) {
- return blockingUnaryCall(
- getChannel(), getViewLogMethod(), getCallOptions(), request);
- }
-
- /**
- *
- **
- * get log bytes
- *
- */
- public org.apache.dolphinscheduler.rpc.RetByteInfo getLogBytes(org.apache.dolphinscheduler.rpc.PathParameter request) {
- return blockingUnaryCall(
- getChannel(), getGetLogBytesMethod(), getCallOptions(), request);
- }
- }
-
- /**
- *
- **
- * log view service
- *
- */
- public static final class LogViewServiceFutureStub extends io.grpc.stub.AbstractStub {
- private LogViewServiceFutureStub(io.grpc.Channel channel) {
- super(channel);
- }
-
- private LogViewServiceFutureStub(io.grpc.Channel channel,
- io.grpc.CallOptions callOptions) {
- super(channel, callOptions);
- }
-
- @java.lang.Override
- protected LogViewServiceFutureStub build(io.grpc.Channel channel,
- io.grpc.CallOptions callOptions) {
- return new LogViewServiceFutureStub(channel, callOptions);
- }
-
- /**
- *
- **
- * roll view log
- *
- */
- public com.google.common.util.concurrent.ListenableFuture rollViewLog(
- org.apache.dolphinscheduler.rpc.LogParameter request) {
- return futureUnaryCall(
- getChannel().newCall(getRollViewLogMethod(), getCallOptions()), request);
- }
-
- /**
- *
- **
- * view all log
- *
- */
- public com.google.common.util.concurrent.ListenableFuture viewLog(
- org.apache.dolphinscheduler.rpc.PathParameter request) {
- return futureUnaryCall(
- getChannel().newCall(getViewLogMethod(), getCallOptions()), request);
- }
-
- /**
- *
- **
- * get log bytes
- *
- */
- public com.google.common.util.concurrent.ListenableFuture getLogBytes(
- org.apache.dolphinscheduler.rpc.PathParameter request) {
- return futureUnaryCall(
- getChannel().newCall(getGetLogBytesMethod(), getCallOptions()), request);
- }
- }
-
- private static final int METHODID_ROLL_VIEW_LOG = 0;
- private static final int METHODID_VIEW_LOG = 1;
- private static final int METHODID_GET_LOG_BYTES = 2;
-
- 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 LogViewServiceImplBase serviceImpl;
- private final int methodId;
-
- MethodHandlers(LogViewServiceImplBase 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_ROLL_VIEW_LOG:
- serviceImpl.rollViewLog((org.apache.dolphinscheduler.rpc.LogParameter) request,
- (io.grpc.stub.StreamObserver) responseObserver);
- break;
- case METHODID_VIEW_LOG:
- serviceImpl.viewLog((org.apache.dolphinscheduler.rpc.PathParameter) request,
- (io.grpc.stub.StreamObserver) responseObserver);
- break;
- case METHODID_GET_LOG_BYTES:
- serviceImpl.getLogBytes((org.apache.dolphinscheduler.rpc.PathParameter) 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 LogViewServiceBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
- LogViewServiceBaseDescriptorSupplier() {}
-
- @java.lang.Override
- public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
- return org.apache.dolphinscheduler.rpc.SchdulerProto.getDescriptor();
- }
-
- @java.lang.Override
- public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
- return getFileDescriptor().findServiceByName("LogViewService");
- }
- }
-
- private static final class LogViewServiceFileDescriptorSupplier
- extends LogViewServiceBaseDescriptorSupplier {
- LogViewServiceFileDescriptorSupplier() {}
- }
-
- private static final class LogViewServiceMethodDescriptorSupplier
- extends LogViewServiceBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
- private final String methodName;
-
- LogViewServiceMethodDescriptorSupplier(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 (LogViewServiceGrpc.class) {
- result = serviceDescriptor;
- if (result == null) {
- serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
- .setSchemaDescriptor(new LogViewServiceFileDescriptorSupplier())
- .addMethod(getRollViewLogMethod())
- .addMethod(getViewLogMethod())
- .addMethod(getGetLogBytesMethod())
- .build();
- }
- }
- }
- return result;
- }
-}