getParserForType() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public io.temporal.omes.KitchenSink.DoStandaloneNexusOperation getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+ }
+
+ public interface DoStandaloneActivityOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:temporal.omes.kitchen_sink.DoStandaloneActivity)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ * @return Whether the activity field is set.
+ */
+ boolean hasActivity();
+ /**
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ * @return The activity.
+ */
+ io.temporal.omes.KitchenSink.ExecuteActivityAction getActivity();
+ /**
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ */
+ io.temporal.omes.KitchenSink.ExecuteActivityActionOrBuilder getActivityOrBuilder();
+ }
+ /**
+ *
+ * DoStandaloneActivity starts an activity outside of any workflow context using
+ * StartActivityExecution and polls for its outcome with PollActivityExecution.
+ * Reuses ExecuteActivityAction so the activity variant, task queue, timeouts, and
+ * retry policy are all configurable. Requires server-side support for
+ * workflow-independent activities.
+ *
+ *
+ * Protobuf type {@code temporal.omes.kitchen_sink.DoStandaloneActivity}
+ */
+ public static final class DoStandaloneActivity extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:temporal.omes.kitchen_sink.DoStandaloneActivity)
+ DoStandaloneActivityOrBuilder {
+ private static final long serialVersionUID = 0L;
+ // Use DoStandaloneActivity.newBuilder() to construct.
+ private DoStandaloneActivity(com.google.protobuf.GeneratedMessageV3.Builder builder) {
+ super(builder);
+ }
+ private DoStandaloneActivity() {
+ }
+
+ @java.lang.Override
+ @SuppressWarnings({"unused"})
+ protected java.lang.Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new DoStandaloneActivity();
+ }
+
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return io.temporal.omes.KitchenSink.internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_descriptor;
+ }
+
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return io.temporal.omes.KitchenSink.internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ io.temporal.omes.KitchenSink.DoStandaloneActivity.class, io.temporal.omes.KitchenSink.DoStandaloneActivity.Builder.class);
+ }
+
+ private int bitField0_;
+ public static final int ACTIVITY_FIELD_NUMBER = 1;
+ private io.temporal.omes.KitchenSink.ExecuteActivityAction activity_;
+ /**
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ * @return Whether the activity field is set.
+ */
+ @java.lang.Override
+ public boolean hasActivity() {
+ return ((bitField0_ & 0x00000001) != 0);
+ }
+ /**
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ * @return The activity.
+ */
+ @java.lang.Override
+ public io.temporal.omes.KitchenSink.ExecuteActivityAction getActivity() {
+ return activity_ == null ? io.temporal.omes.KitchenSink.ExecuteActivityAction.getDefaultInstance() : activity_;
+ }
+ /**
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ */
+ @java.lang.Override
+ public io.temporal.omes.KitchenSink.ExecuteActivityActionOrBuilder getActivityOrBuilder() {
+ return activity_ == null ? io.temporal.omes.KitchenSink.ExecuteActivityAction.getDefaultInstance() : activity_;
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (((bitField0_ & 0x00000001) != 0)) {
+ output.writeMessage(1, getActivity());
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (((bitField0_ & 0x00000001) != 0)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getActivity());
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof io.temporal.omes.KitchenSink.DoStandaloneActivity)) {
+ return super.equals(obj);
+ }
+ io.temporal.omes.KitchenSink.DoStandaloneActivity other = (io.temporal.omes.KitchenSink.DoStandaloneActivity) obj;
+
+ if (hasActivity() != other.hasActivity()) return false;
+ if (hasActivity()) {
+ if (!getActivity()
+ .equals(other.getActivity())) return false;
+ }
+ if (!getUnknownFields().equals(other.getUnknownFields())) return false;
+ return true;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ if (hasActivity()) {
+ hash = (37 * hash) + ACTIVITY_FIELD_NUMBER;
+ hash = (53 * hash) + getActivity().hashCode();
+ }
+ hash = (29 * hash) + getUnknownFields().hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity 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 io.temporal.omes.KitchenSink.DoStandaloneActivity parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity 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 io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(io.temporal.omes.KitchenSink.DoStandaloneActivity prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ *
+ * DoStandaloneActivity starts an activity outside of any workflow context using
+ * StartActivityExecution and polls for its outcome with PollActivityExecution.
+ * Reuses ExecuteActivityAction so the activity variant, task queue, timeouts, and
+ * retry policy are all configurable. Requires server-side support for
+ * workflow-independent activities.
+ *
+ *
+ * Protobuf type {@code temporal.omes.kitchen_sink.DoStandaloneActivity}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder implements
+ // @@protoc_insertion_point(builder_implements:temporal.omes.kitchen_sink.DoStandaloneActivity)
+ io.temporal.omes.KitchenSink.DoStandaloneActivityOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return io.temporal.omes.KitchenSink.internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_descriptor;
+ }
+
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return io.temporal.omes.KitchenSink.internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ io.temporal.omes.KitchenSink.DoStandaloneActivity.class, io.temporal.omes.KitchenSink.DoStandaloneActivity.Builder.class);
+ }
+
+ // Construct using io.temporal.omes.KitchenSink.DoStandaloneActivity.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessageV3
+ .alwaysUseFieldBuilders) {
+ getActivityFieldBuilder();
+ }
+ }
+ @java.lang.Override
+ public Builder clear() {
+ super.clear();
+ bitField0_ = 0;
+ activity_ = null;
+ if (activityBuilder_ != null) {
+ activityBuilder_.dispose();
+ activityBuilder_ = null;
+ }
+ return this;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return io.temporal.omes.KitchenSink.internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_descriptor;
+ }
+
+ @java.lang.Override
+ public io.temporal.omes.KitchenSink.DoStandaloneActivity getDefaultInstanceForType() {
+ return io.temporal.omes.KitchenSink.DoStandaloneActivity.getDefaultInstance();
+ }
+
+ @java.lang.Override
+ public io.temporal.omes.KitchenSink.DoStandaloneActivity build() {
+ io.temporal.omes.KitchenSink.DoStandaloneActivity result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @java.lang.Override
+ public io.temporal.omes.KitchenSink.DoStandaloneActivity buildPartial() {
+ io.temporal.omes.KitchenSink.DoStandaloneActivity result = new io.temporal.omes.KitchenSink.DoStandaloneActivity(this);
+ if (bitField0_ != 0) { buildPartial0(result); }
+ onBuilt();
+ return result;
+ }
+
+ private void buildPartial0(io.temporal.omes.KitchenSink.DoStandaloneActivity result) {
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
+ if (((from_bitField0_ & 0x00000001) != 0)) {
+ result.activity_ = activityBuilder_ == null
+ ? activity_
+ : activityBuilder_.build();
+ to_bitField0_ |= 0x00000001;
+ }
+ result.bitField0_ |= to_bitField0_;
+ }
+
+ @java.lang.Override
+ public Builder clone() {
+ return super.clone();
+ }
+ @java.lang.Override
+ public Builder setField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ java.lang.Object value) {
+ return super.setField(field, value);
+ }
+ @java.lang.Override
+ public Builder clearField(
+ com.google.protobuf.Descriptors.FieldDescriptor field) {
+ return super.clearField(field);
+ }
+ @java.lang.Override
+ public Builder clearOneof(
+ com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+ return super.clearOneof(oneof);
+ }
+ @java.lang.Override
+ public Builder setRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ int index, java.lang.Object value) {
+ return super.setRepeatedField(field, index, value);
+ }
+ @java.lang.Override
+ public Builder addRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ java.lang.Object value) {
+ return super.addRepeatedField(field, value);
+ }
+ @java.lang.Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof io.temporal.omes.KitchenSink.DoStandaloneActivity) {
+ return mergeFrom((io.temporal.omes.KitchenSink.DoStandaloneActivity)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(io.temporal.omes.KitchenSink.DoStandaloneActivity other) {
+ if (other == io.temporal.omes.KitchenSink.DoStandaloneActivity.getDefaultInstance()) return this;
+ if (other.hasActivity()) {
+ mergeActivity(other.getActivity());
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ onChanged();
+ return this;
+ }
+
+ @java.lang.Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @java.lang.Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ if (extensionRegistry == null) {
+ throw new java.lang.NullPointerException();
+ }
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ input.readMessage(
+ getActivityFieldBuilder().getBuilder(),
+ extensionRegistry);
bitField0_ |= 0x00000001;
break;
} // case 10
- case 18: {
- service_ = input.readStringRequireUtf8();
- bitField0_ |= 0x00000002;
- break;
- } // case 18
- case 26: {
- operation_ = input.readStringRequireUtf8();
- bitField0_ |= 0x00000004;
- break;
- } // case 26
default: {
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
done = true; // was an endgroup tag
@@ -7115,220 +8061,125 @@ public Builder mergeFrom(
}
private int bitField0_;
- private java.lang.Object endpoint_ = "";
+ private io.temporal.omes.KitchenSink.ExecuteActivityAction activity_;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ io.temporal.omes.KitchenSink.ExecuteActivityAction, io.temporal.omes.KitchenSink.ExecuteActivityAction.Builder, io.temporal.omes.KitchenSink.ExecuteActivityActionOrBuilder> activityBuilder_;
/**
- * string endpoint = 1;
- * @return The endpoint.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ * @return Whether the activity field is set.
*/
- public java.lang.String getEndpoint() {
- java.lang.Object ref = endpoint_;
- if (!(ref instanceof java.lang.String)) {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- endpoint_ = s;
- return s;
- } else {
- return (java.lang.String) ref;
- }
+ public boolean hasActivity() {
+ return ((bitField0_ & 0x00000001) != 0);
}
/**
- * string endpoint = 1;
- * @return The bytes for endpoint.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
+ * @return The activity.
*/
- public com.google.protobuf.ByteString
- getEndpointBytes() {
- java.lang.Object ref = endpoint_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- endpoint_ = b;
- return b;
+ public io.temporal.omes.KitchenSink.ExecuteActivityAction getActivity() {
+ if (activityBuilder_ == null) {
+ return activity_ == null ? io.temporal.omes.KitchenSink.ExecuteActivityAction.getDefaultInstance() : activity_;
} else {
- return (com.google.protobuf.ByteString) ref;
+ return activityBuilder_.getMessage();
}
}
/**
- * string endpoint = 1;
- * @param value The endpoint to set.
- * @return This builder for chaining.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
*/
- public Builder setEndpoint(
- java.lang.String value) {
- if (value == null) { throw new NullPointerException(); }
- endpoint_ = value;
+ public Builder setActivity(io.temporal.omes.KitchenSink.ExecuteActivityAction value) {
+ if (activityBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ activity_ = value;
+ } else {
+ activityBuilder_.setMessage(value);
+ }
bitField0_ |= 0x00000001;
onChanged();
return this;
}
/**
- * string endpoint = 1;
- * @return This builder for chaining.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
*/
- public Builder clearEndpoint() {
- endpoint_ = getDefaultInstance().getEndpoint();
- bitField0_ = (bitField0_ & ~0x00000001);
- onChanged();
- return this;
- }
- /**
- * string endpoint = 1;
- * @param value The bytes for endpoint to set.
- * @return This builder for chaining.
- */
- public Builder setEndpointBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) { throw new NullPointerException(); }
- checkByteStringIsUtf8(value);
- endpoint_ = value;
+ public Builder setActivity(
+ io.temporal.omes.KitchenSink.ExecuteActivityAction.Builder builderForValue) {
+ if (activityBuilder_ == null) {
+ activity_ = builderForValue.build();
+ } else {
+ activityBuilder_.setMessage(builderForValue.build());
+ }
bitField0_ |= 0x00000001;
onChanged();
return this;
}
-
- private java.lang.Object service_ = "";
/**
- * string service = 2;
- * @return The service.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
*/
- public java.lang.String getService() {
- java.lang.Object ref = service_;
- if (!(ref instanceof java.lang.String)) {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- service_ = s;
- return s;
+ public Builder mergeActivity(io.temporal.omes.KitchenSink.ExecuteActivityAction value) {
+ if (activityBuilder_ == null) {
+ if (((bitField0_ & 0x00000001) != 0) &&
+ activity_ != null &&
+ activity_ != io.temporal.omes.KitchenSink.ExecuteActivityAction.getDefaultInstance()) {
+ getActivityBuilder().mergeFrom(value);
+ } else {
+ activity_ = value;
+ }
} else {
- return (java.lang.String) ref;
+ activityBuilder_.mergeFrom(value);
}
- }
- /**
- * string service = 2;
- * @return The bytes for service.
- */
- public com.google.protobuf.ByteString
- getServiceBytes() {
- java.lang.Object ref = service_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- service_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
+ if (activity_ != null) {
+ bitField0_ |= 0x00000001;
+ onChanged();
}
- }
- /**
- * string service = 2;
- * @param value The service to set.
- * @return This builder for chaining.
- */
- public Builder setService(
- java.lang.String value) {
- if (value == null) { throw new NullPointerException(); }
- service_ = value;
- bitField0_ |= 0x00000002;
- onChanged();
return this;
}
/**
- * string service = 2;
- * @return This builder for chaining.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
*/
- public Builder clearService() {
- service_ = getDefaultInstance().getService();
- bitField0_ = (bitField0_ & ~0x00000002);
+ public Builder clearActivity() {
+ bitField0_ = (bitField0_ & ~0x00000001);
+ activity_ = null;
+ if (activityBuilder_ != null) {
+ activityBuilder_.dispose();
+ activityBuilder_ = null;
+ }
onChanged();
return this;
}
/**
- * string service = 2;
- * @param value The bytes for service to set.
- * @return This builder for chaining.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
*/
- public Builder setServiceBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) { throw new NullPointerException(); }
- checkByteStringIsUtf8(value);
- service_ = value;
- bitField0_ |= 0x00000002;
+ public io.temporal.omes.KitchenSink.ExecuteActivityAction.Builder getActivityBuilder() {
+ bitField0_ |= 0x00000001;
onChanged();
- return this;
+ return getActivityFieldBuilder().getBuilder();
}
-
- private java.lang.Object operation_ = "";
/**
- * string operation = 3;
- * @return The operation.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
*/
- public java.lang.String getOperation() {
- java.lang.Object ref = operation_;
- if (!(ref instanceof java.lang.String)) {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- operation_ = s;
- return s;
+ public io.temporal.omes.KitchenSink.ExecuteActivityActionOrBuilder getActivityOrBuilder() {
+ if (activityBuilder_ != null) {
+ return activityBuilder_.getMessageOrBuilder();
} else {
- return (java.lang.String) ref;
+ return activity_ == null ?
+ io.temporal.omes.KitchenSink.ExecuteActivityAction.getDefaultInstance() : activity_;
}
}
/**
- * string operation = 3;
- * @return The bytes for operation.
+ * .temporal.omes.kitchen_sink.ExecuteActivityAction activity = 1;
*/
- public com.google.protobuf.ByteString
- getOperationBytes() {
- java.lang.Object ref = operation_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- operation_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ io.temporal.omes.KitchenSink.ExecuteActivityAction, io.temporal.omes.KitchenSink.ExecuteActivityAction.Builder, io.temporal.omes.KitchenSink.ExecuteActivityActionOrBuilder>
+ getActivityFieldBuilder() {
+ if (activityBuilder_ == null) {
+ activityBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+ io.temporal.omes.KitchenSink.ExecuteActivityAction, io.temporal.omes.KitchenSink.ExecuteActivityAction.Builder, io.temporal.omes.KitchenSink.ExecuteActivityActionOrBuilder>(
+ getActivity(),
+ getParentForChildren(),
+ isClean());
+ activity_ = null;
}
- }
- /**
- * string operation = 3;
- * @param value The operation to set.
- * @return This builder for chaining.
- */
- public Builder setOperation(
- java.lang.String value) {
- if (value == null) { throw new NullPointerException(); }
- operation_ = value;
- bitField0_ |= 0x00000004;
- onChanged();
- return this;
- }
- /**
- * string operation = 3;
- * @return This builder for chaining.
- */
- public Builder clearOperation() {
- operation_ = getDefaultInstance().getOperation();
- bitField0_ = (bitField0_ & ~0x00000004);
- onChanged();
- return this;
- }
- /**
- * string operation = 3;
- * @param value The bytes for operation to set.
- * @return This builder for chaining.
- */
- public Builder setOperationBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) { throw new NullPointerException(); }
- checkByteStringIsUtf8(value);
- operation_ = value;
- bitField0_ |= 0x00000004;
- onChanged();
- return this;
+ return activityBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
@@ -7343,23 +8194,23 @@ public final Builder mergeUnknownFields(
}
- // @@protoc_insertion_point(builder_scope:temporal.omes.kitchen_sink.DoStandaloneNexusOperation)
+ // @@protoc_insertion_point(builder_scope:temporal.omes.kitchen_sink.DoStandaloneActivity)
}
- // @@protoc_insertion_point(class_scope:temporal.omes.kitchen_sink.DoStandaloneNexusOperation)
- private static final io.temporal.omes.KitchenSink.DoStandaloneNexusOperation DEFAULT_INSTANCE;
+ // @@protoc_insertion_point(class_scope:temporal.omes.kitchen_sink.DoStandaloneActivity)
+ private static final io.temporal.omes.KitchenSink.DoStandaloneActivity DEFAULT_INSTANCE;
static {
- DEFAULT_INSTANCE = new io.temporal.omes.KitchenSink.DoStandaloneNexusOperation();
+ DEFAULT_INSTANCE = new io.temporal.omes.KitchenSink.DoStandaloneActivity();
}
- public static io.temporal.omes.KitchenSink.DoStandaloneNexusOperation getDefaultInstance() {
+ public static io.temporal.omes.KitchenSink.DoStandaloneActivity getDefaultInstance() {
return DEFAULT_INSTANCE;
}
- private static final com.google.protobuf.Parser
- PARSER = new com.google.protobuf.AbstractParser() {
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
@java.lang.Override
- public DoStandaloneNexusOperation parsePartialFrom(
+ public DoStandaloneActivity parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
@@ -7378,17 +8229,17 @@ public DoStandaloneNexusOperation parsePartialFrom(
}
};
- public static com.google.protobuf.Parser parser() {
+ public static com.google.protobuf.Parser parser() {
return PARSER;
}
@java.lang.Override
- public com.google.protobuf.Parser getParserForType() {
+ public com.google.protobuf.Parser getParserForType() {
return PARSER;
}
@java.lang.Override
- public io.temporal.omes.KitchenSink.DoStandaloneNexusOperation getDefaultInstanceForType() {
+ public io.temporal.omes.KitchenSink.DoStandaloneActivity getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
@@ -54573,6 +55424,11 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
private static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_temporal_omes_kitchen_sink_DoStandaloneNexusOperation_fieldAccessorTable;
+ private static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_descriptor;
+ private static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_fieldAccessorTable;
private static final com.google.protobuf.Descriptors.Descriptor
internal_static_temporal_omes_kitchen_sink_DoSignal_descriptor;
private static final
@@ -54829,7 +55685,7 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
"do_signal\030\001 \001(\0132$.temporal.omes.kitchen_" +
"sink.DoSignalH\000\0229\n\tdo_update\030\002 \001(\0132$.tem" +
"poral.omes.kitchen_sink.DoUpdateH\000B\t\n\007va" +
- "riant\"\257\003\n\014ClientAction\0229\n\tdo_signal\030\001 \001(" +
+ "riant\"\203\004\n\014ClientAction\0229\n\tdo_signal\030\001 \001(" +
"\0132$.temporal.omes.kitchen_sink.DoSignalH" +
"\000\0227\n\010do_query\030\002 \001(\0132#.temporal.omes.kitc" +
"hen_sink.DoQueryH\000\0229\n\tdo_update\030\003 \001(\0132$." +
@@ -54839,251 +55695,256 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
"ibe\030\005 \001(\0132&.temporal.omes.kitchen_sink.D" +
"oDescribeH\000\022_\n\035do_standalone_nexus_opera" +
"tion\030\006 \001(\01326.temporal.omes.kitchen_sink." +
- "DoStandaloneNexusOperationH\000B\t\n\007variant\"" +
- "R\n\032DoStandaloneNexusOperation\022\020\n\010endpoin" +
- "t\030\001 \001(\t\022\017\n\007service\030\002 \001(\t\022\021\n\toperation\030\003 " +
- "\001(\t\"\361\002\n\010DoSignal\022Q\n\021do_signal_actions\030\001 " +
- "\001(\01324.temporal.omes.kitchen_sink.DoSigna" +
- "l.DoSignalActionsH\000\022?\n\006custom\030\002 \001(\0132-.te" +
- "mporal.omes.kitchen_sink.HandlerInvocati" +
- "onH\000\022\022\n\nwith_start\030\003 \001(\010\032\261\001\n\017DoSignalAct" +
- "ions\022;\n\ndo_actions\030\001 \001(\0132%.temporal.omes" +
- ".kitchen_sink.ActionSetH\000\022C\n\022do_actions_" +
- "in_main\030\002 \001(\0132%.temporal.omes.kitchen_si" +
- "nk.ActionSetH\000\022\021\n\tsignal_id\030\003 \001(\005B\t\n\007var" +
- "iantB\t\n\007variant\"\014\n\nDoDescribe\"\251\001\n\007DoQuer" +
- "y\0228\n\014report_state\030\001 \001(\0132 .temporal.api.c" +
- "ommon.v1.PayloadsH\000\022?\n\006custom\030\002 \001(\0132-.te" +
- "mporal.omes.kitchen_sink.HandlerInvocati" +
- "onH\000\022\030\n\020failure_expected\030\n \001(\010B\t\n\007varian" +
- "t\"\307\001\n\010DoUpdate\022A\n\ndo_actions\030\001 \001(\0132+.tem" +
- "poral.omes.kitchen_sink.DoActionsUpdateH" +
- "\000\022?\n\006custom\030\002 \001(\0132-.temporal.omes.kitche" +
- "n_sink.HandlerInvocationH\000\022\022\n\nwith_start" +
- "\030\003 \001(\010\022\030\n\020failure_expected\030\n \001(\010B\t\n\007vari" +
- "ant\"\206\001\n\017DoActionsUpdate\022;\n\ndo_actions\030\001 " +
- "\001(\0132%.temporal.omes.kitchen_sink.ActionS" +
- "etH\000\022+\n\treject_me\030\002 \001(\0132\026.google.protobu" +
- "f.EmptyH\000B\t\n\007variant\"P\n\021HandlerInvocatio" +
- "n\022\014\n\004name\030\001 \001(\t\022-\n\004args\030\002 \003(\0132\037.temporal" +
- ".api.common.v1.Payload\"|\n\rWorkflowState\022" +
- "?\n\003kvs\030\001 \003(\01322.temporal.omes.kitchen_sin" +
- "k.WorkflowState.KvsEntry\032*\n\010KvsEntry\022\013\n\003" +
- "key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\250\001\n\rWorkflo" +
- "wInput\022>\n\017initial_actions\030\001 \003(\0132%.tempor" +
- "al.omes.kitchen_sink.ActionSet\022\035\n\025expect" +
- "ed_signal_count\030\002 \001(\005\022\033\n\023expected_signal" +
- "_ids\030\003 \003(\005\022\033\n\023received_signal_ids\030\004 \003(\005\"" +
- "T\n\tActionSet\0223\n\007actions\030\001 \003(\0132\".temporal" +
- ".omes.kitchen_sink.Action\022\022\n\nconcurrent\030" +
- "\002 \001(\010\"\372\010\n\006Action\0228\n\005timer\030\001 \001(\0132\'.tempor" +
- "al.omes.kitchen_sink.TimerActionH\000\022J\n\rex" +
- "ec_activity\030\002 \001(\01321.temporal.omes.kitche" +
- "n_sink.ExecuteActivityActionH\000\022U\n\023exec_c" +
- "hild_workflow\030\003 \001(\01326.temporal.omes.kitc" +
- "hen_sink.ExecuteChildWorkflowActionH\000\022N\n" +
- "\024await_workflow_state\030\004 \001(\0132..temporal.o" +
- "mes.kitchen_sink.AwaitWorkflowStateH\000\022C\n" +
- "\013send_signal\030\005 \001(\0132,.temporal.omes.kitch" +
- "en_sink.SendSignalActionH\000\022K\n\017cancel_wor" +
- "kflow\030\006 \001(\01320.temporal.omes.kitchen_sink" +
- ".CancelWorkflowActionH\000\022L\n\020set_patch_mar" +
- "ker\030\007 \001(\01320.temporal.omes.kitchen_sink.S" +
- "etPatchMarkerActionH\000\022\\\n\030upsert_search_a" +
- "ttributes\030\010 \001(\01328.temporal.omes.kitchen_" +
- "sink.UpsertSearchAttributesActionH\000\022C\n\013u" +
- "psert_memo\030\t \001(\0132,.temporal.omes.kitchen" +
- "_sink.UpsertMemoActionH\000\022G\n\022set_workflow" +
- "_state\030\n \001(\0132).temporal.omes.kitchen_sin" +
- "k.WorkflowStateH\000\022G\n\rreturn_result\030\013 \001(\013" +
- "2..temporal.omes.kitchen_sink.ReturnResu" +
- "ltActionH\000\022E\n\014return_error\030\014 \001(\0132-.tempo" +
- "ral.omes.kitchen_sink.ReturnErrorActionH" +
- "\000\022J\n\017continue_as_new\030\r \001(\0132/.temporal.om" +
- "es.kitchen_sink.ContinueAsNewActionH\000\022B\n" +
- "\021nested_action_set\030\016 \001(\0132%.temporal.omes" +
- ".kitchen_sink.ActionSetH\000\022L\n\017nexus_opera" +
- "tion\030\017 \001(\01321.temporal.omes.kitchen_sink." +
- "ExecuteNexusOperationH\000B\t\n\007variant\"\243\002\n\017A" +
- "waitableChoice\022-\n\013wait_finish\030\001 \001(\0132\026.go" +
- "ogle.protobuf.EmptyH\000\022)\n\007abandon\030\002 \001(\0132\026" +
- ".google.protobuf.EmptyH\000\0227\n\025cancel_befor" +
- "e_started\030\003 \001(\0132\026.google.protobuf.EmptyH" +
- "\000\0226\n\024cancel_after_started\030\004 \001(\0132\026.google" +
- ".protobuf.EmptyH\000\0228\n\026cancel_after_comple" +
- "ted\030\005 \001(\0132\026.google.protobuf.EmptyH\000B\013\n\tc" +
- "ondition\"j\n\013TimerAction\022\024\n\014milliseconds\030" +
- "\001 \001(\004\022E\n\020awaitable_choice\030\002 \001(\0132+.tempor" +
- "al.omes.kitchen_sink.AwaitableChoice\"\352\021\n" +
- "\025ExecuteActivityAction\022T\n\007generic\030\001 \001(\0132" +
- "A.temporal.omes.kitchen_sink.ExecuteActi" +
- "vityAction.GenericActivityH\000\022*\n\005delay\030\002 " +
- "\001(\0132\031.google.protobuf.DurationH\000\022&\n\004noop" +
- "\030\003 \001(\0132\026.google.protobuf.EmptyH\000\022X\n\treso" +
- "urces\030\016 \001(\0132C.temporal.omes.kitchen_sink" +
- ".ExecuteActivityAction.ResourcesActivity" +
- "H\000\022T\n\007payload\030\022 \001(\0132A.temporal.omes.kitc" +
- "hen_sink.ExecuteActivityAction.PayloadAc" +
- "tivityH\000\022R\n\006client\030\023 \001(\0132@.temporal.omes" +
- ".kitchen_sink.ExecuteActivityAction.Clie" +
- "ntActivityH\000\022c\n\017retryable_error\030\024 \001(\0132H." +
- "temporal.omes.kitchen_sink.ExecuteActivi" +
- "tyAction.RetryableErrorActivityH\000\022T\n\007tim" +
- "eout\030\025 \001(\0132A.temporal.omes.kitchen_sink." +
- "ExecuteActivityAction.TimeoutActivityH\000\022" +
- "_\n\theartbeat\030\026 \001(\0132J.temporal.omes.kitch" +
- "en_sink.ExecuteActivityAction.HeartbeatT" +
- "imeoutActivityH\000\022\022\n\ntask_queue\030\004 \001(\t\022O\n\007" +
- "headers\030\005 \003(\0132>.temporal.omes.kitchen_si" +
- "nk.ExecuteActivityAction.HeadersEntry\022<\n" +
- "\031schedule_to_close_timeout\030\006 \001(\0132\031.googl" +
- "e.protobuf.Duration\022<\n\031schedule_to_start" +
- "_timeout\030\007 \001(\0132\031.google.protobuf.Duratio" +
- "n\0229\n\026start_to_close_timeout\030\010 \001(\0132\031.goog" +
- "le.protobuf.Duration\0224\n\021heartbeat_timeou" +
- "t\030\t \001(\0132\031.google.protobuf.Duration\0229\n\014re" +
- "try_policy\030\n \001(\0132#.temporal.api.common.v" +
- "1.RetryPolicy\022*\n\010is_local\030\013 \001(\0132\026.google" +
- ".protobuf.EmptyH\001\022C\n\006remote\030\014 \001(\01321.temp" +
- "oral.omes.kitchen_sink.RemoteActivityOpt" +
- "ionsH\001\022E\n\020awaitable_choice\030\r \001(\0132+.tempo" +
- "ral.omes.kitchen_sink.AwaitableChoice\0222\n" +
- "\010priority\030\017 \001(\0132 .temporal.api.common.v1" +
- ".Priority\022\024\n\014fairness_key\030\020 \001(\t\022\027\n\017fairn" +
- "ess_weight\030\021 \001(\002\032S\n\017GenericActivity\022\014\n\004t" +
- "ype\030\001 \001(\t\0222\n\targuments\030\002 \003(\0132\037.temporal." +
- "api.common.v1.Payload\032\232\001\n\021ResourcesActiv" +
- "ity\022*\n\007run_for\030\001 \001(\0132\031.google.protobuf.D" +
- "uration\022\031\n\021bytes_to_allocate\030\002 \001(\004\022$\n\034cp" +
- "u_yield_every_n_iterations\030\003 \001(\r\022\030\n\020cpu_" +
- "yield_for_ms\030\004 \001(\r\032D\n\017PayloadActivity\022\030\n" +
- "\020bytes_to_receive\030\001 \001(\005\022\027\n\017bytes_to_retu" +
- "rn\030\002 \001(\005\032U\n\016ClientActivity\022C\n\017client_seq" +
- "uence\030\001 \001(\0132*.temporal.omes.kitchen_sink" +
- ".ClientSequence\032/\n\026RetryableErrorActivit" +
- "y\022\025\n\rfail_attempts\030\001 \001(\005\032\222\001\n\017TimeoutActi" +
- "vity\022\025\n\rfail_attempts\030\001 \001(\005\0223\n\020success_d" +
- "uration\030\002 \001(\0132\031.google.protobuf.Duration" +
- "\0223\n\020failure_duration\030\003 \001(\0132\031.google.prot" +
- "obuf.Duration\032\233\001\n\030HeartbeatTimeoutActivi" +
- "ty\022\025\n\rfail_attempts\030\001 \001(\005\0223\n\020success_dur" +
- "ation\030\002 \001(\0132\031.google.protobuf.Duration\0223" +
- "\n\020failure_duration\030\003 \001(\0132\031.google.protob" +
- "uf.Duration\032O\n\014HeadersEntry\022\013\n\003key\030\001 \001(\t" +
- "\022.\n\005value\030\002 \001(\0132\037.temporal.api.common.v1" +
- ".Payload:\0028\001B\017\n\ractivity_typeB\n\n\010localit" +
- "y\"\255\n\n\032ExecuteChildWorkflowAction\022\021\n\tname" +
- "space\030\002 \001(\t\022\023\n\013workflow_id\030\003 \001(\t\022\025\n\rwork" +
- "flow_type\030\004 \001(\t\022\022\n\ntask_queue\030\005 \001(\t\022.\n\005i" +
- "nput\030\006 \003(\0132\037.temporal.api.common.v1.Payl" +
- "oad\022=\n\032workflow_execution_timeout\030\007 \001(\0132" +
- "\031.google.protobuf.Duration\0227\n\024workflow_r" +
- "un_timeout\030\010 \001(\0132\031.google.protobuf.Durat" +
- "ion\0228\n\025workflow_task_timeout\030\t \001(\0132\031.goo" +
- "gle.protobuf.Duration\022J\n\023parent_close_po" +
- "licy\030\n \001(\0162-.temporal.omes.kitchen_sink." +
- "ParentClosePolicy\022N\n\030workflow_id_reuse_p" +
- "olicy\030\014 \001(\0162,.temporal.api.enums.v1.Work" +
- "flowIdReusePolicy\0229\n\014retry_policy\030\r \001(\0132" +
- "#.temporal.api.common.v1.RetryPolicy\022\025\n\r" +
- "cron_schedule\030\016 \001(\t\022T\n\007headers\030\017 \003(\0132C.t" +
+ "DoStandaloneNexusOperationH\000\022R\n\026do_stand" +
+ "alone_activity\030\007 \001(\01320.temporal.omes.kit" +
+ "chen_sink.DoStandaloneActivityH\000B\t\n\007vari" +
+ "ant\"R\n\032DoStandaloneNexusOperation\022\020\n\010end" +
+ "point\030\001 \001(\t\022\017\n\007service\030\002 \001(\t\022\021\n\toperatio" +
+ "n\030\003 \001(\t\"[\n\024DoStandaloneActivity\022C\n\010activ" +
+ "ity\030\001 \001(\01321.temporal.omes.kitchen_sink.E" +
+ "xecuteActivityAction\"\361\002\n\010DoSignal\022Q\n\021do_" +
+ "signal_actions\030\001 \001(\01324.temporal.omes.kit" +
+ "chen_sink.DoSignal.DoSignalActionsH\000\022?\n\006" +
+ "custom\030\002 \001(\0132-.temporal.omes.kitchen_sin" +
+ "k.HandlerInvocationH\000\022\022\n\nwith_start\030\003 \001(" +
+ "\010\032\261\001\n\017DoSignalActions\022;\n\ndo_actions\030\001 \001(" +
+ "\0132%.temporal.omes.kitchen_sink.ActionSet" +
+ "H\000\022C\n\022do_actions_in_main\030\002 \001(\0132%.tempora" +
+ "l.omes.kitchen_sink.ActionSetH\000\022\021\n\tsigna" +
+ "l_id\030\003 \001(\005B\t\n\007variantB\t\n\007variant\"\014\n\nDoDe" +
+ "scribe\"\251\001\n\007DoQuery\0228\n\014report_state\030\001 \001(\013" +
+ "2 .temporal.api.common.v1.PayloadsH\000\022?\n\006" +
+ "custom\030\002 \001(\0132-.temporal.omes.kitchen_sin" +
+ "k.HandlerInvocationH\000\022\030\n\020failure_expecte" +
+ "d\030\n \001(\010B\t\n\007variant\"\307\001\n\010DoUpdate\022A\n\ndo_ac" +
+ "tions\030\001 \001(\0132+.temporal.omes.kitchen_sink" +
+ ".DoActionsUpdateH\000\022?\n\006custom\030\002 \001(\0132-.tem" +
+ "poral.omes.kitchen_sink.HandlerInvocatio" +
+ "nH\000\022\022\n\nwith_start\030\003 \001(\010\022\030\n\020failure_expec" +
+ "ted\030\n \001(\010B\t\n\007variant\"\206\001\n\017DoActionsUpdate" +
+ "\022;\n\ndo_actions\030\001 \001(\0132%.temporal.omes.kit" +
+ "chen_sink.ActionSetH\000\022+\n\treject_me\030\002 \001(\013" +
+ "2\026.google.protobuf.EmptyH\000B\t\n\007variant\"P\n" +
+ "\021HandlerInvocation\022\014\n\004name\030\001 \001(\t\022-\n\004args" +
+ "\030\002 \003(\0132\037.temporal.api.common.v1.Payload\"" +
+ "|\n\rWorkflowState\022?\n\003kvs\030\001 \003(\01322.temporal" +
+ ".omes.kitchen_sink.WorkflowState.KvsEntr" +
+ "y\032*\n\010KvsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(" +
+ "\t:\0028\001\"\250\001\n\rWorkflowInput\022>\n\017initial_actio" +
+ "ns\030\001 \003(\0132%.temporal.omes.kitchen_sink.Ac" +
+ "tionSet\022\035\n\025expected_signal_count\030\002 \001(\005\022\033" +
+ "\n\023expected_signal_ids\030\003 \003(\005\022\033\n\023received_" +
+ "signal_ids\030\004 \003(\005\"T\n\tActionSet\0223\n\007actions" +
+ "\030\001 \003(\0132\".temporal.omes.kitchen_sink.Acti" +
+ "on\022\022\n\nconcurrent\030\002 \001(\010\"\372\010\n\006Action\0228\n\005tim" +
+ "er\030\001 \001(\0132\'.temporal.omes.kitchen_sink.Ti" +
+ "merActionH\000\022J\n\rexec_activity\030\002 \001(\01321.tem" +
+ "poral.omes.kitchen_sink.ExecuteActivityA" +
+ "ctionH\000\022U\n\023exec_child_workflow\030\003 \001(\01326.t" +
"emporal.omes.kitchen_sink.ExecuteChildWo" +
- "rkflowAction.HeadersEntry\022N\n\004memo\030\020 \003(\0132" +
- "@.temporal.omes.kitchen_sink.ExecuteChil" +
- "dWorkflowAction.MemoEntry\022g\n\021search_attr" +
- "ibutes\030\021 \003(\0132L.temporal.omes.kitchen_sin" +
- "k.ExecuteChildWorkflowAction.SearchAttri" +
- "butesEntry\022T\n\021cancellation_type\030\022 \001(\01629." +
- "temporal.omes.kitchen_sink.ChildWorkflow" +
- "CancellationType\022G\n\021versioning_intent\030\023 " +
- "\001(\0162,.temporal.omes.kitchen_sink.Version" +
- "ingIntent\022E\n\020awaitable_choice\030\024 \001(\0132+.te" +
- "mporal.omes.kitchen_sink.AwaitableChoice" +
- "\032O\n\014HeadersEntry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002" +
- " \001(\0132\037.temporal.api.common.v1.Payload:\0028" +
- "\001\032L\n\tMemoEntry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001" +
- "(\0132\037.temporal.api.common.v1.Payload:\0028\001\032" +
- "X\n\025SearchAttributesEntry\022\013\n\003key\030\001 \001(\t\022.\n" +
- "\005value\030\002 \001(\0132\037.temporal.api.common.v1.Pa" +
- "yload:\0028\001\"0\n\022AwaitWorkflowState\022\013\n\003key\030\001" +
- " \001(\t\022\r\n\005value\030\002 \001(\t\"\337\002\n\020SendSignalAction" +
- "\022\023\n\013workflow_id\030\001 \001(\t\022\016\n\006run_id\030\002 \001(\t\022\023\n" +
- "\013signal_name\030\003 \001(\t\022-\n\004args\030\004 \003(\0132\037.tempo" +
- "ral.api.common.v1.Payload\022J\n\007headers\030\005 \003" +
- "(\01329.temporal.omes.kitchen_sink.SendSign" +
- "alAction.HeadersEntry\022E\n\020awaitable_choic" +
- "e\030\006 \001(\0132+.temporal.omes.kitchen_sink.Awa" +
- "itableChoice\032O\n\014HeadersEntry\022\013\n\003key\030\001 \001(" +
- "\t\022.\n\005value\030\002 \001(\0132\037.temporal.api.common.v" +
- "1.Payload:\0028\001\";\n\024CancelWorkflowAction\022\023\n" +
- "\013workflow_id\030\001 \001(\t\022\016\n\006run_id\030\002 \001(\t\"v\n\024Se" +
- "tPatchMarkerAction\022\020\n\010patch_id\030\001 \001(\t\022\022\n\n" +
- "deprecated\030\002 \001(\010\0228\n\014inner_action\030\003 \001(\0132\"" +
- ".temporal.omes.kitchen_sink.Action\"\343\001\n\034U" +
- "psertSearchAttributesAction\022i\n\021search_at" +
- "tributes\030\001 \003(\0132N.temporal.omes.kitchen_s" +
- "ink.UpsertSearchAttributesAction.SearchA" +
- "ttributesEntry\032X\n\025SearchAttributesEntry\022" +
- "\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.temporal.a" +
- "pi.common.v1.Payload:\0028\001\"G\n\020UpsertMemoAc" +
- "tion\0223\n\rupserted_memo\030\001 \001(\0132\034.temporal.a" +
- "pi.common.v1.Memo\"J\n\022ReturnResultAction\022" +
- "4\n\013return_this\030\001 \001(\0132\037.temporal.api.comm" +
- "on.v1.Payload\"F\n\021ReturnErrorAction\0221\n\007fa" +
- "ilure\030\001 \001(\0132 .temporal.api.failure.v1.Fa" +
- "ilure\"\336\006\n\023ContinueAsNewAction\022\025\n\rworkflo" +
- "w_type\030\001 \001(\t\022\022\n\ntask_queue\030\002 \001(\t\0222\n\targu" +
- "ments\030\003 \003(\0132\037.temporal.api.common.v1.Pay" +
- "load\0227\n\024workflow_run_timeout\030\004 \001(\0132\031.goo" +
- "gle.protobuf.Duration\0228\n\025workflow_task_t" +
- "imeout\030\005 \001(\0132\031.google.protobuf.Duration\022" +
- "G\n\004memo\030\006 \003(\01329.temporal.omes.kitchen_si" +
- "nk.ContinueAsNewAction.MemoEntry\022M\n\007head" +
- "ers\030\007 \003(\0132<.temporal.omes.kitchen_sink.C" +
- "ontinueAsNewAction.HeadersEntry\022`\n\021searc" +
- "h_attributes\030\010 \003(\0132E.temporal.omes.kitch" +
- "en_sink.ContinueAsNewAction.SearchAttrib" +
- "utesEntry\0229\n\014retry_policy\030\t \001(\0132#.tempor" +
- "al.api.common.v1.RetryPolicy\022G\n\021versioni" +
- "ng_intent\030\n \001(\0162,.temporal.omes.kitchen_" +
- "sink.VersioningIntent\032L\n\tMemoEntry\022\013\n\003ke" +
- "y\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.temporal.api.co" +
- "mmon.v1.Payload:\0028\001\032O\n\014HeadersEntry\022\013\n\003k" +
- "ey\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.temporal.api.c" +
- "ommon.v1.Payload:\0028\001\032X\n\025SearchAttributes" +
- "Entry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.temp" +
- "oral.api.common.v1.Payload:\0028\001\"\321\001\n\025Remot" +
- "eActivityOptions\022O\n\021cancellation_type\030\001 " +
- "\001(\01624.temporal.omes.kitchen_sink.Activit" +
- "yCancellationType\022\036\n\026do_not_eagerly_exec" +
- "ute\030\002 \001(\010\022G\n\021versioning_intent\030\003 \001(\0162,.t" +
- "emporal.omes.kitchen_sink.VersioningInte" +
- "nt\"\353\002\n\025ExecuteNexusOperation\022\020\n\010endpoint" +
- "\030\001 \001(\t\022\021\n\toperation\030\002 \001(\t\022\r\n\005input\030\003 \001(\t" +
- "\022O\n\007headers\030\004 \003(\0132>.temporal.omes.kitche" +
- "n_sink.ExecuteNexusOperation.HeadersEntr" +
- "y\022E\n\020awaitable_choice\030\005 \001(\0132+.temporal.o" +
- "mes.kitchen_sink.AwaitableChoice\022\027\n\017expe" +
- "cted_output\030\006 \001(\t\022=\n\016before_actions\030\007 \003(" +
+ "rkflowActionH\000\022N\n\024await_workflow_state\030\004" +
+ " \001(\0132..temporal.omes.kitchen_sink.AwaitW" +
+ "orkflowStateH\000\022C\n\013send_signal\030\005 \001(\0132,.te" +
+ "mporal.omes.kitchen_sink.SendSignalActio" +
+ "nH\000\022K\n\017cancel_workflow\030\006 \001(\01320.temporal." +
+ "omes.kitchen_sink.CancelWorkflowActionH\000" +
+ "\022L\n\020set_patch_marker\030\007 \001(\01320.temporal.om" +
+ "es.kitchen_sink.SetPatchMarkerActionH\000\022\\" +
+ "\n\030upsert_search_attributes\030\010 \001(\01328.tempo" +
+ "ral.omes.kitchen_sink.UpsertSearchAttrib" +
+ "utesActionH\000\022C\n\013upsert_memo\030\t \001(\0132,.temp" +
+ "oral.omes.kitchen_sink.UpsertMemoActionH" +
+ "\000\022G\n\022set_workflow_state\030\n \001(\0132).temporal" +
+ ".omes.kitchen_sink.WorkflowStateH\000\022G\n\rre" +
+ "turn_result\030\013 \001(\0132..temporal.omes.kitche" +
+ "n_sink.ReturnResultActionH\000\022E\n\014return_er" +
+ "ror\030\014 \001(\0132-.temporal.omes.kitchen_sink.R" +
+ "eturnErrorActionH\000\022J\n\017continue_as_new\030\r " +
+ "\001(\0132/.temporal.omes.kitchen_sink.Continu" +
+ "eAsNewActionH\000\022B\n\021nested_action_set\030\016 \001(" +
"\0132%.temporal.omes.kitchen_sink.ActionSet" +
- "\032.\n\014HeadersEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002" +
- " \001(\t:\0028\001\"a\n\021NexusHandlerInput\022\r\n\005input\030\001" +
- " \001(\t\022=\n\016before_actions\030\002 \003(\0132%.temporal." +
- "omes.kitchen_sink.ActionSet*\244\001\n\021ParentCl" +
- "osePolicy\022#\n\037PARENT_CLOSE_POLICY_UNSPECI" +
- "FIED\020\000\022!\n\035PARENT_CLOSE_POLICY_TERMINATE\020" +
- "\001\022\037\n\033PARENT_CLOSE_POLICY_ABANDON\020\002\022&\n\"PA" +
- "RENT_CLOSE_POLICY_REQUEST_CANCEL\020\003*@\n\020Ve" +
- "rsioningIntent\022\017\n\013UNSPECIFIED\020\000\022\016\n\nCOMPA" +
- "TIBLE\020\001\022\013\n\007DEFAULT\020\002*\242\001\n\035ChildWorkflowCa" +
- "ncellationType\022\024\n\020CHILD_WF_ABANDON\020\000\022\027\n\023" +
- "CHILD_WF_TRY_CANCEL\020\001\022(\n$CHILD_WF_WAIT_C" +
- "ANCELLATION_COMPLETED\020\002\022(\n$CHILD_WF_WAIT" +
- "_CANCELLATION_REQUESTED\020\003*X\n\030ActivityCan" +
- "cellationType\022\016\n\nTRY_CANCEL\020\000\022\037\n\033WAIT_CA" +
- "NCELLATION_COMPLETED\020\001\022\013\n\007ABANDON\020\002BB\n\020i" +
- "o.temporal.omesZ.github.com/temporalio/o" +
- "mes/loadgen/kitchensinkb\006proto3"
+ "H\000\022L\n\017nexus_operation\030\017 \001(\01321.temporal.o" +
+ "mes.kitchen_sink.ExecuteNexusOperationH\000" +
+ "B\t\n\007variant\"\243\002\n\017AwaitableChoice\022-\n\013wait_" +
+ "finish\030\001 \001(\0132\026.google.protobuf.EmptyH\000\022)" +
+ "\n\007abandon\030\002 \001(\0132\026.google.protobuf.EmptyH" +
+ "\000\0227\n\025cancel_before_started\030\003 \001(\0132\026.googl" +
+ "e.protobuf.EmptyH\000\0226\n\024cancel_after_start" +
+ "ed\030\004 \001(\0132\026.google.protobuf.EmptyH\000\0228\n\026ca" +
+ "ncel_after_completed\030\005 \001(\0132\026.google.prot" +
+ "obuf.EmptyH\000B\013\n\tcondition\"j\n\013TimerAction" +
+ "\022\024\n\014milliseconds\030\001 \001(\004\022E\n\020awaitable_choi" +
+ "ce\030\002 \001(\0132+.temporal.omes.kitchen_sink.Aw" +
+ "aitableChoice\"\352\021\n\025ExecuteActivityAction\022" +
+ "T\n\007generic\030\001 \001(\0132A.temporal.omes.kitchen" +
+ "_sink.ExecuteActivityAction.GenericActiv" +
+ "ityH\000\022*\n\005delay\030\002 \001(\0132\031.google.protobuf.D" +
+ "urationH\000\022&\n\004noop\030\003 \001(\0132\026.google.protobu" +
+ "f.EmptyH\000\022X\n\tresources\030\016 \001(\0132C.temporal." +
+ "omes.kitchen_sink.ExecuteActivityAction." +
+ "ResourcesActivityH\000\022T\n\007payload\030\022 \001(\0132A.t" +
+ "emporal.omes.kitchen_sink.ExecuteActivit" +
+ "yAction.PayloadActivityH\000\022R\n\006client\030\023 \001(" +
+ "\0132@.temporal.omes.kitchen_sink.ExecuteAc" +
+ "tivityAction.ClientActivityH\000\022c\n\017retryab" +
+ "le_error\030\024 \001(\0132H.temporal.omes.kitchen_s" +
+ "ink.ExecuteActivityAction.RetryableError" +
+ "ActivityH\000\022T\n\007timeout\030\025 \001(\0132A.temporal.o" +
+ "mes.kitchen_sink.ExecuteActivityAction.T" +
+ "imeoutActivityH\000\022_\n\theartbeat\030\026 \001(\0132J.te" +
+ "mporal.omes.kitchen_sink.ExecuteActivity" +
+ "Action.HeartbeatTimeoutActivityH\000\022\022\n\ntas" +
+ "k_queue\030\004 \001(\t\022O\n\007headers\030\005 \003(\0132>.tempora" +
+ "l.omes.kitchen_sink.ExecuteActivityActio" +
+ "n.HeadersEntry\022<\n\031schedule_to_close_time" +
+ "out\030\006 \001(\0132\031.google.protobuf.Duration\022<\n\031" +
+ "schedule_to_start_timeout\030\007 \001(\0132\031.google" +
+ ".protobuf.Duration\0229\n\026start_to_close_tim" +
+ "eout\030\010 \001(\0132\031.google.protobuf.Duration\0224\n" +
+ "\021heartbeat_timeout\030\t \001(\0132\031.google.protob" +
+ "uf.Duration\0229\n\014retry_policy\030\n \001(\0132#.temp" +
+ "oral.api.common.v1.RetryPolicy\022*\n\010is_loc" +
+ "al\030\013 \001(\0132\026.google.protobuf.EmptyH\001\022C\n\006re" +
+ "mote\030\014 \001(\01321.temporal.omes.kitchen_sink." +
+ "RemoteActivityOptionsH\001\022E\n\020awaitable_cho" +
+ "ice\030\r \001(\0132+.temporal.omes.kitchen_sink.A" +
+ "waitableChoice\0222\n\010priority\030\017 \001(\0132 .tempo" +
+ "ral.api.common.v1.Priority\022\024\n\014fairness_k" +
+ "ey\030\020 \001(\t\022\027\n\017fairness_weight\030\021 \001(\002\032S\n\017Gen" +
+ "ericActivity\022\014\n\004type\030\001 \001(\t\0222\n\targuments\030" +
+ "\002 \003(\0132\037.temporal.api.common.v1.Payload\032\232" +
+ "\001\n\021ResourcesActivity\022*\n\007run_for\030\001 \001(\0132\031." +
+ "google.protobuf.Duration\022\031\n\021bytes_to_all" +
+ "ocate\030\002 \001(\004\022$\n\034cpu_yield_every_n_iterati" +
+ "ons\030\003 \001(\r\022\030\n\020cpu_yield_for_ms\030\004 \001(\r\032D\n\017P" +
+ "ayloadActivity\022\030\n\020bytes_to_receive\030\001 \001(\005" +
+ "\022\027\n\017bytes_to_return\030\002 \001(\005\032U\n\016ClientActiv" +
+ "ity\022C\n\017client_sequence\030\001 \001(\0132*.temporal." +
+ "omes.kitchen_sink.ClientSequence\032/\n\026Retr" +
+ "yableErrorActivity\022\025\n\rfail_attempts\030\001 \001(" +
+ "\005\032\222\001\n\017TimeoutActivity\022\025\n\rfail_attempts\030\001" +
+ " \001(\005\0223\n\020success_duration\030\002 \001(\0132\031.google." +
+ "protobuf.Duration\0223\n\020failure_duration\030\003 " +
+ "\001(\0132\031.google.protobuf.Duration\032\233\001\n\030Heart" +
+ "beatTimeoutActivity\022\025\n\rfail_attempts\030\001 \001" +
+ "(\005\0223\n\020success_duration\030\002 \001(\0132\031.google.pr" +
+ "otobuf.Duration\0223\n\020failure_duration\030\003 \001(" +
+ "\0132\031.google.protobuf.Duration\032O\n\014HeadersE" +
+ "ntry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.tempo" +
+ "ral.api.common.v1.Payload:\0028\001B\017\n\ractivit" +
+ "y_typeB\n\n\010locality\"\255\n\n\032ExecuteChildWorkf" +
+ "lowAction\022\021\n\tnamespace\030\002 \001(\t\022\023\n\013workflow" +
+ "_id\030\003 \001(\t\022\025\n\rworkflow_type\030\004 \001(\t\022\022\n\ntask" +
+ "_queue\030\005 \001(\t\022.\n\005input\030\006 \003(\0132\037.temporal.a" +
+ "pi.common.v1.Payload\022=\n\032workflow_executi" +
+ "on_timeout\030\007 \001(\0132\031.google.protobuf.Durat" +
+ "ion\0227\n\024workflow_run_timeout\030\010 \001(\0132\031.goog" +
+ "le.protobuf.Duration\0228\n\025workflow_task_ti" +
+ "meout\030\t \001(\0132\031.google.protobuf.Duration\022J" +
+ "\n\023parent_close_policy\030\n \001(\0162-.temporal.o" +
+ "mes.kitchen_sink.ParentClosePolicy\022N\n\030wo" +
+ "rkflow_id_reuse_policy\030\014 \001(\0162,.temporal." +
+ "api.enums.v1.WorkflowIdReusePolicy\0229\n\014re" +
+ "try_policy\030\r \001(\0132#.temporal.api.common.v" +
+ "1.RetryPolicy\022\025\n\rcron_schedule\030\016 \001(\t\022T\n\007" +
+ "headers\030\017 \003(\0132C.temporal.omes.kitchen_si" +
+ "nk.ExecuteChildWorkflowAction.HeadersEnt" +
+ "ry\022N\n\004memo\030\020 \003(\0132@.temporal.omes.kitchen" +
+ "_sink.ExecuteChildWorkflowAction.MemoEnt" +
+ "ry\022g\n\021search_attributes\030\021 \003(\0132L.temporal" +
+ ".omes.kitchen_sink.ExecuteChildWorkflowA" +
+ "ction.SearchAttributesEntry\022T\n\021cancellat" +
+ "ion_type\030\022 \001(\01629.temporal.omes.kitchen_s" +
+ "ink.ChildWorkflowCancellationType\022G\n\021ver" +
+ "sioning_intent\030\023 \001(\0162,.temporal.omes.kit" +
+ "chen_sink.VersioningIntent\022E\n\020awaitable_" +
+ "choice\030\024 \001(\0132+.temporal.omes.kitchen_sin" +
+ "k.AwaitableChoice\032O\n\014HeadersEntry\022\013\n\003key" +
+ "\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.temporal.api.com" +
+ "mon.v1.Payload:\0028\001\032L\n\tMemoEntry\022\013\n\003key\030\001" +
+ " \001(\t\022.\n\005value\030\002 \001(\0132\037.temporal.api.commo" +
+ "n.v1.Payload:\0028\001\032X\n\025SearchAttributesEntr" +
+ "y\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.temporal" +
+ ".api.common.v1.Payload:\0028\001\"0\n\022AwaitWorkf" +
+ "lowState\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t\"\337\002\n" +
+ "\020SendSignalAction\022\023\n\013workflow_id\030\001 \001(\t\022\016" +
+ "\n\006run_id\030\002 \001(\t\022\023\n\013signal_name\030\003 \001(\t\022-\n\004a" +
+ "rgs\030\004 \003(\0132\037.temporal.api.common.v1.Paylo" +
+ "ad\022J\n\007headers\030\005 \003(\01329.temporal.omes.kitc" +
+ "hen_sink.SendSignalAction.HeadersEntry\022E" +
+ "\n\020awaitable_choice\030\006 \001(\0132+.temporal.omes" +
+ ".kitchen_sink.AwaitableChoice\032O\n\014Headers" +
+ "Entry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001(\0132\037.temp" +
+ "oral.api.common.v1.Payload:\0028\001\";\n\024Cancel" +
+ "WorkflowAction\022\023\n\013workflow_id\030\001 \001(\t\022\016\n\006r" +
+ "un_id\030\002 \001(\t\"v\n\024SetPatchMarkerAction\022\020\n\010p" +
+ "atch_id\030\001 \001(\t\022\022\n\ndeprecated\030\002 \001(\010\0228\n\014inn" +
+ "er_action\030\003 \001(\0132\".temporal.omes.kitchen_" +
+ "sink.Action\"\343\001\n\034UpsertSearchAttributesAc" +
+ "tion\022i\n\021search_attributes\030\001 \003(\0132N.tempor" +
+ "al.omes.kitchen_sink.UpsertSearchAttribu" +
+ "tesAction.SearchAttributesEntry\032X\n\025Searc" +
+ "hAttributesEntry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002" +
+ " \001(\0132\037.temporal.api.common.v1.Payload:\0028" +
+ "\001\"G\n\020UpsertMemoAction\0223\n\rupserted_memo\030\001" +
+ " \001(\0132\034.temporal.api.common.v1.Memo\"J\n\022Re" +
+ "turnResultAction\0224\n\013return_this\030\001 \001(\0132\037." +
+ "temporal.api.common.v1.Payload\"F\n\021Return" +
+ "ErrorAction\0221\n\007failure\030\001 \001(\0132 .temporal." +
+ "api.failure.v1.Failure\"\336\006\n\023ContinueAsNew" +
+ "Action\022\025\n\rworkflow_type\030\001 \001(\t\022\022\n\ntask_qu" +
+ "eue\030\002 \001(\t\0222\n\targuments\030\003 \003(\0132\037.temporal." +
+ "api.common.v1.Payload\0227\n\024workflow_run_ti" +
+ "meout\030\004 \001(\0132\031.google.protobuf.Duration\0228" +
+ "\n\025workflow_task_timeout\030\005 \001(\0132\031.google.p" +
+ "rotobuf.Duration\022G\n\004memo\030\006 \003(\01329.tempora" +
+ "l.omes.kitchen_sink.ContinueAsNewAction." +
+ "MemoEntry\022M\n\007headers\030\007 \003(\0132<.temporal.om" +
+ "es.kitchen_sink.ContinueAsNewAction.Head" +
+ "ersEntry\022`\n\021search_attributes\030\010 \003(\0132E.te" +
+ "mporal.omes.kitchen_sink.ContinueAsNewAc" +
+ "tion.SearchAttributesEntry\0229\n\014retry_poli" +
+ "cy\030\t \001(\0132#.temporal.api.common.v1.RetryP" +
+ "olicy\022G\n\021versioning_intent\030\n \001(\0162,.tempo" +
+ "ral.omes.kitchen_sink.VersioningIntent\032L" +
+ "\n\tMemoEntry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001(\0132" +
+ "\037.temporal.api.common.v1.Payload:\0028\001\032O\n\014" +
+ "HeadersEntry\022\013\n\003key\030\001 \001(\t\022.\n\005value\030\002 \001(\013" +
+ "2\037.temporal.api.common.v1.Payload:\0028\001\032X\n" +
+ "\025SearchAttributesEntry\022\013\n\003key\030\001 \001(\t\022.\n\005v" +
+ "alue\030\002 \001(\0132\037.temporal.api.common.v1.Payl" +
+ "oad:\0028\001\"\321\001\n\025RemoteActivityOptions\022O\n\021can" +
+ "cellation_type\030\001 \001(\01624.temporal.omes.kit" +
+ "chen_sink.ActivityCancellationType\022\036\n\026do" +
+ "_not_eagerly_execute\030\002 \001(\010\022G\n\021versioning" +
+ "_intent\030\003 \001(\0162,.temporal.omes.kitchen_si" +
+ "nk.VersioningIntent\"\353\002\n\025ExecuteNexusOper" +
+ "ation\022\020\n\010endpoint\030\001 \001(\t\022\021\n\toperation\030\002 \001" +
+ "(\t\022\r\n\005input\030\003 \001(\t\022O\n\007headers\030\004 \003(\0132>.tem" +
+ "poral.omes.kitchen_sink.ExecuteNexusOper" +
+ "ation.HeadersEntry\022E\n\020awaitable_choice\030\005" +
+ " \001(\0132+.temporal.omes.kitchen_sink.Awaita" +
+ "bleChoice\022\027\n\017expected_output\030\006 \001(\t\022=\n\016be" +
+ "fore_actions\030\007 \003(\0132%.temporal.omes.kitch" +
+ "en_sink.ActionSet\032.\n\014HeadersEntry\022\013\n\003key" +
+ "\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"a\n\021NexusHandle" +
+ "rInput\022\r\n\005input\030\001 \001(\t\022=\n\016before_actions\030" +
+ "\002 \003(\0132%.temporal.omes.kitchen_sink.Actio" +
+ "nSet*\244\001\n\021ParentClosePolicy\022#\n\037PARENT_CLO" +
+ "SE_POLICY_UNSPECIFIED\020\000\022!\n\035PARENT_CLOSE_" +
+ "POLICY_TERMINATE\020\001\022\037\n\033PARENT_CLOSE_POLIC" +
+ "Y_ABANDON\020\002\022&\n\"PARENT_CLOSE_POLICY_REQUE" +
+ "ST_CANCEL\020\003*@\n\020VersioningIntent\022\017\n\013UNSPE" +
+ "CIFIED\020\000\022\016\n\nCOMPATIBLE\020\001\022\013\n\007DEFAULT\020\002*\242\001" +
+ "\n\035ChildWorkflowCancellationType\022\024\n\020CHILD" +
+ "_WF_ABANDON\020\000\022\027\n\023CHILD_WF_TRY_CANCEL\020\001\022(" +
+ "\n$CHILD_WF_WAIT_CANCELLATION_COMPLETED\020\002" +
+ "\022(\n$CHILD_WF_WAIT_CANCELLATION_REQUESTED" +
+ "\020\003*X\n\030ActivityCancellationType\022\016\n\nTRY_CA" +
+ "NCEL\020\000\022\037\n\033WAIT_CANCELLATION_COMPLETED\020\001\022" +
+ "\013\n\007ABANDON\020\002BB\n\020io.temporal.omesZ.github" +
+ ".com/temporalio/omes/loadgen/kitchensink" +
+ "b\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -55123,15 +55984,21 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_ClientAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ClientAction_descriptor,
- new java.lang.String[] { "DoSignal", "DoQuery", "DoUpdate", "NestedActions", "DoDescribe", "DoStandaloneNexusOperation", "Variant", });
+ new java.lang.String[] { "DoSignal", "DoQuery", "DoUpdate", "NestedActions", "DoDescribe", "DoStandaloneNexusOperation", "DoStandaloneActivity", "Variant", });
internal_static_temporal_omes_kitchen_sink_DoStandaloneNexusOperation_descriptor =
getDescriptor().getMessageTypes().get(5);
internal_static_temporal_omes_kitchen_sink_DoStandaloneNexusOperation_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_DoStandaloneNexusOperation_descriptor,
new java.lang.String[] { "Endpoint", "Service", "Operation", });
- internal_static_temporal_omes_kitchen_sink_DoSignal_descriptor =
+ internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_descriptor =
getDescriptor().getMessageTypes().get(6);
+ internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_temporal_omes_kitchen_sink_DoStandaloneActivity_descriptor,
+ new java.lang.String[] { "Activity", });
+ internal_static_temporal_omes_kitchen_sink_DoSignal_descriptor =
+ getDescriptor().getMessageTypes().get(7);
internal_static_temporal_omes_kitchen_sink_DoSignal_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_DoSignal_descriptor,
@@ -55143,37 +56010,37 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_DoSignal_DoSignalActions_descriptor,
new java.lang.String[] { "DoActions", "DoActionsInMain", "SignalId", "Variant", });
internal_static_temporal_omes_kitchen_sink_DoDescribe_descriptor =
- getDescriptor().getMessageTypes().get(7);
+ getDescriptor().getMessageTypes().get(8);
internal_static_temporal_omes_kitchen_sink_DoDescribe_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_DoDescribe_descriptor,
new java.lang.String[] { });
internal_static_temporal_omes_kitchen_sink_DoQuery_descriptor =
- getDescriptor().getMessageTypes().get(8);
+ getDescriptor().getMessageTypes().get(9);
internal_static_temporal_omes_kitchen_sink_DoQuery_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_DoQuery_descriptor,
new java.lang.String[] { "ReportState", "Custom", "FailureExpected", "Variant", });
internal_static_temporal_omes_kitchen_sink_DoUpdate_descriptor =
- getDescriptor().getMessageTypes().get(9);
+ getDescriptor().getMessageTypes().get(10);
internal_static_temporal_omes_kitchen_sink_DoUpdate_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_DoUpdate_descriptor,
new java.lang.String[] { "DoActions", "Custom", "WithStart", "FailureExpected", "Variant", });
internal_static_temporal_omes_kitchen_sink_DoActionsUpdate_descriptor =
- getDescriptor().getMessageTypes().get(10);
+ getDescriptor().getMessageTypes().get(11);
internal_static_temporal_omes_kitchen_sink_DoActionsUpdate_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_DoActionsUpdate_descriptor,
new java.lang.String[] { "DoActions", "RejectMe", "Variant", });
internal_static_temporal_omes_kitchen_sink_HandlerInvocation_descriptor =
- getDescriptor().getMessageTypes().get(11);
+ getDescriptor().getMessageTypes().get(12);
internal_static_temporal_omes_kitchen_sink_HandlerInvocation_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_HandlerInvocation_descriptor,
new java.lang.String[] { "Name", "Args", });
internal_static_temporal_omes_kitchen_sink_WorkflowState_descriptor =
- getDescriptor().getMessageTypes().get(12);
+ getDescriptor().getMessageTypes().get(13);
internal_static_temporal_omes_kitchen_sink_WorkflowState_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_WorkflowState_descriptor,
@@ -55185,37 +56052,37 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_WorkflowState_KvsEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_WorkflowInput_descriptor =
- getDescriptor().getMessageTypes().get(13);
+ getDescriptor().getMessageTypes().get(14);
internal_static_temporal_omes_kitchen_sink_WorkflowInput_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_WorkflowInput_descriptor,
new java.lang.String[] { "InitialActions", "ExpectedSignalCount", "ExpectedSignalIds", "ReceivedSignalIds", });
internal_static_temporal_omes_kitchen_sink_ActionSet_descriptor =
- getDescriptor().getMessageTypes().get(14);
+ getDescriptor().getMessageTypes().get(15);
internal_static_temporal_omes_kitchen_sink_ActionSet_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ActionSet_descriptor,
new java.lang.String[] { "Actions", "Concurrent", });
internal_static_temporal_omes_kitchen_sink_Action_descriptor =
- getDescriptor().getMessageTypes().get(15);
+ getDescriptor().getMessageTypes().get(16);
internal_static_temporal_omes_kitchen_sink_Action_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_Action_descriptor,
new java.lang.String[] { "Timer", "ExecActivity", "ExecChildWorkflow", "AwaitWorkflowState", "SendSignal", "CancelWorkflow", "SetPatchMarker", "UpsertSearchAttributes", "UpsertMemo", "SetWorkflowState", "ReturnResult", "ReturnError", "ContinueAsNew", "NestedActionSet", "NexusOperation", "Variant", });
internal_static_temporal_omes_kitchen_sink_AwaitableChoice_descriptor =
- getDescriptor().getMessageTypes().get(16);
+ getDescriptor().getMessageTypes().get(17);
internal_static_temporal_omes_kitchen_sink_AwaitableChoice_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_AwaitableChoice_descriptor,
new java.lang.String[] { "WaitFinish", "Abandon", "CancelBeforeStarted", "CancelAfterStarted", "CancelAfterCompleted", "Condition", });
internal_static_temporal_omes_kitchen_sink_TimerAction_descriptor =
- getDescriptor().getMessageTypes().get(17);
+ getDescriptor().getMessageTypes().get(18);
internal_static_temporal_omes_kitchen_sink_TimerAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_TimerAction_descriptor,
new java.lang.String[] { "Milliseconds", "AwaitableChoice", });
internal_static_temporal_omes_kitchen_sink_ExecuteActivityAction_descriptor =
- getDescriptor().getMessageTypes().get(18);
+ getDescriptor().getMessageTypes().get(19);
internal_static_temporal_omes_kitchen_sink_ExecuteActivityAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ExecuteActivityAction_descriptor,
@@ -55269,7 +56136,7 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_ExecuteActivityAction_HeadersEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_ExecuteChildWorkflowAction_descriptor =
- getDescriptor().getMessageTypes().get(19);
+ getDescriptor().getMessageTypes().get(20);
internal_static_temporal_omes_kitchen_sink_ExecuteChildWorkflowAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ExecuteChildWorkflowAction_descriptor,
@@ -55293,13 +56160,13 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_ExecuteChildWorkflowAction_SearchAttributesEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_AwaitWorkflowState_descriptor =
- getDescriptor().getMessageTypes().get(20);
+ getDescriptor().getMessageTypes().get(21);
internal_static_temporal_omes_kitchen_sink_AwaitWorkflowState_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_AwaitWorkflowState_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_SendSignalAction_descriptor =
- getDescriptor().getMessageTypes().get(21);
+ getDescriptor().getMessageTypes().get(22);
internal_static_temporal_omes_kitchen_sink_SendSignalAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_SendSignalAction_descriptor,
@@ -55311,19 +56178,19 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_SendSignalAction_HeadersEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_CancelWorkflowAction_descriptor =
- getDescriptor().getMessageTypes().get(22);
+ getDescriptor().getMessageTypes().get(23);
internal_static_temporal_omes_kitchen_sink_CancelWorkflowAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_CancelWorkflowAction_descriptor,
new java.lang.String[] { "WorkflowId", "RunId", });
internal_static_temporal_omes_kitchen_sink_SetPatchMarkerAction_descriptor =
- getDescriptor().getMessageTypes().get(23);
+ getDescriptor().getMessageTypes().get(24);
internal_static_temporal_omes_kitchen_sink_SetPatchMarkerAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_SetPatchMarkerAction_descriptor,
new java.lang.String[] { "PatchId", "Deprecated", "InnerAction", });
internal_static_temporal_omes_kitchen_sink_UpsertSearchAttributesAction_descriptor =
- getDescriptor().getMessageTypes().get(24);
+ getDescriptor().getMessageTypes().get(25);
internal_static_temporal_omes_kitchen_sink_UpsertSearchAttributesAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_UpsertSearchAttributesAction_descriptor,
@@ -55335,25 +56202,25 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_UpsertSearchAttributesAction_SearchAttributesEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_UpsertMemoAction_descriptor =
- getDescriptor().getMessageTypes().get(25);
+ getDescriptor().getMessageTypes().get(26);
internal_static_temporal_omes_kitchen_sink_UpsertMemoAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_UpsertMemoAction_descriptor,
new java.lang.String[] { "UpsertedMemo", });
internal_static_temporal_omes_kitchen_sink_ReturnResultAction_descriptor =
- getDescriptor().getMessageTypes().get(26);
+ getDescriptor().getMessageTypes().get(27);
internal_static_temporal_omes_kitchen_sink_ReturnResultAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ReturnResultAction_descriptor,
new java.lang.String[] { "ReturnThis", });
internal_static_temporal_omes_kitchen_sink_ReturnErrorAction_descriptor =
- getDescriptor().getMessageTypes().get(27);
+ getDescriptor().getMessageTypes().get(28);
internal_static_temporal_omes_kitchen_sink_ReturnErrorAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ReturnErrorAction_descriptor,
new java.lang.String[] { "Failure", });
internal_static_temporal_omes_kitchen_sink_ContinueAsNewAction_descriptor =
- getDescriptor().getMessageTypes().get(28);
+ getDescriptor().getMessageTypes().get(29);
internal_static_temporal_omes_kitchen_sink_ContinueAsNewAction_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ContinueAsNewAction_descriptor,
@@ -55377,13 +56244,13 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_ContinueAsNewAction_SearchAttributesEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_RemoteActivityOptions_descriptor =
- getDescriptor().getMessageTypes().get(29);
+ getDescriptor().getMessageTypes().get(30);
internal_static_temporal_omes_kitchen_sink_RemoteActivityOptions_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_RemoteActivityOptions_descriptor,
new java.lang.String[] { "CancellationType", "DoNotEagerlyExecute", "VersioningIntent", });
internal_static_temporal_omes_kitchen_sink_ExecuteNexusOperation_descriptor =
- getDescriptor().getMessageTypes().get(30);
+ getDescriptor().getMessageTypes().get(31);
internal_static_temporal_omes_kitchen_sink_ExecuteNexusOperation_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_ExecuteNexusOperation_descriptor,
@@ -55395,7 +56262,7 @@ public io.temporal.omes.KitchenSink.NexusHandlerInput getDefaultInstanceForType(
internal_static_temporal_omes_kitchen_sink_ExecuteNexusOperation_HeadersEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_temporal_omes_kitchen_sink_NexusHandlerInput_descriptor =
- getDescriptor().getMessageTypes().get(31);
+ getDescriptor().getMessageTypes().get(32);
internal_static_temporal_omes_kitchen_sink_NexusHandlerInput_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_temporal_omes_kitchen_sink_NexusHandlerInput_descriptor,
diff --git a/workers/java/io/temporal/omes/workerlib/kitchensink/ActivityDispatch.java b/workers/java/io/temporal/omes/workerlib/kitchensink/ActivityDispatch.java
new file mode 100644
index 000000000..5b882ad07
--- /dev/null
+++ b/workers/java/io/temporal/omes/workerlib/kitchensink/ActivityDispatch.java
@@ -0,0 +1,50 @@
+package io.temporal.omes.workerlib.kitchensink;
+
+import io.temporal.omes.KitchenSink;
+import java.util.ArrayList;
+import java.util.List;
+
+// Maps an ExecuteActivityAction to its registered activity name and args.
+// Shared by the workflow-scheduled path and the standalone-activity path.
+public final class ActivityDispatch {
+ final String type;
+ final List