Add support for Stand Alone Nexus Operations

src/Temporalio.Extensions.OpenTelemetry/TracingInterceptor.cs

@@ -701,7 +701,7 @@ public override Task<ChildWorkflowHandle<TWorkflow, TResult>> StartChildWorkflow
             }
 
             public override Task<NexusWorkflowOperationHandle<TResult>> StartNexusOperationAsync<TResult>(
-                StartNexusOperationInput input)
+                Temporalio.Worker.Interceptors.StartNexusOperationInput input)
             {
                 var headers = StartWorkflowActivityOnHeaders(
                     input.Headers, $"StartNexusOperation:{input.Service}/{input.OperationName}");

src/Temporalio/Api/Compute/V1/Provider.cs

@@ -0,0 +1,345 @@
+// <auto-generated>
+//     Generated by the protocol buffer compiler.  DO NOT EDIT!
+//     source: temporal/api/compute/v1/provider.proto
+// </auto-generated>
+#pragma warning disable 1591, 0612, 3021, 8981
+#region Designer generated code
+
+using pb = global::Google.Protobuf;
+using pbc = global::Google.Protobuf.Collections;
+using pbr = global::Google.Protobuf.Reflection;
+using scg = global::System.Collections.Generic;
+namespace Temporalio.Api.Compute.V1 {
+
+  /// <summary>Holder for reflection information generated from temporal/api/compute/v1/provider.proto</summary>
+  public static partial class ProviderReflection {
+
+    #region Descriptor
+    /// <summary>File descriptor for temporal/api/compute/v1/provider.proto</summary>
+    public static pbr::FileDescriptor Descriptor {
+      get { return descriptor; }
+    }
+    private static pbr::FileDescriptor descriptor;
+
+    static ProviderReflection() {
+      byte[] descriptorData = global::System.Convert.FromBase64String(
+          string.Concat(
+            "CiZ0ZW1wb3JhbC9hcGkvY29tcHV0ZS92MS9wcm92aWRlci5wcm90bxIXdGVt",
+            "cG9yYWwuYXBpLmNvbXB1dGUudjEaJHRlbXBvcmFsL2FwaS9jb21tb24vdjEv",
+            "bWVzc2FnZS5wcm90byJpCg9Db21wdXRlUHJvdmlkZXISDAoEdHlwZRgBIAEo",
+            "CRIwCgdkZXRhaWxzGAIgASgLMh8udGVtcG9yYWwuYXBpLmNvbW1vbi52MS5Q",
+            "YXlsb2FkEhYKDm5leHVzX2VuZHBvaW50GAogASgJQo8BChppby50ZW1wb3Jh",
+            "bC5hcGkuY29tcHV0ZS52MUINUHJvdmlkZXJQcm90b1ABWiVnby50ZW1wb3Jh",
+            "bC5pby9hcGkvY29tcHV0ZS92MTtjb21wdXRlqgIZVGVtcG9yYWxpby5BcGku",
+            "Q29tcHV0ZS5WMeoCHFRlbXBvcmFsaW86OkFwaTo6Q29tcHV0ZTo6VjFiBnBy",
+            "b3RvMw=="));
+      descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
+          new pbr::FileDescriptor[] { global::Temporalio.Api.Common.V1.MessageReflection.Descriptor, },
+          new pbr::GeneratedClrTypeInfo(null, null, new pbr::GeneratedClrTypeInfo[] {
+            new pbr::GeneratedClrTypeInfo(typeof(global::Temporalio.Api.Compute.V1.ComputeProvider), global::Temporalio.Api.Compute.V1.ComputeProvider.Parser, new[]{ "Type", "Details", "NexusEndpoint" }, null, null, null, null)
+          }));
+    }
+    #endregion
+
+  }
+  #region Messages
+  /// <summary>
+  /// ComputeProvider stores information used by a worker control plane controller
+  /// to respond to worker lifecycle events. For example, when a Task is received
+  /// on a TaskQueue that has no active pollers, a serverless worker lifecycle
+  /// controller might need to invoke an AWS Lambda Function that itself ends up
+  /// calling the SDK's worker.New() function.
+  /// </summary>
+  public sealed partial class ComputeProvider : pb::IMessage<ComputeProvider>
+  #if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
+      , pb::IBufferMessage
+  #endif
+  {
+    private static readonly pb::MessageParser<ComputeProvider> _parser = new pb::MessageParser<ComputeProvider>(() => new ComputeProvider());
+    private pb::UnknownFieldSet _unknownFields;
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public static pb::MessageParser<ComputeProvider> Parser { get { return _parser; } }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public static pbr::MessageDescriptor Descriptor {
+      get { return global::Temporalio.Api.Compute.V1.ProviderReflection.Descriptor.MessageTypes[0]; }
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    pbr::MessageDescriptor pb::IMessage.Descriptor {
+      get { return Descriptor; }
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public ComputeProvider() {
+      OnConstruction();
+    }
+
+    partial void OnConstruction();
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public ComputeProvider(ComputeProvider other) : this() {
+      type_ = other.type_;
+      details_ = other.details_ != null ? other.details_.Clone() : null;
+      nexusEndpoint_ = other.nexusEndpoint_;
+      _unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public ComputeProvider Clone() {
+      return new ComputeProvider(this);
+    }
+
+    /// <summary>Field number for the "type" field.</summary>
+    public const int TypeFieldNumber = 1;
+    private string type_ = "";
+    /// <summary>
+    /// Type of the compute provider. This string is implementation-specific and
+    /// can be used by implementations to understand how to interpret the
+    /// contents of the provider_details field.
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public string Type {
+      get { return type_; }
+      set {
+        type_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
+      }
+    }
+
+    /// <summary>Field number for the "details" field.</summary>
+    public const int DetailsFieldNumber = 2;
+    private global::Temporalio.Api.Common.V1.Payload details_;
+    /// <summary>
+    /// Contains provider-specific instructions and configuration.
+    /// For server-implemented providers, use the SDK's default content
+    /// converter to ensure the server can understand it.
+    /// For remote-implemented providers, you might use your own content
+    /// converters according to what the remote endpoints understand.
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public global::Temporalio.Api.Common.V1.Payload Details {
+      get { return details_; }
+      set {
+        details_ = value;
+      }
+    }
+
+    /// <summary>Field number for the "nexus_endpoint" field.</summary>
+    public const int NexusEndpointFieldNumber = 10;
+    private string nexusEndpoint_ = "";
+    /// <summary>
+    /// Optional. If the compute provider is a Nexus service, this should point
+    /// there.
+    /// </summary>
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public string NexusEndpoint {
+      get { return nexusEndpoint_; }
+      set {
+        nexusEndpoint_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
+      }
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public override bool Equals(object other) {
+      return Equals(other as ComputeProvider);
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public bool Equals(ComputeProvider other) {
+      if (ReferenceEquals(other, null)) {
+        return false;
+      }
+      if (ReferenceEquals(other, this)) {
+        return true;
+      }
+      if (Type != other.Type) return false;
+      if (!object.Equals(Details, other.Details)) return false;
+      if (NexusEndpoint != other.NexusEndpoint) return false;
+      return Equals(_unknownFields, other._unknownFields);
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public override int GetHashCode() {
+      int hash = 1;
+      if (Type.Length != 0) hash ^= Type.GetHashCode();
+      if (details_ != null) hash ^= Details.GetHashCode();
+      if (NexusEndpoint.Length != 0) hash ^= NexusEndpoint.GetHashCode();
+      if (_unknownFields != null) {
+        hash ^= _unknownFields.GetHashCode();
+      }
+      return hash;
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public override string ToString() {
+      return pb::JsonFormatter.ToDiagnosticString(this);
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public void WriteTo(pb::CodedOutputStream output) {
+    #if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
+      output.WriteRawMessage(this);
+    #else
+      if (Type.Length != 0) {
+        output.WriteRawTag(10);
+        output.WriteString(Type);
+      }
+      if (details_ != null) {
+        output.WriteRawTag(18);
+        output.WriteMessage(Details);
+      }
+      if (NexusEndpoint.Length != 0) {
+        output.WriteRawTag(82);
+        output.WriteString(NexusEndpoint);
+      }
+      if (_unknownFields != null) {
+        _unknownFields.WriteTo(output);
+      }
+    #endif
+    }
+
+    #if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    void pb::IBufferMessage.InternalWriteTo(ref pb::WriteContext output) {
+      if (Type.Length != 0) {
+        output.WriteRawTag(10);
+        output.WriteString(Type);
+      }
+      if (details_ != null) {
+        output.WriteRawTag(18);
+        output.WriteMessage(Details);
+      }
+      if (NexusEndpoint.Length != 0) {
+        output.WriteRawTag(82);
+        output.WriteString(NexusEndpoint);
+      }
+      if (_unknownFields != null) {
+        _unknownFields.WriteTo(ref output);
+      }
+    }
+    #endif
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public int CalculateSize() {
+      int size = 0;
+      if (Type.Length != 0) {
+        size += 1 + pb::CodedOutputStream.ComputeStringSize(Type);
+      }
+      if (details_ != null) {
+        size += 1 + pb::CodedOutputStream.ComputeMessageSize(Details);
+      }
+      if (NexusEndpoint.Length != 0) {
+        size += 1 + pb::CodedOutputStream.ComputeStringSize(NexusEndpoint);
+      }
+      if (_unknownFields != null) {
+        size += _unknownFields.CalculateSize();
+      }
+      return size;
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public void MergeFrom(ComputeProvider other) {
+      if (other == null) {
+        return;
+      }
+      if (other.Type.Length != 0) {
+        Type = other.Type;
+      }
+      if (other.details_ != null) {
+        if (details_ == null) {
+          Details = new global::Temporalio.Api.Common.V1.Payload();
+        }
+        Details.MergeFrom(other.Details);
+      }
+      if (other.NexusEndpoint.Length != 0) {
+        NexusEndpoint = other.NexusEndpoint;
+      }
+      _unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
+    }
+
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    public void MergeFrom(pb::CodedInputStream input) {
+    #if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
+      input.ReadRawMessage(this);
+    #else
+      uint tag;
+      while ((tag = input.ReadTag()) != 0) {
+        switch(tag) {
+          default:
+            _unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, input);
+            break;
+          case 10: {
+            Type = input.ReadString();
+            break;
+          }
+          case 18: {
+            if (details_ == null) {
+              Details = new global::Temporalio.Api.Common.V1.Payload();
+            }
+            input.ReadMessage(Details);
+            break;
+          }
+          case 82: {
+            NexusEndpoint = input.ReadString();
+            break;
+          }
+        }
+      }
+    #endif
+    }
+
+    #if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
+    [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+    [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+    void pb::IBufferMessage.InternalMergeFrom(ref pb::ParseContext input) {
+      uint tag;
+      while ((tag = input.ReadTag()) != 0) {
+        switch(tag) {
+          default:
+            _unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, ref input);
+            break;
+          case 10: {
+            Type = input.ReadString();
+            break;
+          }
+          case 18: {
+            if (details_ == null) {
+              Details = new global::Temporalio.Api.Common.V1.Payload();
+            }
+            input.ReadMessage(Details);
+            break;
+          }
+          case 82: {
+            NexusEndpoint = input.ReadString();
+            break;
+          }
+        }
+      }
+    }
+    #endif
+
+  }
+
+  #endregion
+
+}
+
+#endregion Designer generated code