{
+ 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 cn.escheduler.rpc.RetStrInfo rollViewLog(cn.escheduler.rpc.LogParameter request) {
+ return blockingUnaryCall(
+ getChannel(), getRollViewLogMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ **
+ * view all log
+ *
+ */
+ public cn.escheduler.rpc.RetStrInfo viewLog(cn.escheduler.rpc.PathParameter request) {
+ return blockingUnaryCall(
+ getChannel(), getViewLogMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ **
+ * get log bytes
+ *
+ */
+ public cn.escheduler.rpc.RetByteInfo getLogBytes(cn.escheduler.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(
+ cn.escheduler.rpc.LogParameter request) {
+ return futureUnaryCall(
+ getChannel().newCall(getRollViewLogMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ **
+ * view all log
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture viewLog(
+ cn.escheduler.rpc.PathParameter request) {
+ return futureUnaryCall(
+ getChannel().newCall(getViewLogMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ **
+ * get log bytes
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getLogBytes(
+ cn.escheduler.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((cn.escheduler.rpc.LogParameter) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_VIEW_LOG:
+ serviceImpl.viewLog((cn.escheduler.rpc.PathParameter) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_LOG_BYTES:
+ serviceImpl.getLogBytes((cn.escheduler.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 cn.escheduler.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;
+ }
+}
diff --git a/escheduler-rpc/src/main/proto/scheduler.proto b/escheduler-rpc/src/main/proto/scheduler.proto
new file mode 100644
index 0000000000..7f1129740d
--- /dev/null
+++ b/escheduler-rpc/src/main/proto/scheduler.proto
@@ -0,0 +1,83 @@
+syntax = "proto3";
+
+package schduler;
+
+option java_multiple_files = true;
+option java_package = "cn.escheduler.rpc";
+option java_outer_classname = "SchdulerProto";
+
+
+/**
+ * return str info
+ */
+message RetStrInfo {
+ /**
+ * str msg info
+ */
+ string msg = 1 ;
+}
+
+/**
+ * return byte info
+ */
+message RetByteInfo {
+ /**
+ * byte data info
+ */
+ bytes data = 1;
+}
+
+/**
+ * log parameter
+ */
+message LogParameter {
+
+ /**
+ * path
+ */
+ string path = 1 ;
+
+ /**
+ * skip line num
+ */
+ int32 skipLineNum = 2 ;
+
+ /**
+ * display limt num
+ */
+ int32 limit = 3 ;
+}
+
+
+/**
+ * path parameter
+ */
+message PathParameter {
+
+ /**
+ * path
+ */
+ string path = 1 ;
+}
+
+/**
+ * log view service
+ */
+service LogViewService {
+
+ /**
+ * roll view log
+ */
+ rpc rollViewLog(LogParameter) returns (RetStrInfo) {};
+
+ /**
+ * view all log
+ */
+ rpc viewLog(PathParameter) returns (RetStrInfo) {};
+
+ /**
+ * get log bytes
+ */
+ rpc getLogBytes(PathParameter) returns (RetByteInfo) {};
+}
+