Mercurial > lbo > hg > clusterrpc-java
view src/main/java/net/borgac/clusterrpc/proto/Rpc.java @ 0:ed6ea43af3f4
Initial commit
author | Lewin Bormann <lbo@spheniscida.de> |
---|---|
date | Fri, 23 Sep 2016 16:23:46 +0200 |
parents | |
children |
line wrap: on
line source
// 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) }