Get the worker registry for registering workflows and activities before starting the worker.

Set the JSON-serializable input passed to the workflow. # Panics Panics if `input` cannot be serialized to JSON. Prefer [`ScheduleOptions::try_with_

Set whether workflow inputs and outputs are included in the returned metadata. # Arguments `fetch_payloads` - When `true`, include workflow inputs a

Set the history propagation scope applied to the activity invocation. # Arguments `scope` - Scope controlling how caller history is propagated to th

Set the retry policy applied to the activity invocation. # Arguments `retry_policy` - Policy describing retry attempts, intervals, and backoff.

Purge workflow state and history for an instance. # Arguments `instance_id` - ID of the workflow instance to purge.

Schedule a new workflow instance and return its instance ID. # Arguments `name` - Name of the registered workflow to schedule. `options` - Schedule

Build the default sidecar gRPC address from the environment, with this resolution order: 1. [`DAPR_GRPC_ENDPOINT_ENV`] if set. 2. `http://127.0.0.1:$

Registers a method on the actor type to be exposed to actor clients. # Arguments: `method_name` - The name of the method to be registered. This name

Request worker shutdown and wait for the worker task to finish.

Start the workflow worker on a Tokio task.

Set an explicit instance ID for the new workflow. # Arguments `instance_id` - Caller-supplied identifier for the workflow instance.

Fetch workflow metadata, optionally including inputs and outputs. # Arguments `instance_id` - ID of the workflow instance to fetch metadata for. `op

Schedules a job with the Dapr Distributed Scheduler # Arguments job - The job to schedule overwrite - Optional flag to overwrite an existing job wit

Set the JSON-serializable input passed to the workflow, returning an error if serialization fails. # Arguments `input` - Value serialized to JSON an

Set the Dapr API token used as the `dapr-api-token` metadata value on every outgoing call. Pass an empty string to clear.

Set sidecar Metadata

Registers an actor type to be exposed to actor clients. # Arguments: `registration` - The [ActorTypeRegistration] that describes the actor implementat

Terminate a workflow instance. # Arguments `instance_id` - ID of the workflow instance to terminate.

Wait for a workflow to complete with fetch and timeout options. # Arguments `instance_id` - ID of the workflow instance to wait for. `options` - Fet

Override the gRPC endpoint. Accepts the same shapes as `DAPR_GRPC_ENDPOINT`.

Decrypt binary data using Dapr. returns `Vec<u8>`. # Arguments `encrypted` - Encrypted data usually returned from encrypted, `Vec<StreamPayload>` `o

Deletes a scheduled job from the Dapr Distributed Scheduler # Arguments name - The name of the job to delete

Encrypt binary data using Dapr. returns `Vec<StreamPayload>` to be used in decrypt method # Arguments `payload` - ReaderStream to the data to encryp

Prepend `http://` to `address` when no URL scheme is present so that the underlying tonic channel can parse it.

Retrieves a scheduled job from the Dapr Distributed Scheduler # Arguments name - The name of the job to retrieve

Get the state for a specific key. # Arguments `store_name` - The name of state store. `key` - The key of the desired state. `metadata` - Any metadat

Invoke a Dapr output binding. # Arguments `name` - The name of the output binding to invoke. `data` - The data which will be sent to the output bind

Publish a payload to multiple consumers who are listening on a topic. Dapr guarantees at least once semantics for this endpoint. # Arguments `pubsu

Query state objects based on specific query conditions # Arguments `store_name` - The name of state store. `query` - The query request (json)

Return a diagnostics-safe endpoint string. Keeps scheme when present and strips path/query/fragment and any userinfo so that credentials never appear

Save an array of state objects. This does not include any etag or metadata options. # Arguments `store_name` - The name of state store. `key` - The

Starts the Dapr HTTP server. # Arguments: `port` - The port to listen on. If not specified, the APP_PORT environment variable will be used. If that i

The configured connect timeout.

Set the JSON-serializable payload delivered with the event, returning an error if serialization fails. # Arguments `payload` - Value serialized to J

Wait for a workflow to complete. # Arguments `instance_id` - ID of the workflow instance to wait for.

Set the target app ID hosting the child workflow. # Arguments `app_id` - Dapr app ID that should execute the child workflow.

Set the JSON-serializable payload delivered with the event. # Panics Panics if `payload` cannot be serialized to JSON. Prefer [`EventOptions::try_wi

Set the gRPC connect timeout.

The configured gRPC endpoint.

The configured Dapr API token, if any.

Converse with an LLM # Arguments ConversationRequest - The request containing inputs to send to the LLM

Converse with an LLM using alpha2 # Arguments ConversationRequestAlpha2 - The request containing inputs to send to the LLM

Delete the state for a specific key. # Arguments `store_name` - The name of state store. `key` - The key of the desired state.

Get all secrets for a given store # Arguments `store_name` - The name of the secret store.

Get the configuration for a specific key /// # Arguments `store_name` - The name of config store. `keys` - The key of the desired configuration.