Add plugin info to worker heartbeats (#619)

Author: Sushisource

openapi/openapiv2.json

@@ -12886,6 +12886,19 @@
       ],
       "default": "PENDING_WORKFLOW_TASK_STATE_UNSPECIFIED"
     },
+    "v1PluginInfo": {
+      "type": "object",
+      "properties": {
+        "name": {
+          "type": "string",
+          "description": "The name of the plugin, required."
+        },
+        "version": {
+          "type": "string",
+          "description": "The version of the plugin, may be empty."
+        }
+      }
+    },
     "v1PollActivityTaskQueueResponse": {
       "type": "object",
       "properties": {
@@ -16003,6 +16016,14 @@
           "type": "integer",
           "format": "int32",
           "description": "Current cache size, expressed in number of Workflow Executions."
+        },
+        "plugins": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/v1PluginInfo"
+          },
+          "description": "Plugins currently in use by this SDK."
         }
       },
       "description": "Worker info message, contains information about the worker and its current state.\nAll information is provided by the worker itself."

openapi/openapiv3.yaml

@@ -9740,6 +9740,15 @@ components:
         attempt:
           type: integer
           format: int32
+    PluginInfo:
+      type: object
+      properties:
+        name:
+          type: string
+          description: The name of the plugin, required.
+        version:
+          type: string
+          description: The version of the plugin, may be empty.
     PollWorkflowTaskQueueResponse:
       type: object
       properties:
@@ -13372,6 +13381,11 @@ components:
           type: integer
           description: Current cache size, expressed in number of Workflow Executions.
           format: int32
+        plugins:
+          type: array
+          items:
+            $ref: '#/components/schemas/PluginInfo'
+          description: Plugins currently in use by this SDK.
       description: |-
         Worker info message, contains information about the worker and its current state.
          All information is provided by the worker itself.

temporal/api/sdk/v1/task_complete_metadata.proto

@@ -51,4 +51,4 @@ message WorkflowTaskCompletedMetadata {
   // usually the same as client-version gRPC header. This should only be set if its value changed
   // since the last time recorded on the workflow (or be set on the first task).
   string sdk_version = 4;
-}
+}

temporal/api/worker/v1/message.proto

@@ -127,8 +127,18 @@ message WorkerHeartbeat {
   int32 total_sticky_cache_miss = 21;
   // Current cache size, expressed in number of Workflow Executions.
   int32 current_sticky_cache_size = 22;
+
+  // Plugins currently in use by this SDK.
+  repeated PluginInfo plugins = 23;
 }
 
 message WorkerInfo {
   WorkerHeartbeat worker_heartbeat = 1;
-}
+}
+
+message PluginInfo {
+    // The name of the plugin, required.
+    string name = 1;
+    // The version of the plugin, may be empty.
+    string version = 2;
+}