Release/2.3

Client.IntegrationTests/ZeebeIntegrationTestHelper.cs

@@ -14,7 +14,7 @@ namespace Client.IntegrationTests
 {
     public class ZeebeIntegrationTestHelper
     {
-        public const string LatestVersion = "8.2.12";
+        public const string LatestVersion = "8.3.0";
 
         private const ushort ZeebePort = 26500;
 

Client/Client.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <TargetFrameworks>net6.0;net7.0</TargetFrameworks>
-    <Version>2.2.0</Version>
+    <Version>2.3.0</Version>
     <Authors>Christopher Zell</Authors>
     <Company />
     <Description>
@@ -13,18 +13,19 @@ For more information about the zeebe project please visit http://zeebe.io</Descr
     <PackageProjectUrl>https://github.com/zeebe-io/zeebe-client-csharp</PackageProjectUrl>
     <PackageTags>zeebe, zb, zb-csharp, zb-client, grpc</PackageTags>
 
-    <AssemblyVersion>2.2.0</AssemblyVersion>
-    <FileVersion>2.2.0</FileVersion>
+    <AssemblyVersion>2.3.0</AssemblyVersion>
+    <FileVersion>2.3.0</FileVersion>
     <PackageReleaseNotes>
 Features:
 
-      * Add multi-target support for .net 6.0 and .net 7.0 
+  * Add vars to ThrowError 
 
-      GRPC protocol as generated against Zeebe v8.2.12.
+
+GRPC protocol as generated against Zeebe v8.3.0
 
 -----
 
-This release is based on the Zeebe 8.2.12 release (https://github.com/zeebe-io/zeebe).
+This release is based on the Zeebe 8.3.0 release (https://github.com/zeebe-io/zeebe).
     </PackageReleaseNotes>
     <PackageRequireLicenseAcceptance>true</PackageRequireLicenseAcceptance>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
@@ -34,9 +35,9 @@ This release is based on the Zeebe 8.2.12 release (https://github.com/zeebe-io/z
     <RepositoryType>git</RepositoryType>
     <PackageLicenseExpression>Apache-2.0</PackageLicenseExpression>
     <PackageIcon>icon.png</PackageIcon>
-    <PackageVersion>2.2.0</PackageVersion>
+    <PackageVersion>2.3.0</PackageVersion>
     <RootNamespace>Zeebe.Client</RootNamespace>
-    <Title>2.2.0</Title>
+    <Title>2.3.0</Title>
     <LangVersion>default</LangVersion>
     <PackageReadmeFile>README.md</PackageReadmeFile>
   </PropertyGroup>

Client/Impl/proto/GatewayGrpc.cs

@@ -50,6 +50,10 @@
     [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
     static readonly grpc::Marshaller<global::GatewayProtocol.ActivateJobsResponse> __Marshaller_gateway_protocol_ActivateJobsResponse = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::GatewayProtocol.ActivateJobsResponse.Parser));
     [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::GatewayProtocol.StreamActivatedJobsRequest> __Marshaller_gateway_protocol_StreamActivatedJobsRequest = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::GatewayProtocol.StreamActivatedJobsRequest.Parser));
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::GatewayProtocol.ActivatedJob> __Marshaller_gateway_protocol_ActivatedJob = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::GatewayProtocol.ActivatedJob.Parser));
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
     static readonly grpc::Marshaller<global::GatewayProtocol.CancelProcessInstanceRequest> __Marshaller_gateway_protocol_CancelProcessInstanceRequest = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::GatewayProtocol.CancelProcessInstanceRequest.Parser));
     [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
     static readonly grpc::Marshaller<global::GatewayProtocol.CancelProcessInstanceResponse> __Marshaller_gateway_protocol_CancelProcessInstanceResponse = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::GatewayProtocol.CancelProcessInstanceResponse.Parser));
@@ -126,6 +130,14 @@
         __Marshaller_gateway_protocol_ActivateJobsRequest,
         __Marshaller_gateway_protocol_ActivateJobsResponse);
 
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Method<global::GatewayProtocol.StreamActivatedJobsRequest, global::GatewayProtocol.ActivatedJob> __Method_StreamActivatedJobs = new grpc::Method<global::GatewayProtocol.StreamActivatedJobsRequest, global::GatewayProtocol.ActivatedJob>(
+        grpc::MethodType.ServerStreaming,
+        __ServiceName,
+        "StreamActivatedJobs",
+        __Marshaller_gateway_protocol_StreamActivatedJobsRequest,
+        __Marshaller_gateway_protocol_ActivatedJob);
+
     [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
     static readonly grpc::Method<global::GatewayProtocol.CancelProcessInstanceRequest, global::GatewayProtocol.CancelProcessInstanceResponse> __Method_CancelProcessInstance = new grpc::Method<global::GatewayProtocol.CancelProcessInstanceRequest, global::GatewayProtocol.CancelProcessInstanceResponse>(
         grpc::MethodType.Unary,
@@ -294,6 +306,26 @@
         throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
       }
 
+      /// <summary>
+      ///
+      ///Registers client to a job stream that will stream jobs back to the client as
+      ///they become activatable.
+      ///
+      ///Errors:
+      ///INVALID_ARGUMENT:
+      ///- type is blank (empty string, null)
+      ///- timeout less than 1
+      /// </summary>
+      /// <param name="request">The request received from the client.</param>
+      /// <param name="responseStream">Used for sending responses back to the client.</param>
+      /// <param name="context">The context of the server-side call handler being invoked.</param>
+      /// <returns>A task indicating completion of the handler.</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::System.Threading.Tasks.Task StreamActivatedJobs(global::GatewayProtocol.StreamActivatedJobsRequest request, grpc::IServerStreamWriter<global::GatewayProtocol.ActivatedJob> responseStream, grpc::ServerCallContext context)
+      {
+        throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
+      }
+
       /// <summary>
       ///
       ///Cancels a running process instance
@@ -426,11 +458,17 @@
       ///Note that this is an atomic call, i.e. either all resources are deployed, or none of them are.
       ///
       ///Errors:
+      ///PERMISSION_DENIED:
+      ///- if a deployment to an unauthorized tenant is performed
       ///INVALID_ARGUMENT:
       ///- no resources given.
       ///- if at least one resource is invalid. A resource is considered invalid if:
       ///- the content is not deserializable (e.g. detected as BPMN, but it's broken XML)
       ///- the content is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
+      ///- if multi-tenancy is enabled, and:
+      ///- a tenant id is not provided
+      ///- a tenant id with an invalid format is provided
+      ///- if multi-tenancy is disabled and a tenant id is provided
       /// </summary>
       /// <param name="request">The request received from the client.</param>
       /// <param name="context">The context of the server-side call handler being invoked.</param>
@@ -718,6 +756,44 @@
       }
       /// <summary>
       ///
+      ///Registers client to a job stream that will stream jobs back to the client as
+      ///they become activatable.
+      ///
+      ///Errors:
+      ///INVALID_ARGUMENT:
+      ///- type is blank (empty string, null)
+      ///- timeout less than 1
+      /// </summary>
+      /// <param name="request">The request to send to the server.</param>
+      /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
+      /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param>
+      /// <param name="cancellationToken">An optional token for canceling the call.</param>
+      /// <returns>The call object.</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncServerStreamingCall<global::GatewayProtocol.ActivatedJob> StreamActivatedJobs(global::GatewayProtocol.StreamActivatedJobsRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
+      {
+        return StreamActivatedJobs(request, new grpc::CallOptions(headers, deadline, cancellationToken));
+      }
+      /// <summary>
+      ///
+      ///Registers client to a job stream that will stream jobs back to the client as
+      ///they become activatable.
+      ///
+      ///Errors:
+      ///INVALID_ARGUMENT:
+      ///- type is blank (empty string, null)
+      ///- timeout less than 1
+      /// </summary>
+      /// <param name="request">The request to send to the server.</param>
+      /// <param name="options">The options for the call.</param>
+      /// <returns>The call object.</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncServerStreamingCall<global::GatewayProtocol.ActivatedJob> StreamActivatedJobs(global::GatewayProtocol.StreamActivatedJobsRequest request, grpc::CallOptions options)
+      {
+        return CallInvoker.AsyncServerStreamingCall(__Method_StreamActivatedJobs, null, options, request);
+      }
+      /// <summary>
+      ///
       ///Cancels a running process instance
       ///
       ///Errors:
@@ -1154,7 +1230,7 @@
       /// <param name="cancellationToken">An optional token for canceling the call.</param>
       /// <returns>The response received from the server.</returns>
       [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
       public virtual global::GatewayProtocol.DeployProcessResponse DeployProcess(global::GatewayProtocol.DeployProcessRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
       {
         return DeployProcess(request, new grpc::CallOptions(headers, deadline, cancellationToken));
       }
@@ -1174,7 +1250,7 @@
       /// <param name="options">The options for the call.</param>
       /// <returns>The response received from the server.</returns>
       [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
       public virtual global::GatewayProtocol.DeployProcessResponse DeployProcess(global::GatewayProtocol.DeployProcessRequest request, grpc::CallOptions options)
       {
         return CallInvoker.BlockingUnaryCall(__Method_DeployProcess, null, options, request);
       }
@@ -1196,7 +1272,7 @@
       /// <param name="cancellationToken">An optional token for canceling the call.</param>
       /// <returns>The call object.</returns>
       [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
       public virtual grpc::AsyncUnaryCall<global::GatewayProtocol.DeployProcessResponse> DeployProcessAsync(global::GatewayProtocol.DeployProcessRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
       {
         return DeployProcessAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
       }
@@ -1226,11 +1302,17 @@
       ///Note that this is an atomic call, i.e. either all resources are deployed, or none of them are.
       ///
       ///Errors:
+      ///PERMISSION_DENIED:
+      ///- if a deployment to an unauthorized tenant is performed
       ///INVALID_ARGUMENT:
       ///- no resources given.
       ///- if at least one resource is invalid. A resource is considered invalid if:
       ///- the content is not deserializable (e.g. detected as BPMN, but it's broken XML)
       ///- the content is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
+      ///- if multi-tenancy is enabled, and:
+      ///- a tenant id is not provided
+      ///- a tenant id with an invalid format is provided
+      ///- if multi-tenancy is disabled and a tenant id is provided
       /// </summary>
       /// <param name="request">The request to send to the server.</param>
       /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
@@ -1248,11 +1330,17 @@
       ///Note that this is an atomic call, i.e. either all resources are deployed, or none of them are.
       ///
       ///Errors:
+      ///PERMISSION_DENIED:
+      ///- if a deployment to an unauthorized tenant is performed
       ///INVALID_ARGUMENT:
       ///- no resources given.
       ///- if at least one resource is invalid. A resource is considered invalid if:
       ///- the content is not deserializable (e.g. detected as BPMN, but it's broken XML)
       ///- the content is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
+      ///- if multi-tenancy is enabled, and:
+      ///- a tenant id is not provided
+      ///- a tenant id with an invalid format is provided
+      ///- if multi-tenancy is disabled and a tenant id is provided
       /// </summary>
       /// <param name="request">The request to send to the server.</param>
       /// <param name="options">The options for the call.</param>
@@ -1268,11 +1356,17 @@
       ///Note that this is an atomic call, i.e. either all resources are deployed, or none of them are.
       ///
       ///Errors:
+      ///PERMISSION_DENIED:
+      ///- if a deployment to an unauthorized tenant is performed
       ///INVALID_ARGUMENT:
       ///- no resources given.
       ///- if at least one resource is invalid. A resource is considered invalid if:
       ///- the content is not deserializable (e.g. detected as BPMN, but it's broken XML)
       ///- the content is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
+      ///- if multi-tenancy is enabled, and:
+      ///- a tenant id is not provided
+      ///- a tenant id with an invalid format is provided
+      ///- if multi-tenancy is disabled and a tenant id is provided
       /// </summary>
       /// <param name="request">The request to send to the server.</param>
       /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
@@ -1290,11 +1384,17 @@
       ///Note that this is an atomic call, i.e. either all resources are deployed, or none of them are.
       ///
       ///Errors:
+      ///PERMISSION_DENIED:
+      ///- if a deployment to an unauthorized tenant is performed
       ///INVALID_ARGUMENT:
       ///- no resources given.
       ///- if at least one resource is invalid. A resource is considered invalid if:
       ///- the content is not deserializable (e.g. detected as BPMN, but it's broken XML)
       ///- the content is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
+      ///- if multi-tenancy is enabled, and:
+      ///- a tenant id is not provided
+      ///- a tenant id with an invalid format is provided
+      ///- if multi-tenancy is disabled and a tenant id is provided
       /// </summary>
       /// <param name="request">The request to send to the server.</param>
       /// <param name="options">The options for the call.</param>
@@ -2135,6 +2235,7 @@
     {
       return grpc::ServerServiceDefinition.CreateBuilder()
           .AddMethod(__Method_ActivateJobs, serviceImpl.ActivateJobs)
+          .AddMethod(__Method_StreamActivatedJobs, serviceImpl.StreamActivatedJobs)
           .AddMethod(__Method_CancelProcessInstance, serviceImpl.CancelProcessInstance)
           .AddMethod(__Method_CompleteJob, serviceImpl.CompleteJob)
           .AddMethod(__Method_CreateProcessInstance, serviceImpl.CreateProcessInstance)
@@ -2162,6 +2263,7 @@
     public static void BindService(grpc::ServiceBinderBase serviceBinder, GatewayBase serviceImpl)
     {
       serviceBinder.AddMethod(__Method_ActivateJobs, serviceImpl == null ? null : new grpc::ServerStreamingServerMethod<global::GatewayProtocol.ActivateJobsRequest, global::GatewayProtocol.ActivateJobsResponse>(serviceImpl.ActivateJobs));
+      serviceBinder.AddMethod(__Method_StreamActivatedJobs, serviceImpl == null ? null : new grpc::ServerStreamingServerMethod<global::GatewayProtocol.StreamActivatedJobsRequest, global::GatewayProtocol.ActivatedJob>(serviceImpl.StreamActivatedJobs));
       serviceBinder.AddMethod(__Method_CancelProcessInstance, serviceImpl == null ? null : new grpc::UnaryServerMethod<global::GatewayProtocol.CancelProcessInstanceRequest, global::GatewayProtocol.CancelProcessInstanceResponse>(serviceImpl.CancelProcessInstance));
       serviceBinder.AddMethod(__Method_CompleteJob, serviceImpl == null ? null : new grpc::UnaryServerMethod<global::GatewayProtocol.CompleteJobRequest, global::GatewayProtocol.CompleteJobResponse>(serviceImpl.CompleteJob));
       serviceBinder.AddMethod(__Method_CreateProcessInstance, serviceImpl == null ? null : new grpc::UnaryServerMethod<global::GatewayProtocol.CreateProcessInstanceRequest, global::GatewayProtocol.CreateProcessInstanceResponse>(serviceImpl.CreateProcessInstance));

Doxyfile

@@ -38,7 +38,7 @@ PROJECT_NAME           = "Zeebe C# Client"
 # could be handy for archiving the generated documentation or if some version
 # control system is used.
 
-PROJECT_NUMBER         = 2.2.0
+PROJECT_NUMBER         = 2.3.0
 
 # Using the PROJECT_BRIEF tag one can provide an optional one line description
 # for a project that appears at the top of each page and should give viewer a

docs/annotated.html

@@ -26,7 +26,7 @@
  <tr id="projectrow">
   <td id="projectlogo"><img alt="Logo" src="zeebe-logo.png"/></td>
   <td id="projectalign">
-   <div id="projectname">Zeebe C# Client<span id="projectnumber">&#160;2.2.0</span>
+   <div id="projectname">Zeebe C# Client<span id="projectnumber">&#160;2.3.0</span>
    </div>
    <div id="projectbrief">C# Client to communicate with an Zeebe Gateway</div>
   </td>
@@ -192,7 +192,7 @@
 <!-- start footer part -->
 <div id="nav-path" class="navpath"><!-- id is needed for treeview function! -->
   <ul>
-    <li class="footer">Generated on Fri Sep 8 2023 09:27:05 for Zeebe C# Client by <a href="https://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.5 </li>
+    <li class="footer">Generated on Sun Oct 15 2023 12:48:11 for Zeebe C# Client by <a href="https://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.5 </li>
   </ul>
 </div>
 </body>

docs/classes.html

@@ -26,7 +26,7 @@
  <tr id="projectrow">
   <td id="projectlogo"><img alt="Logo" src="zeebe-logo.png"/></td>
   <td id="projectalign">
-   <div id="projectname">Zeebe C# Client<span id="projectnumber">&#160;2.2.0</span>
+   <div id="projectname">Zeebe C# Client<span id="projectnumber">&#160;2.3.0</span>
    </div>
    <div id="projectbrief">C# Client to communicate with an Zeebe Gateway</div>
   </td>
@@ -105,7 +105,7 @@
 <!-- start footer part -->
 <div id="nav-path" class="navpath"><!-- id is needed for treeview function! -->
   <ul>
-    <li class="footer">Generated on Fri Sep 8 2023 09:27:05 for Zeebe C# Client by <a href="https://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.5 </li>
+    <li class="footer">Generated on Sun Oct 15 2023 12:48:11 for Zeebe C# Client by <a href="https://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.5 </li>
   </ul>
 </div>
 </body>

docs/d0/d12/interfaceIDecisionRequirementsMetadata.html

@@ -26,7 +26,7 @@
  <tr id="projectrow">
   <td id="projectlogo"><img alt="Logo" src="../../zeebe-logo.png"/></td>
   <td id="projectalign">
-   <div id="projectname">Zeebe C# Client<span id="projectnumber">&#160;2.2.0</span>
+   <div id="projectname">Zeebe C# Client<span id="projectnumber">&#160;2.3.0</span>
    </div>
    <div id="projectbrief">C# Client to communicate with an Zeebe Gateway</div>
   </td>
@@ -196,7 +196,7 @@ <h2 class="memtitle"><span class="permalink"><a href="#a703fdf9cd478efd8cc4c87ae
 <div id="nav-path" class="navpath"><!-- id is needed for treeview function! -->
   <ul>
     <li class="navelem"><a class="el" href="../../d0/d12/interfaceIDecisionRequirementsMetadata.html">IDecisionRequirementsMetadata</a></li>
-    <li class="footer">Generated on Fri Sep 8 2023 09:27:05 for Zeebe C# Client by <a href="https://www.doxygen.org/index.html"><img class="footer" src="../../doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.5 </li>
+    <li class="footer">Generated on Sun Oct 15 2023 12:48:11 for Zeebe C# Client by <a href="https://www.doxygen.org/index.html"><img class="footer" src="../../doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.5 </li>
   </ul>
 </div>
 </body>