You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/12/14 07:07:56 UTC
[incubator-eventmesh] branch master updated: fix issue2536
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 3463355d9 fix issue2536
new f1671073d Merge pull request #2578 from jonyangx/issue2536
3463355d9 is described below
commit 3463355d9e0c655965b6705d4470e3a654a03ddd
Author: jonyangx <jo...@gmail.com>
AuthorDate: Tue Dec 13 14:52:26 2022 +0800
fix issue2536
---
.../protocol/workflow/protos/ExecuteResponse.java | 989 +++++++++++----------
1 file changed, 495 insertions(+), 494 deletions(-)
diff --git a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteResponse.java b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteResponse.java
index d3e5fd8bc..c141b684d 100644
--- a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteResponse.java
+++ b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteResponse.java
@@ -20,556 +20,557 @@
package org.apache.eventmesh.common.protocol.workflow.protos;
+import java.util.Objects;
+
+import com.google.protobuf.ByteString;
+
/**
* Protobuf type {@code eventmesh.workflow.api.protocol.ExecuteResponse}
*/
@SuppressWarnings({"all"})
-public final class ExecuteResponse extends
- com.google.protobuf.GeneratedMessageV3 implements
- // @@protoc_insertion_point(message_implements:eventmesh.workflow.api.protocol.ExecuteResponse)
- ExecuteResponseOrBuilder {
-private static final long serialVersionUID = 0L;
- // Use ExecuteResponse.newBuilder() to construct.
- private ExecuteResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
- super(builder);
- }
- private ExecuteResponse() {
- instanceId_ = "";
- }
-
- @Override
- @SuppressWarnings({"unused"})
- protected Object newInstance(
- UnusedPrivateParameter unused) {
- return new ExecuteResponse();
- }
-
- @Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return this.unknownFields;
- }
- private ExecuteResponse(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- this();
- if (extensionRegistry == null) {
- throw new NullPointerException();
- }
- 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;
- case 10: {
- String s = input.readStringRequireUtf8();
-
- instanceId_ = s;
- break;
- }
- default: {
- if (!parseUnknownField(
- input, unknownFields, extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- }
- }
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_descriptor;
- }
-
- @Override
- protected FieldAccessorTable
- internalGetFieldAccessorTable() {
- return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- ExecuteResponse.class, Builder.class);
- }
-
- public static final int INSTANCE_ID_FIELD_NUMBER = 1;
- private volatile Object instanceId_;
- /**
- * <code>string instance_id = 1;</code>
- * @return The instanceId.
- */
- @Override
- public String getInstanceId() {
- Object ref = instanceId_;
- if (ref instanceof String) {
- return (String) ref;
- } else {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- String s = bs.toStringUtf8();
- instanceId_ = s;
- return s;
- }
- }
- /**
- * <code>string instance_id = 1;</code>
- * @return The bytes for instanceId.
- */
- @Override
- public com.google.protobuf.ByteString
- getInstanceIdBytes() {
- Object ref = instanceId_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (String) ref);
- instanceId_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
-
- private byte memoizedIsInitialized = -1;
- @Override
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized == 1) return true;
- if (isInitialized == 0) return false;
-
- memoizedIsInitialized = 1;
- return true;
- }
-
- @Override
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- if (!getInstanceIdBytes().isEmpty()) {
- com.google.protobuf.GeneratedMessageV3.writeString(output, 1, instanceId_);
- }
- unknownFields.writeTo(output);
- }
-
- @Override
- public int getSerializedSize() {
- int size = memoizedSize;
- if (size != -1) return size;
-
- size = 0;
- if (!getInstanceIdBytes().isEmpty()) {
- size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, instanceId_);
- }
- size += unknownFields.getSerializedSize();
- memoizedSize = size;
- return size;
- }
-
- @Override
- public boolean equals(final Object obj) {
- if (obj == this) {
- return true;
- }
- if (!(obj instanceof ExecuteResponse)) {
- return super.equals(obj);
- }
- ExecuteResponse other = (ExecuteResponse) obj;
-
- if (!getInstanceId()
- .equals(other.getInstanceId())) return false;
- if (!unknownFields.equals(other.unknownFields)) return false;
- return true;
- }
-
- @Override
- public int hashCode() {
- if (memoizedHashCode != 0) {
- return memoizedHashCode;
- }
- int hash = 41;
- hash = (19 * hash) + getDescriptor().hashCode();
- hash = (37 * hash) + INSTANCE_ID_FIELD_NUMBER;
- hash = (53 * hash) + getInstanceId().hashCode();
- hash = (29 * hash) + unknownFields.hashCode();
- memoizedHashCode = hash;
- return hash;
- }
-
- public static ExecuteResponse parseFrom(
- java.nio.ByteBuffer data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static ExecuteResponse parseFrom(
- java.nio.ByteBuffer data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static ExecuteResponse parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static ExecuteResponse parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static ExecuteResponse parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static ExecuteResponse parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static ExecuteResponse parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static ExecuteResponse parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
- public static ExecuteResponse parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input);
- }
- public static ExecuteResponse parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
- }
- public static ExecuteResponse parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static ExecuteResponse parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
-
- @Override
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder() {
- return DEFAULT_INSTANCE.toBuilder();
- }
- public static Builder newBuilder(ExecuteResponse prototype) {
- return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
- }
- @Override
- public Builder toBuilder() {
- return this == DEFAULT_INSTANCE
- ? new Builder() : new Builder().mergeFrom(this);
- }
-
- @Override
- protected Builder newBuilderForType(
- BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * Protobuf type {@code eventmesh.workflow.api.protocol.ExecuteResponse}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
- // @@protoc_insertion_point(builder_implements:eventmesh.workflow.api.protocol.ExecuteResponse)
- ExecuteResponseOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_descriptor;
- }
+public final class ExecuteResponse extends com.google.protobuf.GeneratedMessageV3 implements ExecuteResponseOrBuilder {
- @Override
- protected FieldAccessorTable
- internalGetFieldAccessorTable() {
- return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- ExecuteResponse.class, Builder.class);
- }
+ private static final long serialVersionUID = -6807939196493979674L;
- // Construct using org.apache.eventmesh.common.protocol.workflow.protos.ExecuteResponse.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
+ public static final int INSTANCE_ID_FIELD_NUMBER = 1;
+ private volatile String instanceId;
+
+ private byte memoizedIsInitialized = -1;
+
+ // Use ExecuteResponse.newBuilder() to construct.
+ private ExecuteResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
+ super(builder);
}
- private Builder(
- BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
+ private ExecuteResponse() {
+ instanceId = "";
}
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessageV3
- .alwaysUseFieldBuilders) {
- }
+
+ @Override
+ @SuppressWarnings({"unused"})
+ protected Object newInstance(UnusedPrivateParameter unused) {
+ return new ExecuteResponse();
}
+
@Override
- public Builder clear() {
- super.clear();
- instanceId_ = "";
+ public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
+ return this.unknownFields;
+ }
+
+ private ExecuteResponse(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ this();
+ Objects.requireNonNull(extensionRegistry, "ExtensionRegistryLite can not be null");
+ Objects.requireNonNull(input, "CodedInputStream can not be null");
+
+ 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;
+ case 10: {
+ instanceId = input.readStringRequireUtf8();
+ break;
+ }
+ default: {
+ if (!parseUnknownField(
+ input, unknownFields, extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e).setUnfinishedMessage(this);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
- return this;
+ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
+ return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_descriptor;
}
@Override
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_descriptor;
+ protected FieldAccessorTable internalGetFieldAccessorTable() {
+ return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(ExecuteResponse.class, Builder.class);
}
+
+ /**
+ * <code>string instance_id = 1;</code>
+ *
+ * @return The instanceId.
+ */
@Override
- public ExecuteResponse getDefaultInstanceForType() {
- return ExecuteResponse.getDefaultInstance();
+ public String getInstanceId() {
+ return instanceId;
}
+ /**
+ * <code>string instance_id = 1;</code>
+ *
+ * @return The bytes for instanceId.
+ */
@Override
- public ExecuteResponse build() {
- ExecuteResponse result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
+ public com.google.protobuf.ByteString getInstanceIdBytes() {
+ return ByteString.copyFromUtf8(instanceId);
}
+
@Override
- public ExecuteResponse buildPartial() {
- ExecuteResponse result = new ExecuteResponse(this);
- result.instanceId_ = instanceId_;
- onBuilt();
- return result;
+ public final boolean isInitialized() {
+ if (memoizedIsInitialized == 1) {
+ return true;
+ }
+
+ if (memoizedIsInitialized == 0) {
+ return false;
+ }
+
+ memoizedIsInitialized = 1;
+ return true;
}
@Override
- public Builder clone() {
- return super.clone();
+ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException {
+ if (!getInstanceIdBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 1, instanceId);
+ }
+ unknownFields.writeTo(output);
}
+
@Override
- public Builder setField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- Object value) {
- return super.setField(field, value);
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!getInstanceIdBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, instanceId);
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
}
+
@Override
- public Builder clearField(
- com.google.protobuf.Descriptors.FieldDescriptor field) {
- return super.clearField(field);
+ public boolean equals(final Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof ExecuteResponse)) {
+ return super.equals(obj);
+ }
+ ExecuteResponse other = (ExecuteResponse) obj;
+
+ if (!getInstanceId()
+ .equals(other.getInstanceId())) return false;
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
}
+
@Override
- public Builder clearOneof(
- com.google.protobuf.Descriptors.OneofDescriptor oneof) {
- return super.clearOneof(oneof);
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + INSTANCE_ID_FIELD_NUMBER;
+ hash = (53 * hash) + getInstanceId().hashCode();
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
}
- @Override
- public Builder setRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- int index, Object value) {
- return super.setRepeatedField(field, index, value);
+
+ public static ExecuteResponse parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
}
- @Override
- public Builder addRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- Object value) {
- return super.addRepeatedField(field, value);
+
+ public static ExecuteResponse parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
}
- @Override
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof ExecuteResponse) {
- return mergeFrom((ExecuteResponse)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(ExecuteResponse other) {
- if (other == ExecuteResponse.getDefaultInstance()) return this;
- if (!other.getInstanceId().isEmpty()) {
- instanceId_ = other.instanceId_;
- onChanged();
- }
- this.mergeUnknownFields(other.unknownFields);
- onChanged();
- return this;
+
+ public static ExecuteResponse parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
}
- @Override
- public final boolean isInitialized() {
- return true;
+ public static ExecuteResponse parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
}
- @Override
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- ExecuteResponse parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (ExecuteResponse) e.getUnfinishedMessage();
- throw e.unwrapIOException();
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
-
- private Object instanceId_ = "";
- /**
- * <code>string instance_id = 1;</code>
- * @return The instanceId.
- */
- public String getInstanceId() {
- Object ref = instanceId_;
- if (!(ref instanceof String)) {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- String s = bs.toStringUtf8();
- instanceId_ = s;
- return s;
- } else {
- return (String) ref;
- }
+ public static ExecuteResponse parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
}
- /**
- * <code>string instance_id = 1;</code>
- * @return The bytes for instanceId.
- */
- public com.google.protobuf.ByteString
- getInstanceIdBytes() {
- Object ref = instanceId_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (String) ref);
- instanceId_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
+
+ public static ExecuteResponse parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
}
- /**
- * <code>string instance_id = 1;</code>
- * @param value The instanceId to set.
- * @return This builder for chaining.
- */
- public Builder setInstanceId(
- String value) {
- if (value == null) {
- throw new NullPointerException();
- }
-
- instanceId_ = value;
- onChanged();
- return this;
+
+ public static ExecuteResponse parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
}
- /**
- * <code>string instance_id = 1;</code>
- * @return This builder for chaining.
- */
- public Builder clearInstanceId() {
-
- instanceId_ = getDefaultInstance().getInstanceId();
- onChanged();
- return this;
+
+ public static ExecuteResponse parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
}
- /**
- * <code>string instance_id = 1;</code>
- * @param value The bytes for instanceId to set.
- * @return This builder for chaining.
- */
- public Builder setInstanceIdBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- checkByteStringIsUtf8(value);
-
- instanceId_ = value;
- onChanged();
- return this;
+
+ public static ExecuteResponse parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
}
+
+ public static ExecuteResponse parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ public static ExecuteResponse parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+
+ public static ExecuteResponse parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
@Override
- public final Builder setUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
- return super.setUnknownFields(unknownFields);
+ public Builder newBuilderForType() {
+ return newBuilder();
+ }
+
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+
+ public static Builder newBuilder(ExecuteResponse prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+
+ @Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
}
@Override
- public final Builder mergeUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
- return super.mergeUnknownFields(unknownFields);
+ protected Builder newBuilderForType(
+ BuilderParent parent) {
+ return new Builder(parent);
}
+ /**
+ * Protobuf type {@code eventmesh.workflow.api.protocol.ExecuteResponse}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
+ ExecuteResponseOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
+ return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable internalGetFieldAccessorTable() {
+ return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ ExecuteResponse.class, Builder.class);
+ }
+
+ // Construct using org.apache.eventmesh.common.protocol.workflow.protos.ExecuteResponse.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
- // @@protoc_insertion_point(builder_scope:eventmesh.workflow.api.protocol.ExecuteResponse)
- }
+ private Builder(BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
+ }
+ }
+
+ @Override
+ public Builder clear() {
+ super.clear();
+ instanceId = "";
+ return this;
+ }
+
+ @Override
+ public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() {
+ return EventmeshWorkflowGrpc.internal_static_eventmesh_workflow_api_protocol_ExecuteResponse_descriptor;
+ }
+
+ @Override
+ public ExecuteResponse getDefaultInstanceForType() {
+ return ExecuteResponse.getDefaultInstance();
+ }
- // @@protoc_insertion_point(class_scope:eventmesh.workflow.api.protocol.ExecuteResponse)
- private static final ExecuteResponse DEFAULT_INSTANCE;
- static {
- DEFAULT_INSTANCE = new ExecuteResponse();
- }
+ @Override
+ public ExecuteResponse build() {
+ ExecuteResponse result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @Override
+ public ExecuteResponse buildPartial() {
+ ExecuteResponse result = new ExecuteResponse(this);
+ result.instanceId = instanceId;
+ onBuilt();
+ return result;
+ }
+
+ @Override
+ public Builder clone() {
+ return super.clone();
+ }
+
+ @Override
+ public Builder setField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.setField(field, value);
+ }
+
+ @Override
+ public Builder clearField(
+ com.google.protobuf.Descriptors.FieldDescriptor field) {
+ return super.clearField(field);
+ }
+
+ @Override
+ public Builder clearOneof(
+ com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+ return super.clearOneof(oneof);
+ }
+
+ @Override
+ public Builder setRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ int index, Object value) {
+ return super.setRepeatedField(field, index, value);
+ }
+
+ @Override
+ public Builder addRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ Object value) {
+ return super.addRepeatedField(field, value);
+ }
+
+ @Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ Objects.requireNonNull(other, "Message can not be null");
+
+ if (other instanceof ExecuteResponse) {
+ return mergeFrom((ExecuteResponse) other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
- public static ExecuteResponse getDefaultInstance() {
- return DEFAULT_INSTANCE;
- }
+ public Builder mergeFrom(ExecuteResponse other) {
+ Objects.requireNonNull(other, "ExecuteResponse can not be null");
+
+ if (other == ExecuteResponse.getDefaultInstance()) return this;
+ if (!other.getInstanceId().isEmpty()) {
+ instanceId = other.instanceId;
+ onChanged();
+ }
+ this.mergeUnknownFields(other.unknownFields);
+ onChanged();
+ return this;
+ }
+
+ @Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ Objects.requireNonNull(input, "CodedInputStream can not be null");
+ Objects.requireNonNull(extensionRegistry, "ExtensionRegistryLite can not be null");
+
+ ExecuteResponse parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (ExecuteResponse) e.getUnfinishedMessage();
+ throw e.unwrapIOException();
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+
+ return this;
+ }
+
+ private String instanceId = "";
+
+ /**
+ * <code>string instance_id = 1;</code>
+ *
+ * @return The instanceId.
+ */
+ public String getInstanceId() {
+ return instanceId;
+ }
+
+ /**
+ * <code>string instance_id = 1;</code>
+ *
+ * @return The bytes for instanceId.
+ */
+ public com.google.protobuf.ByteString getInstanceIdBytes() {
+ return ByteString.copyFromUtf8(instanceId);
+ }
+
+ /**
+ * <code>string instance_id = 1;</code>
+ *
+ * @param value The instanceId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setInstanceId(
+ String value) {
+ Objects.requireNonNull(value, "InstanceId can not be null");
+ instanceId = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>string instance_id = 1;</code>
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearInstanceId() {
+ instanceId = getDefaultInstance().getInstanceId();
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>string instance_id = 1;</code>
+ *
+ * @param value The bytes for instanceId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setInstanceIdBytes(
+ com.google.protobuf.ByteString value) {
+ Objects.requireNonNull(value, "ByteString can not be null");
+ checkByteStringIsUtf8(value);
+ instanceId = value.toStringUtf8();
+ onChanged();
+ return this;
+ }
+
+ @Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:eventmesh.workflow.api.protocol.ExecuteResponse)
+ }
+
+ // @@protoc_insertion_point(class_scope:eventmesh.workflow.api.protocol.ExecuteResponse)
+ private static final ExecuteResponse DEFAULT_INSTANCE;
+
+ static {
+ DEFAULT_INSTANCE = new ExecuteResponse();
+ }
+
+ public static ExecuteResponse getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser<ExecuteResponse> PARSER =
+ new com.google.protobuf.AbstractParser<ExecuteResponse>() {
+ @Override
+ public ExecuteResponse parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new ExecuteResponse(input, extensionRegistry);
+ }
+ };
+
+ public static com.google.protobuf.Parser<ExecuteResponse> parser() {
+ return PARSER;
+ }
- private static final com.google.protobuf.Parser<ExecuteResponse>
- PARSER = new com.google.protobuf.AbstractParser<ExecuteResponse>() {
@Override
- public ExecuteResponse parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new ExecuteResponse(input, extensionRegistry);
- }
- };
-
- public static com.google.protobuf.Parser<ExecuteResponse> parser() {
- return PARSER;
- }
-
- @Override
- public com.google.protobuf.Parser<ExecuteResponse> getParserForType() {
- return PARSER;
- }
-
- @Override
- public ExecuteResponse getDefaultInstanceForType() {
- return DEFAULT_INSTANCE;
- }
+ public com.google.protobuf.Parser<ExecuteResponse> getParserForType() {
+ return PARSER;
+ }
+
+ @Override
+ public ExecuteResponse getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org