Struct SimplePlugin 

pub struct SimplePlugin { /* private fields */ }

A plugin assembled from declarative values or functions of existing values.

Scalar values replace the corresponding option, while collection values append. Functions receive the existing field and replace it with their return value, except that returned workflow definitions are merged into the existing definitions.

use temporalio_client::ClientOptions;
use temporalio_common::data_converters::DataConverter;
use temporalio_sdk::SimplePlugin;

let plugin = SimplePlugin::builder("my-plugin")
    .data_converter(|existing: Option<DataConverter>| existing.unwrap_or_default())
    .build();
let client_options = ClientOptions::new("default").plugin(plugin).build();

Worker configuration declared by this combined plugin is automatically propagated through the configured client when a worker is created.

Experimental: This API may change or be removed.

Implementations

impl SimplePlugin

pub fn builder(name: impl Into<String>) -> SimplePluginBuilder

Create an instance of SimplePlugin using the builder syntax

Trait Implementations

impl ClientPlugin for SimplePlugin

fn name(&self) -> &str

Return the stable, unique name used to identify this plugin in diagnostics and worker heartbeats.

fn configure_client_options( &self, options: &mut ClientOptions, ) -> Result<(), PluginError>

Configure options before the namespace-bound client is created.

fn configure_connection_options( &self, _options: &mut ConnectionOptions, ) -> Result<(), PluginError>

Configure options before the connection is established.

impl Clone for SimplePlugin

fn clone(&self) -> SimplePlugin

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl From<SimplePlugin> for ErasedClientPlugin

fn from(plugin: SimplePlugin) -> Self

Converts to this type from the input type.

impl WorkerPlugin for SimplePlugin

fn name(&self) -> &str

Stable, unique name used to identify this plugin.

fn configure_worker_options( &self, options: &mut WorkerOptions, ) -> Result<(), PluginError>

Configure worker options.

fn configure_workflow_replayer_options( &self, options: &mut WorkflowReplayerOptions, ) -> Result<(), PluginError>

Configure workflow replayer options.