添加 nacos

This commit is contained in:
eson 2022-06-13 17:45:24 +08:00
parent 4e1e7b42e6
commit f8dddd0fe4
34 changed files with 30637 additions and 408 deletions

View File

@ -24,6 +24,7 @@
<jraft.version>1.3.10</jraft.version>
<spring.boot.web>2.7.0</spring.boot.web>
<mongo.driver.version>3.12.11</mongo.driver.version>
<nacos.version>2.1.0</nacos.version>
</properties>
<dependencies>
@ -80,7 +81,11 @@
<version>${javax.annotation.version}</version>
</dependency>
<dependency>
<groupId>com.alibaba.nacos</groupId>
<artifactId>nacos-client</artifactId>
<version>${nacos.version}</version>
</dependency>
<!-- 添加grpc相关依赖包 -->
@ -121,6 +126,8 @@
</dependency>
</dependencies>
<build>

View File

@ -1,24 +0,0 @@
package com.yuandian.dataflow.annotation;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import org.springframework.boot.context.properties.bind.DefaultValue;
import com.fasterxml.jackson.databind.ser.std.StdKeySerializers.Default;
/**
*
*/
public class Struct {
@Retention(RetentionPolicy.SOURCE)
public @interface Field {
long size() default 4;
}
}

View File

@ -0,0 +1,93 @@
/**
* description
*
* @author eson
*2022年6月13日-17:08:46
*/
package com.yuandian.dataflow.config;
import java.io.IOException;
import java.io.StringBufferInputStream;
import java.io.StringReader;
import java.util.Properties;
import java.util.concurrent.Executor;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import com.google.api.client.http.InputStreamContent;
/**
* description
*
* @author eson
*2022年6月13日-17:08:46
*/
public class Config {
private static Config cnf = new Config();
public static Config GetConfig() {
return cnf;
}
public static void main(String[] args) throws NacosException, InterruptedException, IOException {
String serverAddr = "192.168.1.113:8848";
String dataId = "dataflow";
String group = "yuandian";
Properties properties = new Properties();
properties.put(PropertyKeyConst.SERVER_ADDR, serverAddr);
ConfigService configService = NacosFactory.createConfigService(properties);
String content = configService.getConfig(dataId, group, 5000);
Properties cnf = new Properties();
cnf.load(new StringReader(content));
System.out.println(cnf);
configService.addListener(dataId, group, new Listener() {
@Override
public void receiveConfigInfo(String configInfo) {
System.out.println("recieve:" + configInfo);
try {
cnf.load(new StringReader(configInfo));
System.out.println(cnf);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
@Override
public Executor getExecutor() {
return null;
}
});
Thread.sleep(300000);
// boolean isPublishOk = configService.publishConfig(dataId, group, "content");
// System.out.println(isPublishOk);
// Thread.sleep(3000);
// content = configService.getConfig(dataId, group, 5000);
// System.out.println(content);
// boolean isRemoveOk = configService.removeConfig(dataId, group);
// System.out.println(isRemoveOk);
// Thread.sleep(3000);
// content = configService.getConfig(dataId, group, 5000);
// System.out.println(content);
// Thread.sleep(300000);
};
}

View File

@ -45,10 +45,7 @@ public class TaskLog {
task.setData(ByteBuffer.wrap("hello".getBytes()));
task.setDone(done);
Server.GetNode().apply(task);
Response response = new Response();
response.Code = HttpStatus.OK;
@ -59,8 +56,6 @@ public class TaskLog {
@GetMapping(path = "/test2")
public ResponseEntity<Response> MongodbTest(@RequestBody int status) {
Response response = new Response();
return new ResponseEntity<Response>(response, HttpStatus.OK);
}

View File

@ -12,12 +12,16 @@ import java.time.Instant;
import com.google.protobuf.Any;
import com.google.protobuf.InvalidProtocolBufferException;
import com.yuandian.dataflow.proto.CollectPacketsServerGrpc;
import com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow;
import com.yuandian.dataflow.proto.Base.Request;
import com.yuandian.dataflow.proto.Base.Response;
import com.yuandian.dataflow.proto.CollectPacketsServerGrpc.CollectPacketsServerImplBase;
import com.yuandian.dataflow.proto.CollectPacketsServerGrpc.CollectPacketsServerStub;
import com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow;
import io.grpc.ManagedChannelBuilder;
import io.grpc.netty.shaded.io.netty.handler.codec.compression.CompressionOptions;
import io.grpc.stub.StreamObserver;
@ -58,36 +62,18 @@ public class CollectPackets extends CollectPacketsServerImplBase {
var response = stub.getPackets(Request.newBuilder().setVersion("0.1.0").build());
while(true){
var iter = response.next();
Instant now = Instant.now();
var i = 0;
for(var p : iter.getPacketsList()) {
if(p.is(ApmBaseDataFlow.class)) {
var flow = p.unpack( ApmBaseDataFlow.class);
var flow = p.unpack(ApmBaseDataFlow.class);
i ++;
}
}
}
log.info("条数:{}, {}:ms",i,Duration.between(now, Instant.now()).toMillis());
}
// Client client = new Client("localhost", 2222);
// for (int i = 0; i < 10; i++) {
// Thread.sleep(1000);
// //进行rpc调用的真正逻辑
// client.sayHi("Hello Server -> " + i);
// }
// client.shutdown();
}
}

View File

@ -25,10 +25,16 @@ public final class Base {
int getCode();
/**
* <code>int32 message = 2;</code>
* <code>string message = 2;</code>
* @return The message.
*/
int getMessage();
java.lang.String getMessage();
/**
* <code>string message = 2;</code>
* @return The bytes for message.
*/
com.google.protobuf.ByteString
getMessageBytes();
/**
* <code>repeated .google.protobuf.Any packets = 4;</code>
@ -67,6 +73,7 @@ public final class Base {
super(builder);
}
private Response() {
message_ = "";
packets_ = java.util.Collections.emptyList();
}
@ -106,9 +113,10 @@ public final class Base {
code_ = input.readInt32();
break;
}
case 16: {
case 18: {
java.lang.String s = input.readStringRequireUtf8();
message_ = input.readInt32();
message_ = s;
break;
}
case 34: {
@ -169,14 +177,41 @@ public final class Base {
}
public static final int MESSAGE_FIELD_NUMBER = 2;
private int message_;
private volatile java.lang.Object message_;
/**
* <code>int32 message = 2;</code>
* <code>string message = 2;</code>
* @return The message.
*/
@java.lang.Override
public int getMessage() {
return message_;
public java.lang.String getMessage() {
java.lang.Object ref = message_;
if (ref instanceof java.lang.String) {
return (java.lang.String) ref;
} else {
com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
message_ = s;
return s;
}
}
/**
* <code>string message = 2;</code>
* @return The bytes for message.
*/
@java.lang.Override
public com.google.protobuf.ByteString
getMessageBytes() {
java.lang.Object ref = message_;
if (ref instanceof java.lang.String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
message_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
public static final int PACKETS_FIELD_NUMBER = 4;
@ -236,8 +271,8 @@ public final class Base {
if (code_ != 0) {
output.writeInt32(1, code_);
}
if (message_ != 0) {
output.writeInt32(2, message_);
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(message_)) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 2, message_);
}
for (int i = 0; i < packets_.size(); i++) {
output.writeMessage(4, packets_.get(i));
@ -255,9 +290,8 @@ public final class Base {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, code_);
}
if (message_ != 0) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(2, message_);
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(message_)) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, message_);
}
for (int i = 0; i < packets_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
@ -280,8 +314,8 @@ public final class Base {
if (getCode()
!= other.getCode()) return false;
if (getMessage()
!= other.getMessage()) return false;
if (!getMessage()
.equals(other.getMessage())) return false;
if (!getPacketsList()
.equals(other.getPacketsList())) return false;
if (!unknownFields.equals(other.unknownFields)) return false;
@ -298,7 +332,7 @@ public final class Base {
hash = (37 * hash) + CODE_FIELD_NUMBER;
hash = (53 * hash) + getCode();
hash = (37 * hash) + MESSAGE_FIELD_NUMBER;
hash = (53 * hash) + getMessage();
hash = (53 * hash) + getMessage().hashCode();
if (getPacketsCount() > 0) {
hash = (37 * hash) + PACKETS_FIELD_NUMBER;
hash = (53 * hash) + getPacketsList().hashCode();
@ -439,7 +473,7 @@ public final class Base {
super.clear();
code_ = 0;
message_ = 0;
message_ = "";
if (packetsBuilder_ == null) {
packets_ = java.util.Collections.emptyList();
@ -536,8 +570,9 @@ public final class Base {
if (other.getCode() != 0) {
setCode(other.getCode());
}
if (other.getMessage() != 0) {
setMessage(other.getMessage());
if (!other.getMessage().isEmpty()) {
message_ = other.message_;
onChanged();
}
if (packetsBuilder_ == null) {
if (!other.packets_.isEmpty()) {
@ -626,33 +661,78 @@ public final class Base {
return this;
}
private int message_ ;
private java.lang.Object message_ = "";
/**
* <code>int32 message = 2;</code>
* <code>string message = 2;</code>
* @return The message.
*/
@java.lang.Override
public int getMessage() {
return message_;
public java.lang.String getMessage() {
java.lang.Object ref = message_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
message_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
* <code>int32 message = 2;</code>
* <code>string message = 2;</code>
* @return The bytes for message.
*/
public com.google.protobuf.ByteString
getMessageBytes() {
java.lang.Object ref = message_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
message_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
* <code>string message = 2;</code>
* @param value The message to set.
* @return This builder for chaining.
*/
public Builder setMessage(int value) {
public Builder setMessage(
java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
message_ = value;
onChanged();
return this;
}
/**
* <code>int32 message = 2;</code>
* <code>string message = 2;</code>
* @return This builder for chaining.
*/
public Builder clearMessage() {
message_ = 0;
message_ = getDefaultInstance().getMessage();
onChanged();
return this;
}
/**
* <code>string message = 2;</code>
* @param value The bytes for message to set.
* @return This builder for chaining.
*/
public Builder setMessageBytes(
com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
message_ = value;
onChanged();
return this;
}
@ -2041,7 +2121,7 @@ public final class Base {
java.lang.String[] descriptorData = {
"\n\nBase.proto\022\010dataflow\032\031google/protobuf/" +
"any.proto\"P\n\010Response\022\014\n\004code\030\001 \001(\005\022\017\n\007m" +
"essage\030\002 \001(\005\022%\n\007packets\030\004 \003(\0132\024.google.p" +
"essage\030\002 \001(\t\022%\n\007packets\030\004 \003(\0132\024.google.p" +
"rotobuf.Any\"M\n\007Request\022\014\n\004type\030\001 \001(\005\022\017\n\007" +
"version\030\002 \001(\t\022#\n\005param\030\003 \003(\0132\024.google.pr" +
"otobuf.Any2M\n\024CollectPacketsServer\0225\n\nGe" +

View File

@ -1,7 +1,7 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: ApmBaseDataFlow.proto
package com.yuandian.dataflow.proto;
package com.yuandian.dataflow.proto.msgtype;
public final class ApmBaseDataFlowOuterClass {
private ApmBaseDataFlowOuterClass() {}
@ -671,15 +671,15 @@ public final class ApmBaseDataFlowOuterClass {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.class, com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.class, com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.Builder.class);
}
public static final int TABLE_ID_FIELD_NUMBER = 1;
@ -1584,10 +1584,10 @@ public final class ApmBaseDataFlowOuterClass {
if (obj == this) {
return true;
}
if (!(obj instanceof com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow)) {
if (!(obj instanceof com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow)) {
return super.equals(obj);
}
com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow other = (com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow) obj;
com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow other = (com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow) obj;
if (getTableId()
!= other.getTableId()) return false;
@ -1759,69 +1759,69 @@ public final class ApmBaseDataFlowOuterClass {
return hash;
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(byte[] data)
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseDelimitedFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseDelimitedFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -1834,7 +1834,7 @@ public final class ApmBaseDataFlowOuterClass {
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow prototype) {
public static Builder newBuilder(com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@ -1855,21 +1855,21 @@ public final class ApmBaseDataFlowOuterClass {
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:dataflow.ApmBaseDataFlow)
com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlowOrBuilder {
com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlowOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.class, com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.class, com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.Builder.class);
}
// Construct using com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.newBuilder()
// Construct using com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@ -1969,17 +1969,17 @@ public final class ApmBaseDataFlowOuterClass {
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.internal_static_dataflow_ApmBaseDataFlow_descriptor;
}
@java.lang.Override
public com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.getDefaultInstance();
public com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.getDefaultInstance();
}
@java.lang.Override
public com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow build() {
com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow result = buildPartial();
public com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow build() {
com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@ -1987,8 +1987,8 @@ public final class ApmBaseDataFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow buildPartial() {
com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow result = new com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow(this);
public com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow buildPartial() {
com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow result = new com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow(this);
result.tableId_ = tableId_;
result.probeIf_ = probeIf_;
result.requestPort_ = requestPort_;
@ -2065,16 +2065,16 @@ public final class ApmBaseDataFlowOuterClass {
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow) {
return mergeFrom((com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow)other);
if (other instanceof com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow) {
return mergeFrom((com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow other) {
if (other == com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.getDefaultInstance()) return this;
public Builder mergeFrom(com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow other) {
if (other == com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow.getDefaultInstance()) return this;
if (other.getTableId() != 0) {
setTableId(other.getTableId());
}
@ -2205,11 +2205,11 @@ public final class ApmBaseDataFlowOuterClass {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parsedMessage = null;
com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow) e.getUnfinishedMessage();
parsedMessage = (com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@ -3935,12 +3935,12 @@ public final class ApmBaseDataFlowOuterClass {
}
// @@protoc_insertion_point(class_scope:dataflow.ApmBaseDataFlow)
private static final com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow DEFAULT_INSTANCE;
private static final com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow();
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow();
}
public static com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow getDefaultInstance() {
public static com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@ -3965,7 +3965,7 @@ public final class ApmBaseDataFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.ApmBaseDataFlowOuterClass.ApmBaseDataFlow getDefaultInstanceForType() {
public com.yuandian.dataflow.proto.msgtype.ApmBaseDataFlowOuterClass.ApmBaseDataFlow getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@ -4005,8 +4005,9 @@ public final class ApmBaseDataFlowOuterClass {
"\021\n\tcs_retran\030! \001(\005\022\021\n\tsc_retran\030\" \001(\005\022\025\n" +
"\rconn_setup_tm\030# \001(\005\022\023\n\013new_session\030$ \001(" +
"\005\022\020\n\010cs_alert\030% \001(\005\022\020\n\010sc_alert\030& \001(\005\022\020\n" +
"\010protocal\030\' \001(\tB2\n\033com.yuandian.dataflow" +
".protoZ\023../grpc-gen;grpcgenb\006proto3"
"\010protocal\030\' \001(\tB<\n#com.yuandian.dataflow" +
".proto.msgtypeP\000Z\023../grpc-gen;grpcgenb\006p" +
"roto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,

View File

@ -1,7 +1,7 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: AppFlow.proto
package com.yuandian.dataflow.proto;
package com.yuandian.dataflow.proto.msgtype;
public final class AppFlowOuterClass {
private AppFlowOuterClass() {}
@ -358,15 +358,15 @@ public final class AppFlowOuterClass {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.AppFlowOuterClass.internal_static_dataflow_AppFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.internal_static_dataflow_AppFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.AppFlowOuterClass.internal_static_dataflow_AppFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.internal_static_dataflow_AppFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow.class, com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow.class, com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow.Builder.class);
}
public static final int TABLE_ID_FIELD_NUMBER = 1;
@ -860,10 +860,10 @@ public final class AppFlowOuterClass {
if (obj == this) {
return true;
}
if (!(obj instanceof com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow)) {
if (!(obj instanceof com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow)) {
return super.equals(obj);
}
com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow other = (com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow) obj;
com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow other = (com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow) obj;
if (getTableId()
!= other.getTableId()) return false;
@ -977,69 +977,69 @@ public final class AppFlowOuterClass {
return hash;
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(byte[] data)
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseDelimitedFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseDelimitedFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -1052,7 +1052,7 @@ public final class AppFlowOuterClass {
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow prototype) {
public static Builder newBuilder(com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@ -1073,21 +1073,21 @@ public final class AppFlowOuterClass {
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:dataflow.AppFlow)
com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlowOrBuilder {
com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlowOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.AppFlowOuterClass.internal_static_dataflow_AppFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.internal_static_dataflow_AppFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.AppFlowOuterClass.internal_static_dataflow_AppFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.internal_static_dataflow_AppFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow.class, com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow.class, com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow.Builder.class);
}
// Construct using com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow.newBuilder()
// Construct using com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@ -1159,17 +1159,17 @@ public final class AppFlowOuterClass {
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return com.yuandian.dataflow.proto.AppFlowOuterClass.internal_static_dataflow_AppFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.internal_static_dataflow_AppFlow_descriptor;
}
@java.lang.Override
public com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow.getDefaultInstance();
public com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow.getDefaultInstance();
}
@java.lang.Override
public com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow build() {
com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow result = buildPartial();
public com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow build() {
com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@ -1177,8 +1177,8 @@ public final class AppFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow buildPartial() {
com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow result = new com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow(this);
public com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow buildPartial() {
com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow result = new com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow(this);
result.tableId_ = tableId_;
result.srcIp_ = srcIp_;
result.srcPort_ = srcPort_;
@ -1241,16 +1241,16 @@ public final class AppFlowOuterClass {
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow) {
return mergeFrom((com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow)other);
if (other instanceof com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow) {
return mergeFrom((com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow other) {
if (other == com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow.getDefaultInstance()) return this;
public Builder mergeFrom(com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow other) {
if (other == com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow.getDefaultInstance()) return this;
if (other.getTableId() != 0) {
setTableId(other.getTableId());
}
@ -1339,11 +1339,11 @@ public final class AppFlowOuterClass {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow parsedMessage = null;
com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow) e.getUnfinishedMessage();
parsedMessage = (com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@ -2158,12 +2158,12 @@ public final class AppFlowOuterClass {
}
// @@protoc_insertion_point(class_scope:dataflow.AppFlow)
private static final com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow DEFAULT_INSTANCE;
private static final com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow();
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow();
}
public static com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow getDefaultInstance() {
public static com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@ -2188,7 +2188,7 @@ public final class AppFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.AppFlowOuterClass.AppFlow getDefaultInstanceForType() {
public com.yuandian.dataflow.proto.msgtype.AppFlowOuterClass.AppFlow getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@ -2220,9 +2220,9 @@ public final class AppFlowOuterClass {
"\t\022\016\n\006app_id\030\021 \001(\005\022\024\n\014app_group_id\030\022 \001(\005\022" +
"\020\n\010probe_if\030\023 \001(\005\022\021\n\tapp_style\030\024 \001(\005\022\021\n\t" +
"time_flag\030\025 \001(\005\022\017\n\007vlan_id\030\026 \001(\005\022\022\n\nmpls" +
"_lable\030\027 \001(\005\022\013\n\003tos\030\030 \001(\005B2\n\033com.yuandia" +
"n.dataflow.protoZ\023../grpc-gen;grpcgenb\006p" +
"roto3"
"_lable\030\027 \001(\005\022\013\n\003tos\030\030 \001(\005B<\n#com.yuandia" +
"n.dataflow.proto.msgtypeP\000Z\023../grpc-gen;" +
"grpcgenb\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,

View File

@ -1,7 +1,7 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: BacktrackingFlow.proto
package com.yuandian.dataflow.proto;
package com.yuandian.dataflow.proto.msgtype;
public final class BacktrackingFlowOuterClass {
private BacktrackingFlowOuterClass() {}
@ -367,15 +367,15 @@ public final class BacktrackingFlowOuterClass {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow.class, com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow.class, com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow.Builder.class);
}
public static final int TABLE_ID_FIELD_NUMBER = 1;
@ -825,10 +825,10 @@ public final class BacktrackingFlowOuterClass {
if (obj == this) {
return true;
}
if (!(obj instanceof com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow)) {
if (!(obj instanceof com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow)) {
return super.equals(obj);
}
com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow other = (com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow) obj;
com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow other = (com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow) obj;
if (getTableId()
!= other.getTableId()) return false;
@ -931,69 +931,69 @@ public final class BacktrackingFlowOuterClass {
return hash;
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(byte[] data)
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseDelimitedFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseDelimitedFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -1006,7 +1006,7 @@ public final class BacktrackingFlowOuterClass {
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow prototype) {
public static Builder newBuilder(com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@ -1027,21 +1027,21 @@ public final class BacktrackingFlowOuterClass {
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:dataflow.BacktrackingFlow)
com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlowOrBuilder {
com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlowOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow.class, com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow.class, com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow.Builder.class);
}
// Construct using com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow.newBuilder()
// Construct using com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@ -1103,17 +1103,17 @@ public final class BacktrackingFlowOuterClass {
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.internal_static_dataflow_BacktrackingFlow_descriptor;
}
@java.lang.Override
public com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow.getDefaultInstance();
public com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow.getDefaultInstance();
}
@java.lang.Override
public com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow build() {
com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow result = buildPartial();
public com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow build() {
com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@ -1121,8 +1121,8 @@ public final class BacktrackingFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow buildPartial() {
com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow result = new com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow(this);
public com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow buildPartial() {
com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow result = new com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow(this);
result.tableId_ = tableId_;
result.macSrc_ = macSrc_;
result.macDst_ = macDst_;
@ -1180,16 +1180,16 @@ public final class BacktrackingFlowOuterClass {
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow) {
return mergeFrom((com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow)other);
if (other instanceof com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow) {
return mergeFrom((com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow other) {
if (other == com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow.getDefaultInstance()) return this;
public Builder mergeFrom(com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow other) {
if (other == com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow.getDefaultInstance()) return this;
if (other.getTableId() != 0) {
setTableId(other.getTableId());
}
@ -1262,11 +1262,11 @@ public final class BacktrackingFlowOuterClass {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow parsedMessage = null;
com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow) e.getUnfinishedMessage();
parsedMessage = (com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@ -2097,12 +2097,12 @@ public final class BacktrackingFlowOuterClass {
}
// @@protoc_insertion_point(class_scope:dataflow.BacktrackingFlow)
private static final com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow DEFAULT_INSTANCE;
private static final com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow();
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow();
}
public static com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow getDefaultInstance() {
public static com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@ -2127,7 +2127,7 @@ public final class BacktrackingFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BacktrackingFlowOuterClass.BacktrackingFlow getDefaultInstanceForType() {
public com.yuandian.dataflow.proto.msgtype.BacktrackingFlowOuterClass.BacktrackingFlow getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@ -2156,9 +2156,9 @@ public final class BacktrackingFlowOuterClass {
"\005\022\r\n\005bytes\030\014 \001(\003\022\017\n\007packets\030\r \001(\003\022\016\n\006tcp" +
"_sp\030\016 \001(\003\022\020\n\010tcp_scpn\030\017 \001(\003\022\017\n\007tcp_srp\030\020" +
" \001(\003\022\016\n\006app_id\030\021 \001(\005\022\024\n\014app_group_id\030\022 \001" +
"(\005\022\022\n\nmpls_label\030\023 \001(\005B2\n\033com.yuandian.d" +
"ataflow.protoZ\023../grpc-gen;grpcgenb\006prot" +
"o3"
"(\005\022\022\n\nmpls_label\030\023 \001(\005B<\n#com.yuandian.d" +
"ataflow.proto.msgtypeP\000Z\023../grpc-gen;grp" +
"cgenb\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,

View File

@ -1,7 +1,7 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: BasicTrafficFlow.proto
package com.yuandian.dataflow.proto;
package com.yuandian.dataflow.proto.msgtype;
public final class BasicTrafficFlowOuterClass {
private BasicTrafficFlowOuterClass() {}
@ -262,15 +262,15 @@ public final class BasicTrafficFlowOuterClass {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow.class, com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow.class, com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow.Builder.class);
}
public static final int TABLE_ID_FIELD_NUMBER = 1;
@ -594,10 +594,10 @@ public final class BasicTrafficFlowOuterClass {
if (obj == this) {
return true;
}
if (!(obj instanceof com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow)) {
if (!(obj instanceof com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow)) {
return super.equals(obj);
}
com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow other = (com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow) obj;
com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow other = (com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow) obj;
if (getTableId()
!= other.getTableId()) return false;
@ -679,69 +679,69 @@ public final class BasicTrafficFlowOuterClass {
return hash;
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(byte[] data)
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseDelimitedFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseDelimitedFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -754,7 +754,7 @@ public final class BasicTrafficFlowOuterClass {
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow prototype) {
public static Builder newBuilder(com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@ -775,21 +775,21 @@ public final class BasicTrafficFlowOuterClass {
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:dataflow.BasicTrafficFlow)
com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlowOrBuilder {
com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlowOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow.class, com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow.Builder.class);
com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow.class, com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow.Builder.class);
}
// Construct using com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow.newBuilder()
// Construct using com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@ -845,17 +845,17 @@ public final class BasicTrafficFlowOuterClass {
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_descriptor;
return com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.internal_static_dataflow_BasicTrafficFlow_descriptor;
}
@java.lang.Override
public com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow.getDefaultInstance();
public com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow.getDefaultInstance();
}
@java.lang.Override
public com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow build() {
com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow result = buildPartial();
public com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow build() {
com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@ -863,8 +863,8 @@ public final class BasicTrafficFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow buildPartial() {
com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow result = new com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow(this);
public com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow buildPartial() {
com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow result = new com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow(this);
result.tableId_ = tableId_;
result.capPort_ = capPort_;
result.requestPort_ = requestPort_;
@ -919,16 +919,16 @@ public final class BasicTrafficFlowOuterClass {
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow) {
return mergeFrom((com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow)other);
if (other instanceof com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow) {
return mergeFrom((com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow other) {
if (other == com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow.getDefaultInstance()) return this;
public Builder mergeFrom(com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow other) {
if (other == com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow.getDefaultInstance()) return this;
if (other.getTableId() != 0) {
setTableId(other.getTableId());
}
@ -992,11 +992,11 @@ public final class BasicTrafficFlowOuterClass {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow parsedMessage = null;
com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow) e.getUnfinishedMessage();
parsedMessage = (com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@ -1518,12 +1518,12 @@ public final class BasicTrafficFlowOuterClass {
}
// @@protoc_insertion_point(class_scope:dataflow.BasicTrafficFlow)
private static final com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow DEFAULT_INSTANCE;
private static final com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow();
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow();
}
public static com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow getDefaultInstance() {
public static com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@ -1548,7 +1548,7 @@ public final class BasicTrafficFlowOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BasicTrafficFlowOuterClass.BasicTrafficFlow getDefaultInstanceForType() {
public com.yuandian.dataflow.proto.msgtype.BasicTrafficFlowOuterClass.BasicTrafficFlow getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@ -1577,9 +1577,9 @@ public final class BasicTrafficFlowOuterClass {
"\005\022\022\n\nspackets64\030\n \001(\005\022\023\n\013spackets128\030\013 \001" +
"(\005\022\023\n\013spackets256\030\014 \001(\005\022\023\n\013spackets512\030\r" +
" \001(\005\022\024\n\014spackets1024\030\016 \001(\005\022\020\n\010spackets\030\017" +
" \001(\005\022\021\n\tsend_time\030\020 \001(\005B2\n\033com.yuandian." +
"dataflow.protoZ\023../grpc-gen;grpcgenb\006pro" +
"to3"
" \001(\005\022\021\n\tsend_time\030\020 \001(\005B<\n#com.yuandian." +
"dataflow.proto.msgtypeP\000Z\023../grpc-gen;gr" +
"pcgenb\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,

View File

@ -1,7 +1,7 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: BusinessBodyData.proto
package com.yuandian.dataflow.proto;
package com.yuandian.dataflow.proto.msgtype;
public final class BusinessBodyDataOuterClass {
private BusinessBodyDataOuterClass() {}
@ -364,15 +364,15 @@ public final class BusinessBodyDataOuterClass {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_descriptor;
return com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData.class, com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData.Builder.class);
com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData.class, com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData.Builder.class);
}
public static final int TABLE_ID_FIELD_NUMBER = 1;
@ -956,10 +956,10 @@ public final class BusinessBodyDataOuterClass {
if (obj == this) {
return true;
}
if (!(obj instanceof com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData)) {
if (!(obj instanceof com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData)) {
return super.equals(obj);
}
com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData other = (com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData) obj;
com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData other = (com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData) obj;
if (getTableId()
!= other.getTableId()) return false;
@ -1055,69 +1055,69 @@ public final class BusinessBodyDataOuterClass {
return hash;
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(byte[] data)
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseDelimitedFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseDelimitedFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -1130,7 +1130,7 @@ public final class BusinessBodyDataOuterClass {
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData prototype) {
public static Builder newBuilder(com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@ -1151,21 +1151,21 @@ public final class BusinessBodyDataOuterClass {
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:dataflow.BusinessBodyData)
com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyDataOrBuilder {
com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyDataOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_descriptor;
return com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData.class, com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData.Builder.class);
com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData.class, com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData.Builder.class);
}
// Construct using com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData.newBuilder()
// Construct using com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@ -1225,17 +1225,17 @@ public final class BusinessBodyDataOuterClass {
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_descriptor;
return com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.internal_static_dataflow_BusinessBodyData_descriptor;
}
@java.lang.Override
public com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData.getDefaultInstance();
public com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData.getDefaultInstance();
}
@java.lang.Override
public com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData build() {
com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData result = buildPartial();
public com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData build() {
com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@ -1243,8 +1243,8 @@ public final class BusinessBodyDataOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData buildPartial() {
com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData result = new com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData(this);
public com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData buildPartial() {
com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData result = new com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData(this);
result.tableId_ = tableId_;
result.relvanceDataId_ = relvanceDataId_;
result.requestIp_ = requestIp_;
@ -1301,16 +1301,16 @@ public final class BusinessBodyDataOuterClass {
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData) {
return mergeFrom((com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData)other);
if (other instanceof com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData) {
return mergeFrom((com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData other) {
if (other == com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData.getDefaultInstance()) return this;
public Builder mergeFrom(com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData other) {
if (other == com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData.getDefaultInstance()) return this;
if (other.getTableId() != 0) {
setTableId(other.getTableId());
}
@ -1388,11 +1388,11 @@ public final class BusinessBodyDataOuterClass {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData parsedMessage = null;
com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData) e.getUnfinishedMessage();
parsedMessage = (com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@ -2384,12 +2384,12 @@ public final class BusinessBodyDataOuterClass {
}
// @@protoc_insertion_point(class_scope:dataflow.BusinessBodyData)
private static final com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData DEFAULT_INSTANCE;
private static final com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData();
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData();
}
public static com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData getDefaultInstance() {
public static com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@ -2414,7 +2414,7 @@ public final class BusinessBodyDataOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BusinessBodyDataOuterClass.BusinessBodyData getDefaultInstanceForType() {
public com.yuandian.dataflow.proto.msgtype.BusinessBodyDataOuterClass.BusinessBodyData getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@ -2446,8 +2446,9 @@ public final class BusinessBodyDataOuterClass {
"\n\016request_cookie\030\016 \001(\t\022\034\n\024request_body_c" +
"ontext\030\017 \001(\t\022\035\n\025response_body_context\030\020 " +
"\001(\t\022\021\n\tfilter_id\030\021 \001(\005\022\034\n\024business_detai" +
"l_mesg\030\022 \001(\tB2\n\033com.yuandian.dataflow.pr" +
"otoZ\023../grpc-gen;grpcgenb\006proto3"
"l_mesg\030\022 \001(\tB<\n#com.yuandian.dataflow.pr" +
"oto.msgtypeP\000Z\023../grpc-gen;grpcgenb\006prot" +
"o3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,

View File

@ -1,7 +1,7 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: BussFlowDb.proto
package com.yuandian.dataflow.proto;
package com.yuandian.dataflow.proto.msgtype;
public final class BussFlowDbOuterClass {
private BussFlowDbOuterClass() {}
@ -1095,15 +1095,15 @@ public final class BussFlowDbOuterClass {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_descriptor;
return com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb.class, com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb.Builder.class);
com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb.class, com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb.Builder.class);
}
public static final int TABLE_ID_FIELD_NUMBER = 1;
@ -2957,10 +2957,10 @@ public final class BussFlowDbOuterClass {
if (obj == this) {
return true;
}
if (!(obj instanceof com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb)) {
if (!(obj instanceof com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb)) {
return super.equals(obj);
}
com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb other = (com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb) obj;
com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb other = (com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb) obj;
if (getTableId()
!= other.getTableId()) return false;
@ -3236,69 +3236,69 @@ public final class BussFlowDbOuterClass {
return hash;
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(byte[] data)
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseDelimitedFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseDelimitedFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -3311,7 +3311,7 @@ public final class BussFlowDbOuterClass {
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb prototype) {
public static Builder newBuilder(com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@ -3332,21 +3332,21 @@ public final class BussFlowDbOuterClass {
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:dataflow.BussFlowDb)
com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDbOrBuilder {
com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDbOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_descriptor;
return com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb.class, com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb.Builder.class);
com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb.class, com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb.Builder.class);
}
// Construct using com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb.newBuilder()
// Construct using com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@ -3488,17 +3488,17 @@ public final class BussFlowDbOuterClass {
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return com.yuandian.dataflow.proto.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_descriptor;
return com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.internal_static_dataflow_BussFlowDb_descriptor;
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb.getDefaultInstance();
public com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb.getDefaultInstance();
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb build() {
com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb result = buildPartial();
public com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb build() {
com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@ -3506,8 +3506,8 @@ public final class BussFlowDbOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb buildPartial() {
com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb result = new com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb(this);
public com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb buildPartial() {
com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb result = new com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb(this);
result.tableId_ = tableId_;
result.redisRegex_ = redisRegex_;
result.id_ = id_;
@ -3605,16 +3605,16 @@ public final class BussFlowDbOuterClass {
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb) {
return mergeFrom((com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb)other);
if (other instanceof com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb) {
return mergeFrom((com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb other) {
if (other == com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb.getDefaultInstance()) return this;
public Builder mergeFrom(com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb other) {
if (other == com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb.getDefaultInstance()) return this;
if (other.getTableId() != 0) {
setTableId(other.getTableId());
}
@ -3829,11 +3829,11 @@ public final class BussFlowDbOuterClass {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb parsedMessage = null;
com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb) e.getUnfinishedMessage();
parsedMessage = (com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@ -7174,12 +7174,12 @@ public final class BussFlowDbOuterClass {
}
// @@protoc_insertion_point(class_scope:dataflow.BussFlowDb)
private static final com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb DEFAULT_INSTANCE;
private static final com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb();
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb();
}
public static com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb getDefaultInstance() {
public static com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@ -7204,7 +7204,7 @@ public final class BussFlowDbOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowDbOuterClass.BussFlowDb getDefaultInstanceForType() {
public com.yuandian.dataflow.proto.msgtype.BussFlowDbOuterClass.BussFlowDb getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@ -7257,9 +7257,9 @@ public final class BussFlowDbOuterClass {
"\t\022\017\n\007ori_sql\0304 \001(\t\022\020\n\010reserved\0305 \001(\t\022\020\n\010" +
"bytes_in\0306 \001(\003\022\021\n\tbytes_out\0307 \001(\003\022\022\n\npac" +
"kage_in\0308 \001(\005\022\023\n\013package_out\0309 \001(\005\022\017\n\007da" +
"ta_id\030: \001(\t\022\021\n\tfilter_id\030; \001(\005B2\n\033com.yu" +
"andian.dataflow.protoZ\023../grpc-gen;grpcg" +
"enb\006proto3"
"ta_id\030: \001(\t\022\021\n\tfilter_id\030; \001(\005B<\n#com.yu" +
"andian.dataflow.proto.msgtypeP\000Z\023../grpc" +
"-gen;grpcgenb\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,

View File

@ -1,7 +1,7 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: BussFlowExternal.proto
package com.yuandian.dataflow.proto;
package com.yuandian.dataflow.proto.msgtype;
public final class BussFlowExternalOuterClass {
private BussFlowExternalOuterClass() {}
@ -664,15 +664,15 @@ public final class BussFlowExternalOuterClass {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_descriptor;
return com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal.class, com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal.Builder.class);
com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal.class, com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal.Builder.class);
}
public static final int TABLE_ID_FIELD_NUMBER = 1;
@ -1730,10 +1730,10 @@ public final class BussFlowExternalOuterClass {
if (obj == this) {
return true;
}
if (!(obj instanceof com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal)) {
if (!(obj instanceof com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal)) {
return super.equals(obj);
}
com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal other = (com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal) obj;
com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal other = (com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal) obj;
if (getTableId()
!= other.getTableId()) return false;
@ -1884,69 +1884,69 @@ public final class BussFlowExternalOuterClass {
return hash;
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(byte[] data)
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseDelimitedFrom(java.io.InputStream input)
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseDelimitedFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -1959,7 +1959,7 @@ public final class BussFlowExternalOuterClass {
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal prototype) {
public static Builder newBuilder(com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
@ -1980,21 +1980,21 @@ public final class BussFlowExternalOuterClass {
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:dataflow.BussFlowExternal)
com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternalOrBuilder {
com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternalOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return com.yuandian.dataflow.proto.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_descriptor;
return com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return com.yuandian.dataflow.proto.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_fieldAccessorTable
return com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_fieldAccessorTable
.ensureFieldAccessorsInitialized(
com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal.class, com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal.Builder.class);
com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal.class, com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal.Builder.class);
}
// Construct using com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal.newBuilder()
// Construct using com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@ -2078,17 +2078,17 @@ public final class BussFlowExternalOuterClass {
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return com.yuandian.dataflow.proto.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_descriptor;
return com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.internal_static_dataflow_BussFlowExternal_descriptor;
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal.getDefaultInstance();
public com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal getDefaultInstanceForType() {
return com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal.getDefaultInstance();
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal build() {
com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal result = buildPartial();
public com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal build() {
com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
@ -2096,8 +2096,8 @@ public final class BussFlowExternalOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal buildPartial() {
com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal result = new com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal(this);
public com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal buildPartial() {
com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal result = new com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal(this);
result.tableId_ = tableId_;
result.id_ = id_;
result.probeIf_ = probeIf_;
@ -2166,16 +2166,16 @@ public final class BussFlowExternalOuterClass {
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal) {
return mergeFrom((com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal)other);
if (other instanceof com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal) {
return mergeFrom((com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal other) {
if (other == com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal.getDefaultInstance()) return this;
public Builder mergeFrom(com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal other) {
if (other == com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal.getDefaultInstance()) return this;
if (other.getTableId() != 0) {
setTableId(other.getTableId());
}
@ -2294,11 +2294,11 @@ public final class BussFlowExternalOuterClass {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal parsedMessage = null;
com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal) e.getUnfinishedMessage();
parsedMessage = (com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
@ -4227,12 +4227,12 @@ public final class BussFlowExternalOuterClass {
}
// @@protoc_insertion_point(class_scope:dataflow.BussFlowExternal)
private static final com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal DEFAULT_INSTANCE;
private static final com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal();
DEFAULT_INSTANCE = new com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal();
}
public static com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal getDefaultInstance() {
public static com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@ -4257,7 +4257,7 @@ public final class BussFlowExternalOuterClass {
}
@java.lang.Override
public com.yuandian.dataflow.proto.BussFlowExternalOuterClass.BussFlowExternal getDefaultInstanceForType() {
public com.yuandian.dataflow.proto.msgtype.BussFlowExternalOuterClass.BussFlowExternal getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@ -4294,9 +4294,9 @@ public final class BussFlowExternalOuterClass {
"(\005\022\017\n\007browser\030\031 \001(\t\022\034\n\024business_detail_m" +
"esg\030\032 \001(\t\022\023\n\013insert_time\030\033 \001(\003\022\034\n\024busine" +
"ss_involve_msg\030\034 \001(\t\022\025\n\ris_uncomplete\030\035 " +
"\001(\005\022\021\n\ttime_flag\030\036 \001(\003B2\n\033com.yuandian.d" +
"ataflow.protoZ\023../grpc-gen;grpcgenb\006prot" +
"o3"
"\001(\005\022\021\n\ttime_flag\030\036 \001(\003B<\n#com.yuandian.d" +
"ataflow.proto.msgtypeP\000Z\023../grpc-gen;grp" +
"cgenb\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@ -18,6 +18,8 @@ import com.alipay.sofa.jraft.storage.snapshot.SnapshotReader;
import com.alipay.sofa.jraft.storage.snapshot.SnapshotWriter;
import com.alipay.sofa.jraft.util.Utils;
import lombok.extern.slf4j.Slf4j;
/**
* Counter state machine.
*
@ -25,9 +27,10 @@ import com.alipay.sofa.jraft.util.Utils;
*
* 2018-Apr-09 4:52:31 PM
*/
@Slf4j
public class StateMachine extends StateMachineAdapter {
private static final Logger LOG = LoggerFactory.getLogger(StateMachine.class);
// private static final Logger LOG = LoggerFactory.getLogger(StateMachine.class);
/**
* Counter value
@ -57,11 +60,11 @@ public class StateMachine extends StateMachineAdapter {
// This task is applied by this node, get value from closure to avoid additional
// parsing.
LOG.error("done:%1$s",iter.getData().toString());
log.error("done:%1$s",iter.getData().toString());
} else {
// Have to parse FetchAddRequest from this user log.
LOG.error("null:%1$s",iter.getData().toString());
log.error("null:%1$s",iter.getData().toString());
}
iter.next();
@ -75,7 +78,7 @@ public class StateMachine extends StateMachineAdapter {
@Override
public void onError(final RaftException e) {
LOG.error("Raft error: {}", e, e);
log.error("Raft error: {}", e, e);
}
@Override

View File

@ -1,14 +1,15 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";
package dataflow;
message ApmBaseDataFlow {
int32 table_id = 1;
int32 probe_if = 2;

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -12,7 +12,7 @@ package dataflow;
message Response {
int32 code = 1;
int32 message = 2;
string message = 2;
repeated google.protobuf.Any packets = 4;
}

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

View File

@ -1,6 +1,7 @@
syntax = "proto3";
option java_package = "com.yuandian.dataflow.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";