Mercurial > lbo > hg > clusterrpc-java
changeset 0:ed6ea43af3f4
Initial commit
| author | Lewin Bormann <lbo@spheniscida.de> |
|---|---|
| date | Fri, 23 Sep 2016 16:23:46 +0200 |
| parents | |
| children | 4f815715fcbd |
| files | .hgignore pom.xml rpc.proto src/main/java/net/borgac/clusterrpc/client/Client.java src/main/java/net/borgac/clusterrpc/proto/Rpc.java src/test/java/net/borgac/clusterrpc/ClusterRPCRootTest.java src/test/java/net/borgac/clusterrpc/TestDependencies.java |
| diffstat | 7 files changed, 4429 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/.hgignore Fri Sep 23 16:23:46 2016 +0200 @@ -0,0 +1,4 @@ +nbproject +nb-configuration.xml +target/ +.*class$
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/pom.xml Fri Sep 23 16:23:46 2016 +0200 @@ -0,0 +1,43 @@ +<?xml version="1.0" encoding="UTF-8"?> +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> + <modelVersion>4.0.0</modelVersion> + <groupId>net.borgac</groupId> + <artifactId>clusterrpc</artifactId> + <version>0.1-SNAPSHOT</version> + <packaging>jar</packaging> + <build><!-- + <plugins> + <plugin> + <artifactId>maven-assembly-plugin</artifactId> + <configuration> + <descriptorRefs> + <descriptorRef>jar-with-dependencies</descriptorRef> + </descriptorRefs> + </configuration> + </plugin> + </plugins> + --> + </build> + <dependencies> + <dependency> + <groupId>org.zeromq</groupId> + <artifactId>jeromq</artifactId> + <version>0.3.5</version> + </dependency> + <dependency> + <groupId>com.google.protobuf</groupId> + <artifactId>protobuf-java</artifactId> + <version>3.0.0</version> + </dependency> + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <version>4.12</version> + </dependency> + </dependencies> + <properties> + <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> + <maven.compiler.source>1.8</maven.compiler.source> + <maven.compiler.target>1.8</maven.compiler.target> + </properties> +</project> \ No newline at end of file
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/rpc.proto Fri Sep 23 16:23:46 2016 +0200 @@ -0,0 +1,63 @@ +package proto; + +message TraceInfo { + required int64 received_time = 1; + required int64 replied_time = 2; + optional string machine_name = 3; + optional string endpoint_name = 4; + optional string error_message = 5; + optional string redirect = 6; + repeated TraceInfo child_calls = 7; +} + +message RPCRequest { + // A unique-ish ID for this RPC + optional string rpc_id = 1; + required string srvc = 2; + required string procedure = 3; + required bytes data = 4; + optional int64 deadline = 5; // UNIX µs timestamp after which we don't want to have an answer anymore + // (i.e. the server doesn't need to bother sending one) + optional string caller_id = 6; + optional bool want_trace = 7; +} + +message RPCResponse { + optional string rpc_id = 1; + optional bytes response_data = 2; + + enum Status { + // Default value + STATUS_UNKNOWN = 0; + // a.k.a. 200 + STATUS_OK = 1; + // service/endpoint not found (a.k.a. 404) + STATUS_NOT_FOUND = 2; + // The handler returned an error; see the error_message for a description (500). response_data may have content + STATUS_NOT_OK = 4; + // An error happened in the clusterrpc implementation (500) + STATUS_SERVER_ERROR = 5; + // The requested timeout has been expired + STATUS_TIMEOUT = 6; + // The server is overloaded (503) + STATUS_OVERLOADED_RETRY = 7; + // We couldn't even send the request (PB serialization error, ...) + STATUS_CLIENT_REQUEST_ERROR = 9; + // We couldn't send the request because of network/socket issues. + STATUS_CLIENT_NETWORK_ERROR = 10; + // Client function called in a wrong way (e.g. different lengt of raddrs + // and rports slices to NewClientRR()) + STATUS_CLIENT_CALLED_WRONG = 11; + // Timeout somewhere in the call stack + STATUS_MISSED_DEADLINE = 12; + // Loadshedding mode, not accepting requests right now + STATUS_LOADSHED = 13; + // Health check failed + STATUS_UNHEALTHY = 14; + } + + required Status response_status = 3; + optional string error_message = 4; + optional TraceInfo traceinfo = 5; +} +
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/net/borgac/clusterrpc/client/Client.java Fri Sep 23 16:23:46 2016 +0200 @@ -0,0 +1,10 @@ +package net.borgac.clusterrpc.client; + +/** + * @brief The entry point for all client requests. + * + * @author lbo + */ +public class Client { + +}
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/net/borgac/clusterrpc/proto/Rpc.java Fri Sep 23 16:23:46 2016 +0200 @@ -0,0 +1,4214 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: rpc.proto + +package proto; + +public final class Rpc { + private Rpc() {} + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistry registry) { + } + public interface TraceInfoOrBuilder extends + // @@protoc_insertion_point(interface_extends:proto.TraceInfo) + com.google.protobuf.MessageOrBuilder { + + /** + * <code>required int64 received_time = 1;</code> + */ + boolean hasReceivedTime(); + /** + * <code>required int64 received_time = 1;</code> + */ + long getReceivedTime(); + + /** + * <code>required int64 replied_time = 2;</code> + */ + boolean hasRepliedTime(); + /** + * <code>required int64 replied_time = 2;</code> + */ + long getRepliedTime(); + + /** + * <code>optional string machine_name = 3;</code> + */ + boolean hasMachineName(); + /** + * <code>optional string machine_name = 3;</code> + */ + java.lang.String getMachineName(); + /** + * <code>optional string machine_name = 3;</code> + */ + com.google.protobuf.ByteString + getMachineNameBytes(); + + /** + * <code>optional string endpoint_name = 4;</code> + */ + boolean hasEndpointName(); + /** + * <code>optional string endpoint_name = 4;</code> + */ + java.lang.String getEndpointName(); + /** + * <code>optional string endpoint_name = 4;</code> + */ + com.google.protobuf.ByteString + getEndpointNameBytes(); + + /** + * <code>optional string error_message = 5;</code> + */ + boolean hasErrorMessage(); + /** + * <code>optional string error_message = 5;</code> + */ + java.lang.String getErrorMessage(); + /** + * <code>optional string error_message = 5;</code> + */ + com.google.protobuf.ByteString + getErrorMessageBytes(); + + /** + * <code>optional string redirect = 6;</code> + */ + boolean hasRedirect(); + /** + * <code>optional string redirect = 6;</code> + */ + java.lang.String getRedirect(); + /** + * <code>optional string redirect = 6;</code> + */ + com.google.protobuf.ByteString + getRedirectBytes(); + + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + java.util.List<proto.Rpc.TraceInfo> + getChildCallsList(); + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + proto.Rpc.TraceInfo getChildCalls(int index); + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + int getChildCallsCount(); + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + java.util.List<? extends proto.Rpc.TraceInfoOrBuilder> + getChildCallsOrBuilderList(); + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + proto.Rpc.TraceInfoOrBuilder getChildCallsOrBuilder( + int index); + } + /** + * Protobuf type {@code proto.TraceInfo} + */ + public static final class TraceInfo extends + com.google.protobuf.GeneratedMessage implements + // @@protoc_insertion_point(message_implements:proto.TraceInfo) + TraceInfoOrBuilder { + // Use TraceInfo.newBuilder() to construct. + private TraceInfo(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private TraceInfo(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final TraceInfo defaultInstance; + public static TraceInfo getDefaultInstance() { + return defaultInstance; + } + + public TraceInfo getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private TraceInfo( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 8: { + bitField0_ |= 0x00000001; + receivedTime_ = input.readInt64(); + break; + } + case 16: { + bitField0_ |= 0x00000002; + repliedTime_ = input.readInt64(); + break; + } + case 26: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000004; + machineName_ = bs; + break; + } + case 34: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000008; + endpointName_ = bs; + break; + } + case 42: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000010; + errorMessage_ = bs; + break; + } + case 50: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000020; + redirect_ = bs; + break; + } + case 58: { + if (!((mutable_bitField0_ & 0x00000040) == 0x00000040)) { + childCalls_ = new java.util.ArrayList<proto.Rpc.TraceInfo>(); + mutable_bitField0_ |= 0x00000040; + } + childCalls_.add(input.readMessage(proto.Rpc.TraceInfo.PARSER, extensionRegistry)); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + if (((mutable_bitField0_ & 0x00000040) == 0x00000040)) { + childCalls_ = java.util.Collections.unmodifiableList(childCalls_); + } + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return proto.Rpc.internal_static_proto_TraceInfo_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return proto.Rpc.internal_static_proto_TraceInfo_fieldAccessorTable + .ensureFieldAccessorsInitialized( + proto.Rpc.TraceInfo.class, proto.Rpc.TraceInfo.Builder.class); + } + + public static com.google.protobuf.Parser<TraceInfo> PARSER = + new com.google.protobuf.AbstractParser<TraceInfo>() { + public TraceInfo parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new TraceInfo(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<TraceInfo> getParserForType() { + return PARSER; + } + + private int bitField0_; + public static final int RECEIVED_TIME_FIELD_NUMBER = 1; + private long receivedTime_; + /** + * <code>required int64 received_time = 1;</code> + */ + public boolean hasReceivedTime() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required int64 received_time = 1;</code> + */ + public long getReceivedTime() { + return receivedTime_; + } + + public static final int REPLIED_TIME_FIELD_NUMBER = 2; + private long repliedTime_; + /** + * <code>required int64 replied_time = 2;</code> + */ + public boolean hasRepliedTime() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required int64 replied_time = 2;</code> + */ + public long getRepliedTime() { + return repliedTime_; + } + + public static final int MACHINE_NAME_FIELD_NUMBER = 3; + private java.lang.Object machineName_; + /** + * <code>optional string machine_name = 3;</code> + */ + public boolean hasMachineName() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>optional string machine_name = 3;</code> + */ + public java.lang.String getMachineName() { + java.lang.Object ref = machineName_; + 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(); + if (bs.isValidUtf8()) { + machineName_ = s; + } + return s; + } + } + /** + * <code>optional string machine_name = 3;</code> + */ + public com.google.protobuf.ByteString + getMachineNameBytes() { + java.lang.Object ref = machineName_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + machineName_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int ENDPOINT_NAME_FIELD_NUMBER = 4; + private java.lang.Object endpointName_; + /** + * <code>optional string endpoint_name = 4;</code> + */ + public boolean hasEndpointName() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <code>optional string endpoint_name = 4;</code> + */ + public java.lang.String getEndpointName() { + java.lang.Object ref = endpointName_; + 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(); + if (bs.isValidUtf8()) { + endpointName_ = s; + } + return s; + } + } + /** + * <code>optional string endpoint_name = 4;</code> + */ + public com.google.protobuf.ByteString + getEndpointNameBytes() { + java.lang.Object ref = endpointName_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + endpointName_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int ERROR_MESSAGE_FIELD_NUMBER = 5; + private java.lang.Object errorMessage_; + /** + * <code>optional string error_message = 5;</code> + */ + public boolean hasErrorMessage() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional string error_message = 5;</code> + */ + public java.lang.String getErrorMessage() { + java.lang.Object ref = errorMessage_; + 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(); + if (bs.isValidUtf8()) { + errorMessage_ = s; + } + return s; + } + } + /** + * <code>optional string error_message = 5;</code> + */ + public com.google.protobuf.ByteString + getErrorMessageBytes() { + java.lang.Object ref = errorMessage_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + errorMessage_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int REDIRECT_FIELD_NUMBER = 6; + private java.lang.Object redirect_; + /** + * <code>optional string redirect = 6;</code> + */ + public boolean hasRedirect() { + return ((bitField0_ & 0x00000020) == 0x00000020); + } + /** + * <code>optional string redirect = 6;</code> + */ + public java.lang.String getRedirect() { + java.lang.Object ref = redirect_; + 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(); + if (bs.isValidUtf8()) { + redirect_ = s; + } + return s; + } + } + /** + * <code>optional string redirect = 6;</code> + */ + public com.google.protobuf.ByteString + getRedirectBytes() { + java.lang.Object ref = redirect_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + redirect_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int CHILD_CALLS_FIELD_NUMBER = 7; + private java.util.List<proto.Rpc.TraceInfo> childCalls_; + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public java.util.List<proto.Rpc.TraceInfo> getChildCallsList() { + return childCalls_; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public java.util.List<? extends proto.Rpc.TraceInfoOrBuilder> + getChildCallsOrBuilderList() { + return childCalls_; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public int getChildCallsCount() { + return childCalls_.size(); + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public proto.Rpc.TraceInfo getChildCalls(int index) { + return childCalls_.get(index); + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public proto.Rpc.TraceInfoOrBuilder getChildCallsOrBuilder( + int index) { + return childCalls_.get(index); + } + + private void initFields() { + receivedTime_ = 0L; + repliedTime_ = 0L; + machineName_ = ""; + endpointName_ = ""; + errorMessage_ = ""; + redirect_ = ""; + childCalls_ = java.util.Collections.emptyList(); + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + if (!hasReceivedTime()) { + memoizedIsInitialized = 0; + return false; + } + if (!hasRepliedTime()) { + memoizedIsInitialized = 0; + return false; + } + for (int i = 0; i < getChildCallsCount(); i++) { + if (!getChildCalls(i).isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeInt64(1, receivedTime_); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeInt64(2, repliedTime_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + output.writeBytes(3, getMachineNameBytes()); + } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + output.writeBytes(4, getEndpointNameBytes()); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + output.writeBytes(5, getErrorMessageBytes()); + } + if (((bitField0_ & 0x00000020) == 0x00000020)) { + output.writeBytes(6, getRedirectBytes()); + } + for (int i = 0; i < childCalls_.size(); i++) { + output.writeMessage(7, childCalls_.get(i)); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeInt64Size(1, receivedTime_); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += com.google.protobuf.CodedOutputStream + .computeInt64Size(2, repliedTime_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(3, getMachineNameBytes()); + } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(4, getEndpointNameBytes()); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(5, getErrorMessageBytes()); + } + if (((bitField0_ & 0x00000020) == 0x00000020)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(6, getRedirectBytes()); + } + for (int i = 0; i < childCalls_.size(); i++) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(7, childCalls_.get(i)); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static proto.Rpc.TraceInfo parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static proto.Rpc.TraceInfo parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static proto.Rpc.TraceInfo parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static proto.Rpc.TraceInfo parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static proto.Rpc.TraceInfo parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static proto.Rpc.TraceInfo parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static proto.Rpc.TraceInfo parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static proto.Rpc.TraceInfo parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static proto.Rpc.TraceInfo parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static proto.Rpc.TraceInfo parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(proto.Rpc.TraceInfo prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code proto.TraceInfo} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> implements + // @@protoc_insertion_point(builder_implements:proto.TraceInfo) + proto.Rpc.TraceInfoOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return proto.Rpc.internal_static_proto_TraceInfo_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return proto.Rpc.internal_static_proto_TraceInfo_fieldAccessorTable + .ensureFieldAccessorsInitialized( + proto.Rpc.TraceInfo.class, proto.Rpc.TraceInfo.Builder.class); + } + + // Construct using proto.Rpc.TraceInfo.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + getChildCallsFieldBuilder(); + } + } + private static Builder create() { + return new Builder(); + } + + public Builder clear() { + super.clear(); + receivedTime_ = 0L; + bitField0_ = (bitField0_ & ~0x00000001); + repliedTime_ = 0L; + bitField0_ = (bitField0_ & ~0x00000002); + machineName_ = ""; + bitField0_ = (bitField0_ & ~0x00000004); + endpointName_ = ""; + bitField0_ = (bitField0_ & ~0x00000008); + errorMessage_ = ""; + bitField0_ = (bitField0_ & ~0x00000010); + redirect_ = ""; + bitField0_ = (bitField0_ & ~0x00000020); + if (childCallsBuilder_ == null) { + childCalls_ = java.util.Collections.emptyList(); + bitField0_ = (bitField0_ & ~0x00000040); + } else { + childCallsBuilder_.clear(); + } + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return proto.Rpc.internal_static_proto_TraceInfo_descriptor; + } + + public proto.Rpc.TraceInfo getDefaultInstanceForType() { + return proto.Rpc.TraceInfo.getDefaultInstance(); + } + + public proto.Rpc.TraceInfo build() { + proto.Rpc.TraceInfo result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public proto.Rpc.TraceInfo buildPartial() { + proto.Rpc.TraceInfo result = new proto.Rpc.TraceInfo(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.receivedTime_ = receivedTime_; + if (((from_bitField0_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x00000002; + } + result.repliedTime_ = repliedTime_; + if (((from_bitField0_ & 0x00000004) == 0x00000004)) { + to_bitField0_ |= 0x00000004; + } + result.machineName_ = machineName_; + if (((from_bitField0_ & 0x00000008) == 0x00000008)) { + to_bitField0_ |= 0x00000008; + } + result.endpointName_ = endpointName_; + if (((from_bitField0_ & 0x00000010) == 0x00000010)) { + to_bitField0_ |= 0x00000010; + } + result.errorMessage_ = errorMessage_; + if (((from_bitField0_ & 0x00000020) == 0x00000020)) { + to_bitField0_ |= 0x00000020; + } + result.redirect_ = redirect_; + if (childCallsBuilder_ == null) { + if (((bitField0_ & 0x00000040) == 0x00000040)) { + childCalls_ = java.util.Collections.unmodifiableList(childCalls_); + bitField0_ = (bitField0_ & ~0x00000040); + } + result.childCalls_ = childCalls_; + } else { + result.childCalls_ = childCallsBuilder_.build(); + } + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof proto.Rpc.TraceInfo) { + return mergeFrom((proto.Rpc.TraceInfo)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(proto.Rpc.TraceInfo other) { + if (other == proto.Rpc.TraceInfo.getDefaultInstance()) return this; + if (other.hasReceivedTime()) { + setReceivedTime(other.getReceivedTime()); + } + if (other.hasRepliedTime()) { + setRepliedTime(other.getRepliedTime()); + } + if (other.hasMachineName()) { + bitField0_ |= 0x00000004; + machineName_ = other.machineName_; + onChanged(); + } + if (other.hasEndpointName()) { + bitField0_ |= 0x00000008; + endpointName_ = other.endpointName_; + onChanged(); + } + if (other.hasErrorMessage()) { + bitField0_ |= 0x00000010; + errorMessage_ = other.errorMessage_; + onChanged(); + } + if (other.hasRedirect()) { + bitField0_ |= 0x00000020; + redirect_ = other.redirect_; + onChanged(); + } + if (childCallsBuilder_ == null) { + if (!other.childCalls_.isEmpty()) { + if (childCalls_.isEmpty()) { + childCalls_ = other.childCalls_; + bitField0_ = (bitField0_ & ~0x00000040); + } else { + ensureChildCallsIsMutable(); + childCalls_.addAll(other.childCalls_); + } + onChanged(); + } + } else { + if (!other.childCalls_.isEmpty()) { + if (childCallsBuilder_.isEmpty()) { + childCallsBuilder_.dispose(); + childCallsBuilder_ = null; + childCalls_ = other.childCalls_; + bitField0_ = (bitField0_ & ~0x00000040); + childCallsBuilder_ = + com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? + getChildCallsFieldBuilder() : null; + } else { + childCallsBuilder_.addAllMessages(other.childCalls_); + } + } + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasReceivedTime()) { + + return false; + } + if (!hasRepliedTime()) { + + return false; + } + for (int i = 0; i < getChildCallsCount(); i++) { + if (!getChildCalls(i).isInitialized()) { + + return false; + } + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + proto.Rpc.TraceInfo parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (proto.Rpc.TraceInfo) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + private long receivedTime_ ; + /** + * <code>required int64 received_time = 1;</code> + */ + public boolean hasReceivedTime() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required int64 received_time = 1;</code> + */ + public long getReceivedTime() { + return receivedTime_; + } + /** + * <code>required int64 received_time = 1;</code> + */ + public Builder setReceivedTime(long value) { + bitField0_ |= 0x00000001; + receivedTime_ = value; + onChanged(); + return this; + } + /** + * <code>required int64 received_time = 1;</code> + */ + public Builder clearReceivedTime() { + bitField0_ = (bitField0_ & ~0x00000001); + receivedTime_ = 0L; + onChanged(); + return this; + } + + private long repliedTime_ ; + /** + * <code>required int64 replied_time = 2;</code> + */ + public boolean hasRepliedTime() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required int64 replied_time = 2;</code> + */ + public long getRepliedTime() { + return repliedTime_; + } + /** + * <code>required int64 replied_time = 2;</code> + */ + public Builder setRepliedTime(long value) { + bitField0_ |= 0x00000002; + repliedTime_ = value; + onChanged(); + return this; + } + /** + * <code>required int64 replied_time = 2;</code> + */ + public Builder clearRepliedTime() { + bitField0_ = (bitField0_ & ~0x00000002); + repliedTime_ = 0L; + onChanged(); + return this; + } + + private java.lang.Object machineName_ = ""; + /** + * <code>optional string machine_name = 3;</code> + */ + public boolean hasMachineName() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>optional string machine_name = 3;</code> + */ + public java.lang.String getMachineName() { + java.lang.Object ref = machineName_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + machineName_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string machine_name = 3;</code> + */ + public com.google.protobuf.ByteString + getMachineNameBytes() { + java.lang.Object ref = machineName_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + machineName_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string machine_name = 3;</code> + */ + public Builder setMachineName( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000004; + machineName_ = value; + onChanged(); + return this; + } + /** + * <code>optional string machine_name = 3;</code> + */ + public Builder clearMachineName() { + bitField0_ = (bitField0_ & ~0x00000004); + machineName_ = getDefaultInstance().getMachineName(); + onChanged(); + return this; + } + /** + * <code>optional string machine_name = 3;</code> + */ + public Builder setMachineNameBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000004; + machineName_ = value; + onChanged(); + return this; + } + + private java.lang.Object endpointName_ = ""; + /** + * <code>optional string endpoint_name = 4;</code> + */ + public boolean hasEndpointName() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <code>optional string endpoint_name = 4;</code> + */ + public java.lang.String getEndpointName() { + java.lang.Object ref = endpointName_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + endpointName_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string endpoint_name = 4;</code> + */ + public com.google.protobuf.ByteString + getEndpointNameBytes() { + java.lang.Object ref = endpointName_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + endpointName_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string endpoint_name = 4;</code> + */ + public Builder setEndpointName( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000008; + endpointName_ = value; + onChanged(); + return this; + } + /** + * <code>optional string endpoint_name = 4;</code> + */ + public Builder clearEndpointName() { + bitField0_ = (bitField0_ & ~0x00000008); + endpointName_ = getDefaultInstance().getEndpointName(); + onChanged(); + return this; + } + /** + * <code>optional string endpoint_name = 4;</code> + */ + public Builder setEndpointNameBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000008; + endpointName_ = value; + onChanged(); + return this; + } + + private java.lang.Object errorMessage_ = ""; + /** + * <code>optional string error_message = 5;</code> + */ + public boolean hasErrorMessage() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional string error_message = 5;</code> + */ + public java.lang.String getErrorMessage() { + java.lang.Object ref = errorMessage_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + errorMessage_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string error_message = 5;</code> + */ + public com.google.protobuf.ByteString + getErrorMessageBytes() { + java.lang.Object ref = errorMessage_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + errorMessage_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string error_message = 5;</code> + */ + public Builder setErrorMessage( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000010; + errorMessage_ = value; + onChanged(); + return this; + } + /** + * <code>optional string error_message = 5;</code> + */ + public Builder clearErrorMessage() { + bitField0_ = (bitField0_ & ~0x00000010); + errorMessage_ = getDefaultInstance().getErrorMessage(); + onChanged(); + return this; + } + /** + * <code>optional string error_message = 5;</code> + */ + public Builder setErrorMessageBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000010; + errorMessage_ = value; + onChanged(); + return this; + } + + private java.lang.Object redirect_ = ""; + /** + * <code>optional string redirect = 6;</code> + */ + public boolean hasRedirect() { + return ((bitField0_ & 0x00000020) == 0x00000020); + } + /** + * <code>optional string redirect = 6;</code> + */ + public java.lang.String getRedirect() { + java.lang.Object ref = redirect_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + redirect_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string redirect = 6;</code> + */ + public com.google.protobuf.ByteString + getRedirectBytes() { + java.lang.Object ref = redirect_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + redirect_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string redirect = 6;</code> + */ + public Builder setRedirect( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000020; + redirect_ = value; + onChanged(); + return this; + } + /** + * <code>optional string redirect = 6;</code> + */ + public Builder clearRedirect() { + bitField0_ = (bitField0_ & ~0x00000020); + redirect_ = getDefaultInstance().getRedirect(); + onChanged(); + return this; + } + /** + * <code>optional string redirect = 6;</code> + */ + public Builder setRedirectBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000020; + redirect_ = value; + onChanged(); + return this; + } + + private java.util.List<proto.Rpc.TraceInfo> childCalls_ = + java.util.Collections.emptyList(); + private void ensureChildCallsIsMutable() { + if (!((bitField0_ & 0x00000040) == 0x00000040)) { + childCalls_ = new java.util.ArrayList<proto.Rpc.TraceInfo>(childCalls_); + bitField0_ |= 0x00000040; + } + } + + private com.google.protobuf.RepeatedFieldBuilder< + proto.Rpc.TraceInfo, proto.Rpc.TraceInfo.Builder, proto.Rpc.TraceInfoOrBuilder> childCallsBuilder_; + + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public java.util.List<proto.Rpc.TraceInfo> getChildCallsList() { + if (childCallsBuilder_ == null) { + return java.util.Collections.unmodifiableList(childCalls_); + } else { + return childCallsBuilder_.getMessageList(); + } + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public int getChildCallsCount() { + if (childCallsBuilder_ == null) { + return childCalls_.size(); + } else { + return childCallsBuilder_.getCount(); + } + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public proto.Rpc.TraceInfo getChildCalls(int index) { + if (childCallsBuilder_ == null) { + return childCalls_.get(index); + } else { + return childCallsBuilder_.getMessage(index); + } + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder setChildCalls( + int index, proto.Rpc.TraceInfo value) { + if (childCallsBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + ensureChildCallsIsMutable(); + childCalls_.set(index, value); + onChanged(); + } else { + childCallsBuilder_.setMessage(index, value); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder setChildCalls( + int index, proto.Rpc.TraceInfo.Builder builderForValue) { + if (childCallsBuilder_ == null) { + ensureChildCallsIsMutable(); + childCalls_.set(index, builderForValue.build()); + onChanged(); + } else { + childCallsBuilder_.setMessage(index, builderForValue.build()); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder addChildCalls(proto.Rpc.TraceInfo value) { + if (childCallsBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + ensureChildCallsIsMutable(); + childCalls_.add(value); + onChanged(); + } else { + childCallsBuilder_.addMessage(value); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder addChildCalls( + int index, proto.Rpc.TraceInfo value) { + if (childCallsBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + ensureChildCallsIsMutable(); + childCalls_.add(index, value); + onChanged(); + } else { + childCallsBuilder_.addMessage(index, value); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder addChildCalls( + proto.Rpc.TraceInfo.Builder builderForValue) { + if (childCallsBuilder_ == null) { + ensureChildCallsIsMutable(); + childCalls_.add(builderForValue.build()); + onChanged(); + } else { + childCallsBuilder_.addMessage(builderForValue.build()); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder addChildCalls( + int index, proto.Rpc.TraceInfo.Builder builderForValue) { + if (childCallsBuilder_ == null) { + ensureChildCallsIsMutable(); + childCalls_.add(index, builderForValue.build()); + onChanged(); + } else { + childCallsBuilder_.addMessage(index, builderForValue.build()); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder addAllChildCalls( + java.lang.Iterable<? extends proto.Rpc.TraceInfo> values) { + if (childCallsBuilder_ == null) { + ensureChildCallsIsMutable(); + com.google.protobuf.AbstractMessageLite.Builder.addAll( + values, childCalls_); + onChanged(); + } else { + childCallsBuilder_.addAllMessages(values); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder clearChildCalls() { + if (childCallsBuilder_ == null) { + childCalls_ = java.util.Collections.emptyList(); + bitField0_ = (bitField0_ & ~0x00000040); + onChanged(); + } else { + childCallsBuilder_.clear(); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public Builder removeChildCalls(int index) { + if (childCallsBuilder_ == null) { + ensureChildCallsIsMutable(); + childCalls_.remove(index); + onChanged(); + } else { + childCallsBuilder_.remove(index); + } + return this; + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public proto.Rpc.TraceInfo.Builder getChildCallsBuilder( + int index) { + return getChildCallsFieldBuilder().getBuilder(index); + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public proto.Rpc.TraceInfoOrBuilder getChildCallsOrBuilder( + int index) { + if (childCallsBuilder_ == null) { + return childCalls_.get(index); } else { + return childCallsBuilder_.getMessageOrBuilder(index); + } + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public java.util.List<? extends proto.Rpc.TraceInfoOrBuilder> + getChildCallsOrBuilderList() { + if (childCallsBuilder_ != null) { + return childCallsBuilder_.getMessageOrBuilderList(); + } else { + return java.util.Collections.unmodifiableList(childCalls_); + } + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public proto.Rpc.TraceInfo.Builder addChildCallsBuilder() { + return getChildCallsFieldBuilder().addBuilder( + proto.Rpc.TraceInfo.getDefaultInstance()); + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public proto.Rpc.TraceInfo.Builder addChildCallsBuilder( + int index) { + return getChildCallsFieldBuilder().addBuilder( + index, proto.Rpc.TraceInfo.getDefaultInstance()); + } + /** + * <code>repeated .proto.TraceInfo child_calls = 7;</code> + */ + public java.util.List<proto.Rpc.TraceInfo.Builder> + getChildCallsBuilderList() { + return getChildCallsFieldBuilder().getBuilderList(); + } + private com.google.protobuf.RepeatedFieldBuilder< + proto.Rpc.TraceInfo, proto.Rpc.TraceInfo.Builder, proto.Rpc.TraceInfoOrBuilder> + getChildCallsFieldBuilder() { + if (childCallsBuilder_ == null) { + childCallsBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< + proto.Rpc.TraceInfo, proto.Rpc.TraceInfo.Builder, proto.Rpc.TraceInfoOrBuilder>( + childCalls_, + ((bitField0_ & 0x00000040) == 0x00000040), + getParentForChildren(), + isClean()); + childCalls_ = null; + } + return childCallsBuilder_; + } + + // @@protoc_insertion_point(builder_scope:proto.TraceInfo) + } + + static { + defaultInstance = new TraceInfo(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:proto.TraceInfo) + } + + public interface RPCRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:proto.RPCRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + boolean hasRpcId(); + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + java.lang.String getRpcId(); + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + com.google.protobuf.ByteString + getRpcIdBytes(); + + /** + * <code>required string srvc = 2;</code> + */ + boolean hasSrvc(); + /** + * <code>required string srvc = 2;</code> + */ + java.lang.String getSrvc(); + /** + * <code>required string srvc = 2;</code> + */ + com.google.protobuf.ByteString + getSrvcBytes(); + + /** + * <code>required string procedure = 3;</code> + */ + boolean hasProcedure(); + /** + * <code>required string procedure = 3;</code> + */ + java.lang.String getProcedure(); + /** + * <code>required string procedure = 3;</code> + */ + com.google.protobuf.ByteString + getProcedureBytes(); + + /** + * <code>required bytes data = 4;</code> + */ + boolean hasData(); + /** + * <code>required bytes data = 4;</code> + */ + com.google.protobuf.ByteString getData(); + + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + boolean hasDeadline(); + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + long getDeadline(); + + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + boolean hasCallerId(); + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + java.lang.String getCallerId(); + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + com.google.protobuf.ByteString + getCallerIdBytes(); + + /** + * <code>optional bool want_trace = 7;</code> + */ + boolean hasWantTrace(); + /** + * <code>optional bool want_trace = 7;</code> + */ + boolean getWantTrace(); + } + /** + * Protobuf type {@code proto.RPCRequest} + */ + public static final class RPCRequest extends + com.google.protobuf.GeneratedMessage implements + // @@protoc_insertion_point(message_implements:proto.RPCRequest) + RPCRequestOrBuilder { + // Use RPCRequest.newBuilder() to construct. + private RPCRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private RPCRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final RPCRequest defaultInstance; + public static RPCRequest getDefaultInstance() { + return defaultInstance; + } + + public RPCRequest getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private RPCRequest( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000001; + rpcId_ = bs; + break; + } + case 18: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000002; + srvc_ = bs; + break; + } + case 26: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000004; + procedure_ = bs; + break; + } + case 34: { + bitField0_ |= 0x00000008; + data_ = input.readBytes(); + break; + } + case 40: { + bitField0_ |= 0x00000010; + deadline_ = input.readInt64(); + break; + } + case 50: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000020; + callerId_ = bs; + break; + } + case 56: { + bitField0_ |= 0x00000040; + wantTrace_ = input.readBool(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return proto.Rpc.internal_static_proto_RPCRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return proto.Rpc.internal_static_proto_RPCRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + proto.Rpc.RPCRequest.class, proto.Rpc.RPCRequest.Builder.class); + } + + public static com.google.protobuf.Parser<RPCRequest> PARSER = + new com.google.protobuf.AbstractParser<RPCRequest>() { + public RPCRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new RPCRequest(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<RPCRequest> getParserForType() { + return PARSER; + } + + private int bitField0_; + public static final int RPC_ID_FIELD_NUMBER = 1; + private java.lang.Object rpcId_; + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public boolean hasRpcId() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public java.lang.String getRpcId() { + java.lang.Object ref = rpcId_; + 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(); + if (bs.isValidUtf8()) { + rpcId_ = s; + } + return s; + } + } + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public com.google.protobuf.ByteString + getRpcIdBytes() { + java.lang.Object ref = rpcId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + rpcId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int SRVC_FIELD_NUMBER = 2; + private java.lang.Object srvc_; + /** + * <code>required string srvc = 2;</code> + */ + public boolean hasSrvc() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required string srvc = 2;</code> + */ + public java.lang.String getSrvc() { + java.lang.Object ref = srvc_; + 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(); + if (bs.isValidUtf8()) { + srvc_ = s; + } + return s; + } + } + /** + * <code>required string srvc = 2;</code> + */ + public com.google.protobuf.ByteString + getSrvcBytes() { + java.lang.Object ref = srvc_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + srvc_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int PROCEDURE_FIELD_NUMBER = 3; + private java.lang.Object procedure_; + /** + * <code>required string procedure = 3;</code> + */ + public boolean hasProcedure() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>required string procedure = 3;</code> + */ + public java.lang.String getProcedure() { + java.lang.Object ref = procedure_; + 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(); + if (bs.isValidUtf8()) { + procedure_ = s; + } + return s; + } + } + /** + * <code>required string procedure = 3;</code> + */ + public com.google.protobuf.ByteString + getProcedureBytes() { + java.lang.Object ref = procedure_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + procedure_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int DATA_FIELD_NUMBER = 4; + private com.google.protobuf.ByteString data_; + /** + * <code>required bytes data = 4;</code> + */ + public boolean hasData() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <code>required bytes data = 4;</code> + */ + public com.google.protobuf.ByteString getData() { + return data_; + } + + public static final int DEADLINE_FIELD_NUMBER = 5; + private long deadline_; + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + public boolean hasDeadline() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + public long getDeadline() { + return deadline_; + } + + public static final int CALLER_ID_FIELD_NUMBER = 6; + private java.lang.Object callerId_; + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public boolean hasCallerId() { + return ((bitField0_ & 0x00000020) == 0x00000020); + } + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public java.lang.String getCallerId() { + java.lang.Object ref = callerId_; + 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(); + if (bs.isValidUtf8()) { + callerId_ = s; + } + return s; + } + } + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public com.google.protobuf.ByteString + getCallerIdBytes() { + java.lang.Object ref = callerId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + callerId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int WANT_TRACE_FIELD_NUMBER = 7; + private boolean wantTrace_; + /** + * <code>optional bool want_trace = 7;</code> + */ + public boolean hasWantTrace() { + return ((bitField0_ & 0x00000040) == 0x00000040); + } + /** + * <code>optional bool want_trace = 7;</code> + */ + public boolean getWantTrace() { + return wantTrace_; + } + + private void initFields() { + rpcId_ = ""; + srvc_ = ""; + procedure_ = ""; + data_ = com.google.protobuf.ByteString.EMPTY; + deadline_ = 0L; + callerId_ = ""; + wantTrace_ = false; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + if (!hasSrvc()) { + memoizedIsInitialized = 0; + return false; + } + if (!hasProcedure()) { + memoizedIsInitialized = 0; + return false; + } + if (!hasData()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, getRpcIdBytes()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeBytes(2, getSrvcBytes()); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + output.writeBytes(3, getProcedureBytes()); + } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + output.writeBytes(4, data_); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + output.writeInt64(5, deadline_); + } + if (((bitField0_ & 0x00000020) == 0x00000020)) { + output.writeBytes(6, getCallerIdBytes()); + } + if (((bitField0_ & 0x00000040) == 0x00000040)) { + output.writeBool(7, wantTrace_); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getRpcIdBytes()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(2, getSrvcBytes()); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(3, getProcedureBytes()); + } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(4, data_); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + size += com.google.protobuf.CodedOutputStream + .computeInt64Size(5, deadline_); + } + if (((bitField0_ & 0x00000020) == 0x00000020)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(6, getCallerIdBytes()); + } + if (((bitField0_ & 0x00000040) == 0x00000040)) { + size += com.google.protobuf.CodedOutputStream + .computeBoolSize(7, wantTrace_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static proto.Rpc.RPCRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static proto.Rpc.RPCRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static proto.Rpc.RPCRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static proto.Rpc.RPCRequest parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static proto.Rpc.RPCRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static proto.Rpc.RPCRequest parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static proto.Rpc.RPCRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static proto.Rpc.RPCRequest parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static proto.Rpc.RPCRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static proto.Rpc.RPCRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(proto.Rpc.RPCRequest prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code proto.RPCRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> implements + // @@protoc_insertion_point(builder_implements:proto.RPCRequest) + proto.Rpc.RPCRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return proto.Rpc.internal_static_proto_RPCRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return proto.Rpc.internal_static_proto_RPCRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + proto.Rpc.RPCRequest.class, proto.Rpc.RPCRequest.Builder.class); + } + + // Construct using proto.Rpc.RPCRequest.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + } + } + private static Builder create() { + return new Builder(); + } + + public Builder clear() { + super.clear(); + rpcId_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + srvc_ = ""; + bitField0_ = (bitField0_ & ~0x00000002); + procedure_ = ""; + bitField0_ = (bitField0_ & ~0x00000004); + data_ = com.google.protobuf.ByteString.EMPTY; + bitField0_ = (bitField0_ & ~0x00000008); + deadline_ = 0L; + bitField0_ = (bitField0_ & ~0x00000010); + callerId_ = ""; + bitField0_ = (bitField0_ & ~0x00000020); + wantTrace_ = false; + bitField0_ = (bitField0_ & ~0x00000040); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return proto.Rpc.internal_static_proto_RPCRequest_descriptor; + } + + public proto.Rpc.RPCRequest getDefaultInstanceForType() { + return proto.Rpc.RPCRequest.getDefaultInstance(); + } + + public proto.Rpc.RPCRequest build() { + proto.Rpc.RPCRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public proto.Rpc.RPCRequest buildPartial() { + proto.Rpc.RPCRequest result = new proto.Rpc.RPCRequest(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.rpcId_ = rpcId_; + if (((from_bitField0_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x00000002; + } + result.srvc_ = srvc_; + if (((from_bitField0_ & 0x00000004) == 0x00000004)) { + to_bitField0_ |= 0x00000004; + } + result.procedure_ = procedure_; + if (((from_bitField0_ & 0x00000008) == 0x00000008)) { + to_bitField0_ |= 0x00000008; + } + result.data_ = data_; + if (((from_bitField0_ & 0x00000010) == 0x00000010)) { + to_bitField0_ |= 0x00000010; + } + result.deadline_ = deadline_; + if (((from_bitField0_ & 0x00000020) == 0x00000020)) { + to_bitField0_ |= 0x00000020; + } + result.callerId_ = callerId_; + if (((from_bitField0_ & 0x00000040) == 0x00000040)) { + to_bitField0_ |= 0x00000040; + } + result.wantTrace_ = wantTrace_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof proto.Rpc.RPCRequest) { + return mergeFrom((proto.Rpc.RPCRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(proto.Rpc.RPCRequest other) { + if (other == proto.Rpc.RPCRequest.getDefaultInstance()) return this; + if (other.hasRpcId()) { + bitField0_ |= 0x00000001; + rpcId_ = other.rpcId_; + onChanged(); + } + if (other.hasSrvc()) { + bitField0_ |= 0x00000002; + srvc_ = other.srvc_; + onChanged(); + } + if (other.hasProcedure()) { + bitField0_ |= 0x00000004; + procedure_ = other.procedure_; + onChanged(); + } + if (other.hasData()) { + setData(other.getData()); + } + if (other.hasDeadline()) { + setDeadline(other.getDeadline()); + } + if (other.hasCallerId()) { + bitField0_ |= 0x00000020; + callerId_ = other.callerId_; + onChanged(); + } + if (other.hasWantTrace()) { + setWantTrace(other.getWantTrace()); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasSrvc()) { + + return false; + } + if (!hasProcedure()) { + + return false; + } + if (!hasData()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + proto.Rpc.RPCRequest parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (proto.Rpc.RPCRequest) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + private java.lang.Object rpcId_ = ""; + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public boolean hasRpcId() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public java.lang.String getRpcId() { + java.lang.Object ref = rpcId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + rpcId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public com.google.protobuf.ByteString + getRpcIdBytes() { + java.lang.Object ref = rpcId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + rpcId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public Builder setRpcId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + rpcId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public Builder clearRpcId() { + bitField0_ = (bitField0_ & ~0x00000001); + rpcId_ = getDefaultInstance().getRpcId(); + onChanged(); + return this; + } + /** + * <code>optional string rpc_id = 1;</code> + * + * <pre> + * A unique-ish ID for this RPC + * </pre> + */ + public Builder setRpcIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + rpcId_ = value; + onChanged(); + return this; + } + + private java.lang.Object srvc_ = ""; + /** + * <code>required string srvc = 2;</code> + */ + public boolean hasSrvc() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required string srvc = 2;</code> + */ + public java.lang.String getSrvc() { + java.lang.Object ref = srvc_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + srvc_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string srvc = 2;</code> + */ + public com.google.protobuf.ByteString + getSrvcBytes() { + java.lang.Object ref = srvc_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + srvc_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string srvc = 2;</code> + */ + public Builder setSrvc( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000002; + srvc_ = value; + onChanged(); + return this; + } + /** + * <code>required string srvc = 2;</code> + */ + public Builder clearSrvc() { + bitField0_ = (bitField0_ & ~0x00000002); + srvc_ = getDefaultInstance().getSrvc(); + onChanged(); + return this; + } + /** + * <code>required string srvc = 2;</code> + */ + public Builder setSrvcBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000002; + srvc_ = value; + onChanged(); + return this; + } + + private java.lang.Object procedure_ = ""; + /** + * <code>required string procedure = 3;</code> + */ + public boolean hasProcedure() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>required string procedure = 3;</code> + */ + public java.lang.String getProcedure() { + java.lang.Object ref = procedure_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + procedure_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string procedure = 3;</code> + */ + public com.google.protobuf.ByteString + getProcedureBytes() { + java.lang.Object ref = procedure_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + procedure_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string procedure = 3;</code> + */ + public Builder setProcedure( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000004; + procedure_ = value; + onChanged(); + return this; + } + /** + * <code>required string procedure = 3;</code> + */ + public Builder clearProcedure() { + bitField0_ = (bitField0_ & ~0x00000004); + procedure_ = getDefaultInstance().getProcedure(); + onChanged(); + return this; + } + /** + * <code>required string procedure = 3;</code> + */ + public Builder setProcedureBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000004; + procedure_ = value; + onChanged(); + return this; + } + + private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; + /** + * <code>required bytes data = 4;</code> + */ + public boolean hasData() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <code>required bytes data = 4;</code> + */ + public com.google.protobuf.ByteString getData() { + return data_; + } + /** + * <code>required bytes data = 4;</code> + */ + public Builder setData(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000008; + data_ = value; + onChanged(); + return this; + } + /** + * <code>required bytes data = 4;</code> + */ + public Builder clearData() { + bitField0_ = (bitField0_ & ~0x00000008); + data_ = getDefaultInstance().getData(); + onChanged(); + return this; + } + + private long deadline_ ; + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + public boolean hasDeadline() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + public long getDeadline() { + return deadline_; + } + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + public Builder setDeadline(long value) { + bitField0_ |= 0x00000010; + deadline_ = value; + onChanged(); + return this; + } + /** + * <code>optional int64 deadline = 5;</code> + * + * <pre> + * UNIX µs timestamp after which we don't want to have an answer anymore + * </pre> + */ + public Builder clearDeadline() { + bitField0_ = (bitField0_ & ~0x00000010); + deadline_ = 0L; + onChanged(); + return this; + } + + private java.lang.Object callerId_ = ""; + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public boolean hasCallerId() { + return ((bitField0_ & 0x00000020) == 0x00000020); + } + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public java.lang.String getCallerId() { + java.lang.Object ref = callerId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + callerId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public com.google.protobuf.ByteString + getCallerIdBytes() { + java.lang.Object ref = callerId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + callerId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public Builder setCallerId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000020; + callerId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public Builder clearCallerId() { + bitField0_ = (bitField0_ & ~0x00000020); + callerId_ = getDefaultInstance().getCallerId(); + onChanged(); + return this; + } + /** + * <code>optional string caller_id = 6;</code> + * + * <pre> + * (i.e. the server doesn't need to bother sending one) + * </pre> + */ + public Builder setCallerIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000020; + callerId_ = value; + onChanged(); + return this; + } + + private boolean wantTrace_ ; + /** + * <code>optional bool want_trace = 7;</code> + */ + public boolean hasWantTrace() { + return ((bitField0_ & 0x00000040) == 0x00000040); + } + /** + * <code>optional bool want_trace = 7;</code> + */ + public boolean getWantTrace() { + return wantTrace_; + } + /** + * <code>optional bool want_trace = 7;</code> + */ + public Builder setWantTrace(boolean value) { + bitField0_ |= 0x00000040; + wantTrace_ = value; + onChanged(); + return this; + } + /** + * <code>optional bool want_trace = 7;</code> + */ + public Builder clearWantTrace() { + bitField0_ = (bitField0_ & ~0x00000040); + wantTrace_ = false; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:proto.RPCRequest) + } + + static { + defaultInstance = new RPCRequest(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:proto.RPCRequest) + } + + public interface RPCResponseOrBuilder extends + // @@protoc_insertion_point(interface_extends:proto.RPCResponse) + com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string rpc_id = 1;</code> + */ + boolean hasRpcId(); + /** + * <code>optional string rpc_id = 1;</code> + */ + java.lang.String getRpcId(); + /** + * <code>optional string rpc_id = 1;</code> + */ + com.google.protobuf.ByteString + getRpcIdBytes(); + + /** + * <code>optional bytes response_data = 2;</code> + */ + boolean hasResponseData(); + /** + * <code>optional bytes response_data = 2;</code> + */ + com.google.protobuf.ByteString getResponseData(); + + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + boolean hasResponseStatus(); + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + proto.Rpc.RPCResponse.Status getResponseStatus(); + + /** + * <code>optional string error_message = 4;</code> + */ + boolean hasErrorMessage(); + /** + * <code>optional string error_message = 4;</code> + */ + java.lang.String getErrorMessage(); + /** + * <code>optional string error_message = 4;</code> + */ + com.google.protobuf.ByteString + getErrorMessageBytes(); + + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + boolean hasTraceinfo(); + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + proto.Rpc.TraceInfo getTraceinfo(); + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + proto.Rpc.TraceInfoOrBuilder getTraceinfoOrBuilder(); + } + /** + * Protobuf type {@code proto.RPCResponse} + */ + public static final class RPCResponse extends + com.google.protobuf.GeneratedMessage implements + // @@protoc_insertion_point(message_implements:proto.RPCResponse) + RPCResponseOrBuilder { + // Use RPCResponse.newBuilder() to construct. + private RPCResponse(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private RPCResponse(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final RPCResponse defaultInstance; + public static RPCResponse getDefaultInstance() { + return defaultInstance; + } + + public RPCResponse getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private RPCResponse( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000001; + rpcId_ = bs; + break; + } + case 18: { + bitField0_ |= 0x00000002; + responseData_ = input.readBytes(); + break; + } + case 24: { + int rawValue = input.readEnum(); + proto.Rpc.RPCResponse.Status value = proto.Rpc.RPCResponse.Status.valueOf(rawValue); + if (value == null) { + unknownFields.mergeVarintField(3, rawValue); + } else { + bitField0_ |= 0x00000004; + responseStatus_ = value; + } + break; + } + case 34: { + com.google.protobuf.ByteString bs = input.readBytes(); + bitField0_ |= 0x00000008; + errorMessage_ = bs; + break; + } + case 42: { + proto.Rpc.TraceInfo.Builder subBuilder = null; + if (((bitField0_ & 0x00000010) == 0x00000010)) { + subBuilder = traceinfo_.toBuilder(); + } + traceinfo_ = input.readMessage(proto.Rpc.TraceInfo.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(traceinfo_); + traceinfo_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000010; + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return proto.Rpc.internal_static_proto_RPCResponse_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return proto.Rpc.internal_static_proto_RPCResponse_fieldAccessorTable + .ensureFieldAccessorsInitialized( + proto.Rpc.RPCResponse.class, proto.Rpc.RPCResponse.Builder.class); + } + + public static com.google.protobuf.Parser<RPCResponse> PARSER = + new com.google.protobuf.AbstractParser<RPCResponse>() { + public RPCResponse parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new RPCResponse(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<RPCResponse> getParserForType() { + return PARSER; + } + + /** + * Protobuf enum {@code proto.RPCResponse.Status} + */ + public enum Status + implements com.google.protobuf.ProtocolMessageEnum { + /** + * <code>STATUS_UNKNOWN = 0;</code> + * + * <pre> + * Default value + * </pre> + */ + STATUS_UNKNOWN(0, 0), + /** + * <code>STATUS_OK = 1;</code> + * + * <pre> + * a.k.a. 200 + * </pre> + */ + STATUS_OK(1, 1), + /** + * <code>STATUS_NOT_FOUND = 2;</code> + * + * <pre> + * service/endpoint not found (a.k.a. 404) + * </pre> + */ + STATUS_NOT_FOUND(2, 2), + /** + * <code>STATUS_NOT_OK = 4;</code> + * + * <pre> + * The handler returned an error; see the error_message for a description (500). response_data may have content + * </pre> + */ + STATUS_NOT_OK(3, 4), + /** + * <code>STATUS_SERVER_ERROR = 5;</code> + * + * <pre> + * An error happened in the clusterrpc implementation (500) + * </pre> + */ + STATUS_SERVER_ERROR(4, 5), + /** + * <code>STATUS_TIMEOUT = 6;</code> + * + * <pre> + * The requested timeout has been expired + * </pre> + */ + STATUS_TIMEOUT(5, 6), + /** + * <code>STATUS_OVERLOADED_RETRY = 7;</code> + * + * <pre> + * The server is overloaded (503) + * </pre> + */ + STATUS_OVERLOADED_RETRY(6, 7), + /** + * <code>STATUS_CLIENT_REQUEST_ERROR = 9;</code> + * + * <pre> + * We couldn't even send the request (PB serialization error, ...) + * </pre> + */ + STATUS_CLIENT_REQUEST_ERROR(7, 9), + /** + * <code>STATUS_CLIENT_NETWORK_ERROR = 10;</code> + * + * <pre> + * We couldn't send the request because of network/socket issues. + * </pre> + */ + STATUS_CLIENT_NETWORK_ERROR(8, 10), + /** + * <code>STATUS_CLIENT_CALLED_WRONG = 11;</code> + * + * <pre> + * Client function called in a wrong way (e.g. different lengt of raddrs + * and rports slices to NewClientRR()) + * </pre> + */ + STATUS_CLIENT_CALLED_WRONG(9, 11), + /** + * <code>STATUS_MISSED_DEADLINE = 12;</code> + * + * <pre> + * Timeout somewhere in the call stack + * </pre> + */ + STATUS_MISSED_DEADLINE(10, 12), + /** + * <code>STATUS_LOADSHED = 13;</code> + * + * <pre> + * Loadshedding mode, not accepting requests right now + * </pre> + */ + STATUS_LOADSHED(11, 13), + /** + * <code>STATUS_UNHEALTHY = 14;</code> + * + * <pre> + * Health check failed + * </pre> + */ + STATUS_UNHEALTHY(12, 14), + ; + + /** + * <code>STATUS_UNKNOWN = 0;</code> + * + * <pre> + * Default value + * </pre> + */ + public static final int STATUS_UNKNOWN_VALUE = 0; + /** + * <code>STATUS_OK = 1;</code> + * + * <pre> + * a.k.a. 200 + * </pre> + */ + public static final int STATUS_OK_VALUE = 1; + /** + * <code>STATUS_NOT_FOUND = 2;</code> + * + * <pre> + * service/endpoint not found (a.k.a. 404) + * </pre> + */ + public static final int STATUS_NOT_FOUND_VALUE = 2; + /** + * <code>STATUS_NOT_OK = 4;</code> + * + * <pre> + * The handler returned an error; see the error_message for a description (500). response_data may have content + * </pre> + */ + public static final int STATUS_NOT_OK_VALUE = 4; + /** + * <code>STATUS_SERVER_ERROR = 5;</code> + * + * <pre> + * An error happened in the clusterrpc implementation (500) + * </pre> + */ + public static final int STATUS_SERVER_ERROR_VALUE = 5; + /** + * <code>STATUS_TIMEOUT = 6;</code> + * + * <pre> + * The requested timeout has been expired + * </pre> + */ + public static final int STATUS_TIMEOUT_VALUE = 6; + /** + * <code>STATUS_OVERLOADED_RETRY = 7;</code> + * + * <pre> + * The server is overloaded (503) + * </pre> + */ + public static final int STATUS_OVERLOADED_RETRY_VALUE = 7; + /** + * <code>STATUS_CLIENT_REQUEST_ERROR = 9;</code> + * + * <pre> + * We couldn't even send the request (PB serialization error, ...) + * </pre> + */ + public static final int STATUS_CLIENT_REQUEST_ERROR_VALUE = 9; + /** + * <code>STATUS_CLIENT_NETWORK_ERROR = 10;</code> + * + * <pre> + * We couldn't send the request because of network/socket issues. + * </pre> + */ + public static final int STATUS_CLIENT_NETWORK_ERROR_VALUE = 10; + /** + * <code>STATUS_CLIENT_CALLED_WRONG = 11;</code> + * + * <pre> + * Client function called in a wrong way (e.g. different lengt of raddrs + * and rports slices to NewClientRR()) + * </pre> + */ + public static final int STATUS_CLIENT_CALLED_WRONG_VALUE = 11; + /** + * <code>STATUS_MISSED_DEADLINE = 12;</code> + * + * <pre> + * Timeout somewhere in the call stack + * </pre> + */ + public static final int STATUS_MISSED_DEADLINE_VALUE = 12; + /** + * <code>STATUS_LOADSHED = 13;</code> + * + * <pre> + * Loadshedding mode, not accepting requests right now + * </pre> + */ + public static final int STATUS_LOADSHED_VALUE = 13; + /** + * <code>STATUS_UNHEALTHY = 14;</code> + * + * <pre> + * Health check failed + * </pre> + */ + public static final int STATUS_UNHEALTHY_VALUE = 14; + + + public final int getNumber() { return value; } + + public static Status valueOf(int value) { + switch (value) { + case 0: return STATUS_UNKNOWN; + case 1: return STATUS_OK; + case 2: return STATUS_NOT_FOUND; + case 4: return STATUS_NOT_OK; + case 5: return STATUS_SERVER_ERROR; + case 6: return STATUS_TIMEOUT; + case 7: return STATUS_OVERLOADED_RETRY; + case 9: return STATUS_CLIENT_REQUEST_ERROR; + case 10: return STATUS_CLIENT_NETWORK_ERROR; + case 11: return STATUS_CLIENT_CALLED_WRONG; + case 12: return STATUS_MISSED_DEADLINE; + case 13: return STATUS_LOADSHED; + case 14: return STATUS_UNHEALTHY; + default: return null; + } + } + + public static com.google.protobuf.Internal.EnumLiteMap<Status> + internalGetValueMap() { + return internalValueMap; + } + private static com.google.protobuf.Internal.EnumLiteMap<Status> + internalValueMap = + new com.google.protobuf.Internal.EnumLiteMap<Status>() { + public Status findValueByNumber(int number) { + return Status.valueOf(number); + } + }; + + public final com.google.protobuf.Descriptors.EnumValueDescriptor + getValueDescriptor() { + return getDescriptor().getValues().get(index); + } + public final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptorForType() { + return getDescriptor(); + } + public static final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptor() { + return proto.Rpc.RPCResponse.getDescriptor().getEnumTypes().get(0); + } + + private static final Status[] VALUES = values(); + + public static Status valueOf( + com.google.protobuf.Descriptors.EnumValueDescriptor desc) { + if (desc.getType() != getDescriptor()) { + throw new java.lang.IllegalArgumentException( + "EnumValueDescriptor is not for this type."); + } + return VALUES[desc.getIndex()]; + } + + private final int index; + private final int value; + + private Status(int index, int value) { + this.index = index; + this.value = value; + } + + // @@protoc_insertion_point(enum_scope:proto.RPCResponse.Status) + } + + private int bitField0_; + public static final int RPC_ID_FIELD_NUMBER = 1; + private java.lang.Object rpcId_; + /** + * <code>optional string rpc_id = 1;</code> + */ + public boolean hasRpcId() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>optional string rpc_id = 1;</code> + */ + public java.lang.String getRpcId() { + java.lang.Object ref = rpcId_; + 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(); + if (bs.isValidUtf8()) { + rpcId_ = s; + } + return s; + } + } + /** + * <code>optional string rpc_id = 1;</code> + */ + public com.google.protobuf.ByteString + getRpcIdBytes() { + java.lang.Object ref = rpcId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + rpcId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int RESPONSE_DATA_FIELD_NUMBER = 2; + private com.google.protobuf.ByteString responseData_; + /** + * <code>optional bytes response_data = 2;</code> + */ + public boolean hasResponseData() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>optional bytes response_data = 2;</code> + */ + public com.google.protobuf.ByteString getResponseData() { + return responseData_; + } + + public static final int RESPONSE_STATUS_FIELD_NUMBER = 3; + private proto.Rpc.RPCResponse.Status responseStatus_; + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + public boolean hasResponseStatus() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + public proto.Rpc.RPCResponse.Status getResponseStatus() { + return responseStatus_; + } + + public static final int ERROR_MESSAGE_FIELD_NUMBER = 4; + private java.lang.Object errorMessage_; + /** + * <code>optional string error_message = 4;</code> + */ + public boolean hasErrorMessage() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <code>optional string error_message = 4;</code> + */ + public java.lang.String getErrorMessage() { + java.lang.Object ref = errorMessage_; + 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(); + if (bs.isValidUtf8()) { + errorMessage_ = s; + } + return s; + } + } + /** + * <code>optional string error_message = 4;</code> + */ + public com.google.protobuf.ByteString + getErrorMessageBytes() { + java.lang.Object ref = errorMessage_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + errorMessage_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int TRACEINFO_FIELD_NUMBER = 5; + private proto.Rpc.TraceInfo traceinfo_; + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public boolean hasTraceinfo() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public proto.Rpc.TraceInfo getTraceinfo() { + return traceinfo_; + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public proto.Rpc.TraceInfoOrBuilder getTraceinfoOrBuilder() { + return traceinfo_; + } + + private void initFields() { + rpcId_ = ""; + responseData_ = com.google.protobuf.ByteString.EMPTY; + responseStatus_ = proto.Rpc.RPCResponse.Status.STATUS_UNKNOWN; + errorMessage_ = ""; + traceinfo_ = proto.Rpc.TraceInfo.getDefaultInstance(); + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + if (!hasResponseStatus()) { + memoizedIsInitialized = 0; + return false; + } + if (hasTraceinfo()) { + if (!getTraceinfo().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, getRpcIdBytes()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeBytes(2, responseData_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + output.writeEnum(3, responseStatus_.getNumber()); + } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + output.writeBytes(4, getErrorMessageBytes()); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + output.writeMessage(5, traceinfo_); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getRpcIdBytes()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(2, responseData_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + size += com.google.protobuf.CodedOutputStream + .computeEnumSize(3, responseStatus_.getNumber()); + } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(4, getErrorMessageBytes()); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(5, traceinfo_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static proto.Rpc.RPCResponse parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static proto.Rpc.RPCResponse parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static proto.Rpc.RPCResponse parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static proto.Rpc.RPCResponse parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static proto.Rpc.RPCResponse parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static proto.Rpc.RPCResponse parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static proto.Rpc.RPCResponse parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static proto.Rpc.RPCResponse parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static proto.Rpc.RPCResponse parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static proto.Rpc.RPCResponse parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(proto.Rpc.RPCResponse prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code proto.RPCResponse} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> implements + // @@protoc_insertion_point(builder_implements:proto.RPCResponse) + proto.Rpc.RPCResponseOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return proto.Rpc.internal_static_proto_RPCResponse_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return proto.Rpc.internal_static_proto_RPCResponse_fieldAccessorTable + .ensureFieldAccessorsInitialized( + proto.Rpc.RPCResponse.class, proto.Rpc.RPCResponse.Builder.class); + } + + // Construct using proto.Rpc.RPCResponse.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + getTraceinfoFieldBuilder(); + } + } + private static Builder create() { + return new Builder(); + } + + public Builder clear() { + super.clear(); + rpcId_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + responseData_ = com.google.protobuf.ByteString.EMPTY; + bitField0_ = (bitField0_ & ~0x00000002); + responseStatus_ = proto.Rpc.RPCResponse.Status.STATUS_UNKNOWN; + bitField0_ = (bitField0_ & ~0x00000004); + errorMessage_ = ""; + bitField0_ = (bitField0_ & ~0x00000008); + if (traceinfoBuilder_ == null) { + traceinfo_ = proto.Rpc.TraceInfo.getDefaultInstance(); + } else { + traceinfoBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000010); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return proto.Rpc.internal_static_proto_RPCResponse_descriptor; + } + + public proto.Rpc.RPCResponse getDefaultInstanceForType() { + return proto.Rpc.RPCResponse.getDefaultInstance(); + } + + public proto.Rpc.RPCResponse build() { + proto.Rpc.RPCResponse result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public proto.Rpc.RPCResponse buildPartial() { + proto.Rpc.RPCResponse result = new proto.Rpc.RPCResponse(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.rpcId_ = rpcId_; + if (((from_bitField0_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x00000002; + } + result.responseData_ = responseData_; + if (((from_bitField0_ & 0x00000004) == 0x00000004)) { + to_bitField0_ |= 0x00000004; + } + result.responseStatus_ = responseStatus_; + if (((from_bitField0_ & 0x00000008) == 0x00000008)) { + to_bitField0_ |= 0x00000008; + } + result.errorMessage_ = errorMessage_; + if (((from_bitField0_ & 0x00000010) == 0x00000010)) { + to_bitField0_ |= 0x00000010; + } + if (traceinfoBuilder_ == null) { + result.traceinfo_ = traceinfo_; + } else { + result.traceinfo_ = traceinfoBuilder_.build(); + } + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof proto.Rpc.RPCResponse) { + return mergeFrom((proto.Rpc.RPCResponse)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(proto.Rpc.RPCResponse other) { + if (other == proto.Rpc.RPCResponse.getDefaultInstance()) return this; + if (other.hasRpcId()) { + bitField0_ |= 0x00000001; + rpcId_ = other.rpcId_; + onChanged(); + } + if (other.hasResponseData()) { + setResponseData(other.getResponseData()); + } + if (other.hasResponseStatus()) { + setResponseStatus(other.getResponseStatus()); + } + if (other.hasErrorMessage()) { + bitField0_ |= 0x00000008; + errorMessage_ = other.errorMessage_; + onChanged(); + } + if (other.hasTraceinfo()) { + mergeTraceinfo(other.getTraceinfo()); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasResponseStatus()) { + + return false; + } + if (hasTraceinfo()) { + if (!getTraceinfo().isInitialized()) { + + return false; + } + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + proto.Rpc.RPCResponse parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (proto.Rpc.RPCResponse) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + private java.lang.Object rpcId_ = ""; + /** + * <code>optional string rpc_id = 1;</code> + */ + public boolean hasRpcId() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>optional string rpc_id = 1;</code> + */ + public java.lang.String getRpcId() { + java.lang.Object ref = rpcId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + rpcId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string rpc_id = 1;</code> + */ + public com.google.protobuf.ByteString + getRpcIdBytes() { + java.lang.Object ref = rpcId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + rpcId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string rpc_id = 1;</code> + */ + public Builder setRpcId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + rpcId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string rpc_id = 1;</code> + */ + public Builder clearRpcId() { + bitField0_ = (bitField0_ & ~0x00000001); + rpcId_ = getDefaultInstance().getRpcId(); + onChanged(); + return this; + } + /** + * <code>optional string rpc_id = 1;</code> + */ + public Builder setRpcIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + rpcId_ = value; + onChanged(); + return this; + } + + private com.google.protobuf.ByteString responseData_ = com.google.protobuf.ByteString.EMPTY; + /** + * <code>optional bytes response_data = 2;</code> + */ + public boolean hasResponseData() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>optional bytes response_data = 2;</code> + */ + public com.google.protobuf.ByteString getResponseData() { + return responseData_; + } + /** + * <code>optional bytes response_data = 2;</code> + */ + public Builder setResponseData(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000002; + responseData_ = value; + onChanged(); + return this; + } + /** + * <code>optional bytes response_data = 2;</code> + */ + public Builder clearResponseData() { + bitField0_ = (bitField0_ & ~0x00000002); + responseData_ = getDefaultInstance().getResponseData(); + onChanged(); + return this; + } + + private proto.Rpc.RPCResponse.Status responseStatus_ = proto.Rpc.RPCResponse.Status.STATUS_UNKNOWN; + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + public boolean hasResponseStatus() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + public proto.Rpc.RPCResponse.Status getResponseStatus() { + return responseStatus_; + } + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + public Builder setResponseStatus(proto.Rpc.RPCResponse.Status value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000004; + responseStatus_ = value; + onChanged(); + return this; + } + /** + * <code>required .proto.RPCResponse.Status response_status = 3;</code> + */ + public Builder clearResponseStatus() { + bitField0_ = (bitField0_ & ~0x00000004); + responseStatus_ = proto.Rpc.RPCResponse.Status.STATUS_UNKNOWN; + onChanged(); + return this; + } + + private java.lang.Object errorMessage_ = ""; + /** + * <code>optional string error_message = 4;</code> + */ + public boolean hasErrorMessage() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <code>optional string error_message = 4;</code> + */ + public java.lang.String getErrorMessage() { + java.lang.Object ref = errorMessage_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + errorMessage_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string error_message = 4;</code> + */ + public com.google.protobuf.ByteString + getErrorMessageBytes() { + java.lang.Object ref = errorMessage_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + errorMessage_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string error_message = 4;</code> + */ + public Builder setErrorMessage( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000008; + errorMessage_ = value; + onChanged(); + return this; + } + /** + * <code>optional string error_message = 4;</code> + */ + public Builder clearErrorMessage() { + bitField0_ = (bitField0_ & ~0x00000008); + errorMessage_ = getDefaultInstance().getErrorMessage(); + onChanged(); + return this; + } + /** + * <code>optional string error_message = 4;</code> + */ + public Builder setErrorMessageBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000008; + errorMessage_ = value; + onChanged(); + return this; + } + + private proto.Rpc.TraceInfo traceinfo_ = proto.Rpc.TraceInfo.getDefaultInstance(); + private com.google.protobuf.SingleFieldBuilder< + proto.Rpc.TraceInfo, proto.Rpc.TraceInfo.Builder, proto.Rpc.TraceInfoOrBuilder> traceinfoBuilder_; + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public boolean hasTraceinfo() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public proto.Rpc.TraceInfo getTraceinfo() { + if (traceinfoBuilder_ == null) { + return traceinfo_; + } else { + return traceinfoBuilder_.getMessage(); + } + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public Builder setTraceinfo(proto.Rpc.TraceInfo value) { + if (traceinfoBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + traceinfo_ = value; + onChanged(); + } else { + traceinfoBuilder_.setMessage(value); + } + bitField0_ |= 0x00000010; + return this; + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public Builder setTraceinfo( + proto.Rpc.TraceInfo.Builder builderForValue) { + if (traceinfoBuilder_ == null) { + traceinfo_ = builderForValue.build(); + onChanged(); + } else { + traceinfoBuilder_.setMessage(builderForValue.build()); + } + bitField0_ |= 0x00000010; + return this; + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public Builder mergeTraceinfo(proto.Rpc.TraceInfo value) { + if (traceinfoBuilder_ == null) { + if (((bitField0_ & 0x00000010) == 0x00000010) && + traceinfo_ != proto.Rpc.TraceInfo.getDefaultInstance()) { + traceinfo_ = + proto.Rpc.TraceInfo.newBuilder(traceinfo_).mergeFrom(value).buildPartial(); + } else { + traceinfo_ = value; + } + onChanged(); + } else { + traceinfoBuilder_.mergeFrom(value); + } + bitField0_ |= 0x00000010; + return this; + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public Builder clearTraceinfo() { + if (traceinfoBuilder_ == null) { + traceinfo_ = proto.Rpc.TraceInfo.getDefaultInstance(); + onChanged(); + } else { + traceinfoBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000010); + return this; + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public proto.Rpc.TraceInfo.Builder getTraceinfoBuilder() { + bitField0_ |= 0x00000010; + onChanged(); + return getTraceinfoFieldBuilder().getBuilder(); + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + public proto.Rpc.TraceInfoOrBuilder getTraceinfoOrBuilder() { + if (traceinfoBuilder_ != null) { + return traceinfoBuilder_.getMessageOrBuilder(); + } else { + return traceinfo_; + } + } + /** + * <code>optional .proto.TraceInfo traceinfo = 5;</code> + */ + private com.google.protobuf.SingleFieldBuilder< + proto.Rpc.TraceInfo, proto.Rpc.TraceInfo.Builder, proto.Rpc.TraceInfoOrBuilder> + getTraceinfoFieldBuilder() { + if (traceinfoBuilder_ == null) { + traceinfoBuilder_ = new com.google.protobuf.SingleFieldBuilder< + proto.Rpc.TraceInfo, proto.Rpc.TraceInfo.Builder, proto.Rpc.TraceInfoOrBuilder>( + getTraceinfo(), + getParentForChildren(), + isClean()); + traceinfo_ = null; + } + return traceinfoBuilder_; + } + + // @@protoc_insertion_point(builder_scope:proto.RPCResponse) + } + + static { + defaultInstance = new RPCResponse(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:proto.RPCResponse) + } + + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_proto_TraceInfo_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_proto_TraceInfo_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_proto_RPCRequest_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_proto_RPCRequest_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_proto_RPCResponse_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_proto_RPCResponse_fieldAccessorTable; + + public static com.google.protobuf.Descriptors.FileDescriptor + getDescriptor() { + return descriptor; + } + private static com.google.protobuf.Descriptors.FileDescriptor + descriptor; + static { + java.lang.String[] descriptorData = { + "\n\trpc.proto\022\005proto\"\265\001\n\tTraceInfo\022\025\n\rrece" + + "ived_time\030\001 \002(\003\022\024\n\014replied_time\030\002 \002(\003\022\024\n" + + "\014machine_name\030\003 \001(\t\022\025\n\rendpoint_name\030\004 \001" + + "(\t\022\025\n\rerror_message\030\005 \001(\t\022\020\n\010redirect\030\006 " + + "\001(\t\022%\n\013child_calls\030\007 \003(\0132\020.proto.TraceIn" + + "fo\"\204\001\n\nRPCRequest\022\016\n\006rpc_id\030\001 \001(\t\022\014\n\004srv" + + "c\030\002 \002(\t\022\021\n\tprocedure\030\003 \002(\t\022\014\n\004data\030\004 \002(\014" + + "\022\020\n\010deadline\030\005 \001(\003\022\021\n\tcaller_id\030\006 \001(\t\022\022\n" + + "\nwant_trace\030\007 \001(\010\"\356\003\n\013RPCResponse\022\016\n\006rpc" + + "_id\030\001 \001(\t\022\025\n\rresponse_data\030\002 \001(\014\0222\n\017resp", + "onse_status\030\003 \002(\0162\031.proto.RPCResponse.St" + + "atus\022\025\n\rerror_message\030\004 \001(\t\022#\n\ttraceinfo" + + "\030\005 \001(\0132\020.proto.TraceInfo\"\307\002\n\006Status\022\022\n\016S" + + "TATUS_UNKNOWN\020\000\022\r\n\tSTATUS_OK\020\001\022\024\n\020STATUS" + + "_NOT_FOUND\020\002\022\021\n\rSTATUS_NOT_OK\020\004\022\027\n\023STATU" + + "S_SERVER_ERROR\020\005\022\022\n\016STATUS_TIMEOUT\020\006\022\033\n\027" + + "STATUS_OVERLOADED_RETRY\020\007\022\037\n\033STATUS_CLIE" + + "NT_REQUEST_ERROR\020\t\022\037\n\033STATUS_CLIENT_NETW" + + "ORK_ERROR\020\n\022\036\n\032STATUS_CLIENT_CALLED_WRON" + + "G\020\013\022\032\n\026STATUS_MISSED_DEADLINE\020\014\022\023\n\017STATU", + "S_LOADSHED\020\r\022\024\n\020STATUS_UNHEALTHY\020\016" + }; + com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = + new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { + public com.google.protobuf.ExtensionRegistry assignDescriptors( + com.google.protobuf.Descriptors.FileDescriptor root) { + descriptor = root; + return null; + } + }; + com.google.protobuf.Descriptors.FileDescriptor + .internalBuildGeneratedFileFrom(descriptorData, + new com.google.protobuf.Descriptors.FileDescriptor[] { + }, assigner); + internal_static_proto_TraceInfo_descriptor = + getDescriptor().getMessageTypes().get(0); + internal_static_proto_TraceInfo_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_proto_TraceInfo_descriptor, + new java.lang.String[] { "ReceivedTime", "RepliedTime", "MachineName", "EndpointName", "ErrorMessage", "Redirect", "ChildCalls", }); + internal_static_proto_RPCRequest_descriptor = + getDescriptor().getMessageTypes().get(1); + internal_static_proto_RPCRequest_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_proto_RPCRequest_descriptor, + new java.lang.String[] { "RpcId", "Srvc", "Procedure", "Data", "Deadline", "CallerId", "WantTrace", }); + internal_static_proto_RPCResponse_descriptor = + getDescriptor().getMessageTypes().get(2); + internal_static_proto_RPCResponse_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_proto_RPCResponse_descriptor, + new java.lang.String[] { "RpcId", "ResponseData", "ResponseStatus", "ErrorMessage", "Traceinfo", }); + } + + // @@protoc_insertion_point(outer_class_scope) +}
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/test/java/net/borgac/clusterrpc/ClusterRPCRootTest.java Fri Sep 23 16:23:46 2016 +0200 @@ -0,0 +1,49 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ +package net.borgac.clusterrpc; + +import org.junit.After; +import org.junit.AfterClass; +import org.junit.Assert; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; + +/** + * + * @author lbo + */ +public class ClusterRPCRootTest { + + public ClusterRPCRootTest() { + } + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + // @Test + // public void hello() {} + @Test + public void testThatTestingWorks() { + Assert.assertTrue(true); + } +}
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/test/java/net/borgac/clusterrpc/TestDependencies.java Fri Sep 23 16:23:46 2016 +0200 @@ -0,0 +1,46 @@ +package net.borgac.clusterrpc; + +import com.google.protobuf.Empty; +import org.junit.After; +import org.junit.AfterClass; +import org.junit.Assert; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; + +/** + * + * @author lbo + */ +public class TestDependencies { + + public TestDependencies() { + } + + @BeforeClass + public static void setUpClass() { + } + + @AfterClass + public static void tearDownClass() { + } + + @Before + public void setUp() { + } + + @After + public void tearDown() { + } + + // TODO add test methods here. + // The methods must be annotated with annotation @Test. For example: + // + // @Test + // public void hello() {} + @Test + public void testProtobufLib() { + Empty e = Empty.newBuilder().build(); + Assert.assertNotNull(e); + } +}