Rename worker heartbeat duration to interval in C bridge, plumb plugin names (#1071)

* Rename heartbeat_duration to heartbeat_interval for c bridge

* Plumb plugins through C bridge

Author: yuandrew

crates/sdk-core-c-bridge/include/temporal-sdk-core-c-bridge.h

@@ -446,7 +446,7 @@ typedef struct TemporalCoreTelemetryOptions {
 
 typedef struct TemporalCoreRuntimeOptions {
   const struct TemporalCoreTelemetryOptions *telemetry;
-  uint64_t worker_heartbeat_duration_millis;
+  uint64_t worker_heartbeat_interval_millis;
 } TemporalCoreRuntimeOptions;
 
 typedef struct TemporalCoreTestServerOptions {
@@ -785,6 +785,7 @@ typedef struct TemporalCoreWorkerOptions {
   struct TemporalCorePollerBehavior nexus_task_poller_behavior;
   bool nondeterminism_as_workflow_fail;
   struct TemporalCoreByteArrayRefArray nondeterminism_as_workflow_fail_for_types;
+  struct TemporalCoreByteArrayRefArray plugins;
 } TemporalCoreWorkerOptions;
 
 /**

crates/sdk-core-c-bridge/src/runtime.rs

@@ -31,7 +31,7 @@ use url::Url;
 #[repr(C)]
 pub struct RuntimeOptions {
     pub telemetry: *const TelemetryOptions,
-    pub worker_heartbeat_duration_millis: u64,
+    pub worker_heartbeat_interval_millis: u64,
 }
 
 #[repr(C)]
@@ -240,11 +240,11 @@ impl Runtime {
             CoreTelemetryOptions::default()
         };
 
-        let heartbeat_interval = if options.worker_heartbeat_duration_millis == 0 {
+        let heartbeat_interval = if options.worker_heartbeat_interval_millis == 0 {
             None
         } else {
             Some(Duration::from_millis(
-                options.worker_heartbeat_duration_millis,
+                options.worker_heartbeat_interval_millis,
             ))
         };
 

crates/sdk-core-c-bridge/src/tests/context.rs

@@ -153,7 +153,7 @@ impl Context {
 
         let RuntimeOrFail { runtime, fail } = temporal_core_runtime_new(&RuntimeOptions {
             telemetry: std::ptr::null(),
-            worker_heartbeat_duration_millis: 0,
+            worker_heartbeat_interval_millis: 0,
         });
 
         if let Some(fail) = byte_array_to_string(runtime, fail) {

crates/sdk-core-c-bridge/src/worker.rs

@@ -56,6 +56,7 @@ pub struct WorkerOptions {
     pub nexus_task_poller_behavior: PollerBehavior,
     pub nondeterminism_as_workflow_fail: bool,
     pub nondeterminism_as_workflow_fail_for_types: ByteArrayRefArray,
+    pub plugins: ByteArrayRefArray,
 }
 
 #[repr(C)]
@@ -1257,6 +1258,18 @@ impl TryFrom<&WorkerOptions> for temporalio_sdk_core::WorkerConfig {
                     })
                     .collect::<HashMap<String, HashSet<WorkflowErrorType>>>(),
             )
+            .plugins(
+                opt.plugins
+                    .to_str_vec()
+                    .into_iter()
+                    .map(
+                        |name| temporalio_common::protos::temporal::api::worker::v1::PluginInfo {
+                            name: name.to_owned(),
+                            version: String::new(),
+                        },
+                    )
+                    .collect::<Vec<_>>(),
+            )
             .build()
             .map_err(|err| anyhow::anyhow!(err))
     }