Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
yanghaoyuan.sh
DolphinScheduler
提交
601a1b66
DolphinScheduler
项目概览
yanghaoyuan.sh
/
DolphinScheduler
与 Fork 源项目一致
Fork自
apache / DolphinScheduler
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
DolphinScheduler
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
601a1b66
编写于
12月 11, 2019
作者:
Q
qiaozhanwei
提交者:
lgcareer
12月 11, 2019
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
remove LogViewServiceGrpc.java file and pom modify (#1436)
上级
fd93b2bb
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
0 addition
and
539 deletion
+0
-539
dolphinscheduler-rpc/pom.xml
dolphinscheduler-rpc/pom.xml
+0
-24
dolphinscheduler-rpc/src/main/java/org/apache/dolphinscheduler/rpc/LogViewServiceGrpc.java
...a/org/apache/dolphinscheduler/rpc/LogViewServiceGrpc.java
+0
-515
未找到文件。
dolphinscheduler-rpc/pom.xml
浏览文件 @
601a1b66
...
@@ -34,7 +34,6 @@
...
@@ -34,7 +34,6 @@
<maven.compiler.source>
1.7
</maven.compiler.source>
<maven.compiler.source>
1.7
</maven.compiler.source>
<maven.compiler.target>
1.7
</maven.compiler.target>
<maven.compiler.target>
1.7
</maven.compiler.target>
<protobuf.output.directory>
${project.basedir}/src/main/java
</protobuf.output.directory>
<protobuf.version>
3.5.1
</protobuf.version>
<protobuf.version>
3.5.1
</protobuf.version>
<grpc.version>
1.9.0
</grpc.version>
<grpc.version>
1.9.0
</grpc.version>
</properties>
</properties>
...
@@ -97,29 +96,6 @@
...
@@ -97,29 +96,6 @@
<goals>
<goals>
<goal>
compile-custom
</goal>
<goal>
compile-custom
</goal>
</goals>
</goals>
<configuration>
<outputDirectory>
${protobuf.output.directory}
</outputDirectory>
</configuration>
</execution>
</executions>
</plugin>
<!-- add generated proto buffer classes into the package -->
<plugin>
<groupId>
org.codehaus.mojo
</groupId>
<artifactId>
build-helper-maven-plugin
</artifactId>
<version>
1.7
</version>
<executions>
<execution>
<id>
add-classes
</id>
<phase>
generate-sources
</phase>
<goals>
<goal>
add-source
</goal>
</goals>
<configuration>
<sources>
<source>
${protobuf.output.directory}
</source>
</sources>
</configuration>
</execution>
</execution>
</executions>
</executions>
</plugin>
</plugin>
...
...
dolphinscheduler-rpc/src/main/java/org/apache/dolphinscheduler/rpc/LogViewServiceGrpc.java
已删除
100644 → 0
浏览文件 @
fd93b2bb
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.apache.dolphinscheduler.rpc
;
import
static
io
.
grpc
.
MethodDescriptor
.
generateFullMethodName
;
import
static
io
.
grpc
.
stub
.
ClientCalls
.
asyncBidiStreamingCall
;
import
static
io
.
grpc
.
stub
.
ClientCalls
.
asyncClientStreamingCall
;
import
static
io
.
grpc
.
stub
.
ClientCalls
.
asyncServerStreamingCall
;
import
static
io
.
grpc
.
stub
.
ClientCalls
.
asyncUnaryCall
;
import
static
io
.
grpc
.
stub
.
ClientCalls
.
blockingServerStreamingCall
;
import
static
io
.
grpc
.
stub
.
ClientCalls
.
blockingUnaryCall
;
import
static
io
.
grpc
.
stub
.
ClientCalls
.
futureUnaryCall
;
import
static
io
.
grpc
.
stub
.
ServerCalls
.
asyncBidiStreamingCall
;
import
static
io
.
grpc
.
stub
.
ServerCalls
.
asyncClientStreamingCall
;
import
static
io
.
grpc
.
stub
.
ServerCalls
.
asyncServerStreamingCall
;
import
static
io
.
grpc
.
stub
.
ServerCalls
.
asyncUnaryCall
;
import
static
io
.
grpc
.
stub
.
ServerCalls
.
asyncUnimplementedStreamingCall
;
import
static
io
.
grpc
.
stub
.
ServerCalls
.
asyncUnimplementedUnaryCall
;
/**
* <pre>
**
* log view service
* </pre>
*/
@javax
.
annotation
.
Generated
(
value
=
"by gRPC proto compiler (version 1.9.0)"
,
comments
=
"Source: scheduler.proto"
)
public
final
class
LogViewServiceGrpc
{
private
LogViewServiceGrpc
()
{}
public
static
final
String
SERVICE_NAME
=
"schduler.LogViewService"
;
// Static method descriptors that strictly reflect the proto.
@io
.
grpc
.
ExperimentalApi
(
"https://github.com/grpc/grpc-java/issues/1901"
)
@java
.
lang
.
Deprecated
// Use {@link #getRollViewLogMethod()} instead.
public
static
final
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
METHOD_ROLL_VIEW_LOG
=
getRollViewLogMethod
();
private
static
volatile
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
getRollViewLogMethod
;
@io
.
grpc
.
ExperimentalApi
(
"https://github.com/grpc/grpc-java/issues/1901"
)
public
static
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
getRollViewLogMethod
()
{
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
getRollViewLogMethod
;
if
((
getRollViewLogMethod
=
LogViewServiceGrpc
.
getRollViewLogMethod
)
==
null
)
{
synchronized
(
LogViewServiceGrpc
.
class
)
{
if
((
getRollViewLogMethod
=
LogViewServiceGrpc
.
getRollViewLogMethod
)
==
null
)
{
LogViewServiceGrpc
.
getRollViewLogMethod
=
getRollViewLogMethod
=
io
.
grpc
.
MethodDescriptor
.<
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
newBuilder
()
.
setType
(
io
.
grpc
.
MethodDescriptor
.
MethodType
.
UNARY
)
.
setFullMethodName
(
generateFullMethodName
(
"schduler.LogViewService"
,
"rollViewLog"
))
.
setSampledToLocalTracing
(
true
)
.
setRequestMarshaller
(
io
.
grpc
.
protobuf
.
ProtoUtils
.
marshaller
(
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
.
getDefaultInstance
()))
.
setResponseMarshaller
(
io
.
grpc
.
protobuf
.
ProtoUtils
.
marshaller
(
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
.
getDefaultInstance
()))
.
setSchemaDescriptor
(
new
LogViewServiceMethodDescriptorSupplier
(
"rollViewLog"
))
.
build
();
}
}
}
return
getRollViewLogMethod
;
}
@io
.
grpc
.
ExperimentalApi
(
"https://github.com/grpc/grpc-java/issues/1901"
)
@java
.
lang
.
Deprecated
// Use {@link #getViewLogMethod()} instead.
public
static
final
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
METHOD_VIEW_LOG
=
getViewLogMethod
();
private
static
volatile
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
getViewLogMethod
;
@io
.
grpc
.
ExperimentalApi
(
"https://github.com/grpc/grpc-java/issues/1901"
)
public
static
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
getViewLogMethod
()
{
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
getViewLogMethod
;
if
((
getViewLogMethod
=
LogViewServiceGrpc
.
getViewLogMethod
)
==
null
)
{
synchronized
(
LogViewServiceGrpc
.
class
)
{
if
((
getViewLogMethod
=
LogViewServiceGrpc
.
getViewLogMethod
)
==
null
)
{
LogViewServiceGrpc
.
getViewLogMethod
=
getViewLogMethod
=
io
.
grpc
.
MethodDescriptor
.<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
newBuilder
()
.
setType
(
io
.
grpc
.
MethodDescriptor
.
MethodType
.
UNARY
)
.
setFullMethodName
(
generateFullMethodName
(
"schduler.LogViewService"
,
"viewLog"
))
.
setSampledToLocalTracing
(
true
)
.
setRequestMarshaller
(
io
.
grpc
.
protobuf
.
ProtoUtils
.
marshaller
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
.
getDefaultInstance
()))
.
setResponseMarshaller
(
io
.
grpc
.
protobuf
.
ProtoUtils
.
marshaller
(
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
.
getDefaultInstance
()))
.
setSchemaDescriptor
(
new
LogViewServiceMethodDescriptorSupplier
(
"viewLog"
))
.
build
();
}
}
}
return
getViewLogMethod
;
}
@io
.
grpc
.
ExperimentalApi
(
"https://github.com/grpc/grpc-java/issues/1901"
)
@java
.
lang
.
Deprecated
// Use {@link #getGetLogBytesMethod()} instead.
public
static
final
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
METHOD_GET_LOG_BYTES
=
getGetLogBytesMethod
();
private
static
volatile
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
getGetLogBytesMethod
;
@io
.
grpc
.
ExperimentalApi
(
"https://github.com/grpc/grpc-java/issues/1901"
)
public
static
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
getGetLogBytesMethod
()
{
io
.
grpc
.
MethodDescriptor
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
getGetLogBytesMethod
;
if
((
getGetLogBytesMethod
=
LogViewServiceGrpc
.
getGetLogBytesMethod
)
==
null
)
{
synchronized
(
LogViewServiceGrpc
.
class
)
{
if
((
getGetLogBytesMethod
=
LogViewServiceGrpc
.
getGetLogBytesMethod
)
==
null
)
{
LogViewServiceGrpc
.
getGetLogBytesMethod
=
getGetLogBytesMethod
=
io
.
grpc
.
MethodDescriptor
.<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
newBuilder
()
.
setType
(
io
.
grpc
.
MethodDescriptor
.
MethodType
.
UNARY
)
.
setFullMethodName
(
generateFullMethodName
(
"schduler.LogViewService"
,
"getLogBytes"
))
.
setSampledToLocalTracing
(
true
)
.
setRequestMarshaller
(
io
.
grpc
.
protobuf
.
ProtoUtils
.
marshaller
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
.
getDefaultInstance
()))
.
setResponseMarshaller
(
io
.
grpc
.
protobuf
.
ProtoUtils
.
marshaller
(
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
.
getDefaultInstance
()))
.
setSchemaDescriptor
(
new
LogViewServiceMethodDescriptorSupplier
(
"getLogBytes"
))
.
build
();
}
}
}
return
getGetLogBytesMethod
;
}
/**
* Creates a new async stub that supports all call types for the service
*/
public
static
LogViewServiceStub
newStub
(
io
.
grpc
.
Channel
channel
)
{
return
new
LogViewServiceStub
(
channel
);
}
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
public
static
LogViewServiceBlockingStub
newBlockingStub
(
io
.
grpc
.
Channel
channel
)
{
return
new
LogViewServiceBlockingStub
(
channel
);
}
/**
* Creates a new ListenableFuture-style stub that supports unary calls on the service
*/
public
static
LogViewServiceFutureStub
newFutureStub
(
io
.
grpc
.
Channel
channel
)
{
return
new
LogViewServiceFutureStub
(
channel
);
}
/**
* <pre>
**
* log view service
* </pre>
*/
public
static
abstract
class
LogViewServiceImplBase
implements
io
.
grpc
.
BindableService
{
/**
* <pre>
**
* roll view log
* </pre>
*/
public
void
rollViewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
request
,
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
responseObserver
)
{
asyncUnimplementedUnaryCall
(
getRollViewLogMethod
(),
responseObserver
);
}
/**
* <pre>
**
* view all log
* </pre>
*/
public
void
viewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
request
,
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
responseObserver
)
{
asyncUnimplementedUnaryCall
(
getViewLogMethod
(),
responseObserver
);
}
/**
* <pre>
**
* get log bytes
* </pre>
*/
public
void
getLogBytes
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
request
,
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
responseObserver
)
{
asyncUnimplementedUnaryCall
(
getGetLogBytesMethod
(),
responseObserver
);
}
@java
.
lang
.
Override
public
final
io
.
grpc
.
ServerServiceDefinition
bindService
()
{
return
io
.
grpc
.
ServerServiceDefinition
.
builder
(
getServiceDescriptor
())
.
addMethod
(
getRollViewLogMethod
(),
asyncUnaryCall
(
new
MethodHandlers
<
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>(
this
,
METHODID_ROLL_VIEW_LOG
)))
.
addMethod
(
getViewLogMethod
(),
asyncUnaryCall
(
new
MethodHandlers
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>(
this
,
METHODID_VIEW_LOG
)))
.
addMethod
(
getGetLogBytesMethod
(),
asyncUnaryCall
(
new
MethodHandlers
<
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
,
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>(
this
,
METHODID_GET_LOG_BYTES
)))
.
build
();
}
}
/**
* <pre>
**
* log view service
* </pre>
*/
public
static
final
class
LogViewServiceStub
extends
io
.
grpc
.
stub
.
AbstractStub
<
LogViewServiceStub
>
{
private
LogViewServiceStub
(
io
.
grpc
.
Channel
channel
)
{
super
(
channel
);
}
private
LogViewServiceStub
(
io
.
grpc
.
Channel
channel
,
io
.
grpc
.
CallOptions
callOptions
)
{
super
(
channel
,
callOptions
);
}
@java
.
lang
.
Override
protected
LogViewServiceStub
build
(
io
.
grpc
.
Channel
channel
,
io
.
grpc
.
CallOptions
callOptions
)
{
return
new
LogViewServiceStub
(
channel
,
callOptions
);
}
/**
* <pre>
**
* roll view log
* </pre>
*/
public
void
rollViewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
request
,
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
responseObserver
)
{
asyncUnaryCall
(
getChannel
().
newCall
(
getRollViewLogMethod
(),
getCallOptions
()),
request
,
responseObserver
);
}
/**
* <pre>
**
* view all log
* </pre>
*/
public
void
viewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
request
,
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
responseObserver
)
{
asyncUnaryCall
(
getChannel
().
newCall
(
getViewLogMethod
(),
getCallOptions
()),
request
,
responseObserver
);
}
/**
* <pre>
**
* get log bytes
* </pre>
*/
public
void
getLogBytes
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
request
,
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
responseObserver
)
{
asyncUnaryCall
(
getChannel
().
newCall
(
getGetLogBytesMethod
(),
getCallOptions
()),
request
,
responseObserver
);
}
}
/**
* <pre>
**
* log view service
* </pre>
*/
public
static
final
class
LogViewServiceBlockingStub
extends
io
.
grpc
.
stub
.
AbstractStub
<
LogViewServiceBlockingStub
>
{
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
);
}
/**
* <pre>
**
* roll view log
* </pre>
*/
public
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
rollViewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
request
)
{
return
blockingUnaryCall
(
getChannel
(),
getRollViewLogMethod
(),
getCallOptions
(),
request
);
}
/**
* <pre>
**
* view all log
* </pre>
*/
public
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
viewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
request
)
{
return
blockingUnaryCall
(
getChannel
(),
getViewLogMethod
(),
getCallOptions
(),
request
);
}
/**
* <pre>
**
* get log bytes
* </pre>
*/
public
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
getLogBytes
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
request
)
{
return
blockingUnaryCall
(
getChannel
(),
getGetLogBytesMethod
(),
getCallOptions
(),
request
);
}
}
/**
* <pre>
**
* log view service
* </pre>
*/
public
static
final
class
LogViewServiceFutureStub
extends
io
.
grpc
.
stub
.
AbstractStub
<
LogViewServiceFutureStub
>
{
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
);
}
/**
* <pre>
**
* roll view log
* </pre>
*/
public
com
.
google
.
common
.
util
.
concurrent
.
ListenableFuture
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
rollViewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
request
)
{
return
futureUnaryCall
(
getChannel
().
newCall
(
getRollViewLogMethod
(),
getCallOptions
()),
request
);
}
/**
* <pre>
**
* view all log
* </pre>
*/
public
com
.
google
.
common
.
util
.
concurrent
.
ListenableFuture
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>
viewLog
(
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
request
)
{
return
futureUnaryCall
(
getChannel
().
newCall
(
getViewLogMethod
(),
getCallOptions
()),
request
);
}
/**
* <pre>
**
* get log bytes
* </pre>
*/
public
com
.
google
.
common
.
util
.
concurrent
.
ListenableFuture
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>
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
<
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
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
<
Resp
>
responseObserver
)
{
switch
(
methodId
)
{
case
METHODID_ROLL_VIEW_LOG:
serviceImpl
.
rollViewLog
((
org
.
apache
.
dolphinscheduler
.
rpc
.
LogParameter
)
request
,
(
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>)
responseObserver
);
break
;
case
METHODID_VIEW_LOG:
serviceImpl
.
viewLog
((
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
)
request
,
(
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetStrInfo
>)
responseObserver
);
break
;
case
METHODID_GET_LOG_BYTES:
serviceImpl
.
getLogBytes
((
org
.
apache
.
dolphinscheduler
.
rpc
.
PathParameter
)
request
,
(
io
.
grpc
.
stub
.
StreamObserver
<
org
.
apache
.
dolphinscheduler
.
rpc
.
RetByteInfo
>)
responseObserver
);
break
;
default
:
throw
new
AssertionError
();
}
}
@java
.
lang
.
Override
@java
.
lang
.
SuppressWarnings
(
"unchecked"
)
public
io
.
grpc
.
stub
.
StreamObserver
<
Req
>
invoke
(
io
.
grpc
.
stub
.
StreamObserver
<
Resp
>
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
;
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录