Functions — github.com/dapr/rust-sdk

CodeHub MCPcopy Create free account

hub / github.com/dapr/rust-sdk / functions

Functions462 in github.com/dapr/rust-sdk

⨍ Functions 462◇ Types & classes 361

Functionensure_url_scheme_prepends_for_bare_host

dapr/src/workflow/client.rs:647

Functionensure_url_scheme_prepends_when_missing

dapr/src/workflow/client.rs:639

Functionensure_url_scheme_preserves_http

dapr/src/workflow/client.rs:623

Functionensure_url_scheme_preserves_https

dapr/src/workflow/client.rs:631

Functionevent_options_payload_json_handles_none

dapr/src/workflow/options.rs:405

Functionevent_options_payload_json_round_trips

dapr/src/workflow/options.rs:410

Functionevent_options_try_with_payload_propagates_error

dapr/src/workflow/options.rs:418

Methodexecute_actor_state_transaction

Executes state transactions for a specified actor

dapr/src/dapr/dapr.proto.runtime.v1.rs:4723

Methodexecute_actor_state_transaction

Saves a state value within the scope of this instance of the actor. # Arguments `operations` - A list of [ActorStateOperation] to perform on the stat

dapr/src/server/actor/context_client.rs:81

Methodexecute_state_transaction

Executes transactions for a specified store

dapr/src/dapr/dapr.proto.runtime.v1.rs:4295

Functionfail_activity

( _ctx: ActivityContext, _input: Option<String>, )

examples/src/workflow/main.rs:60

Functionfallback_handler

(OriginalUri(uri): OriginalUri)

dapr/src/server/http.rs:279

Functionfetch_options_with_fetch_payloads_toggles

dapr/src/workflow/options.rs:478

(&self, f: &mut fmt::Formatter<'_>)

dapr/src/error.rs:44

(&self, f: &mut std::fmt::Formatter<'_>)

dapr/src/server/actor/mod.rs:34

Functionformat_duration

(duration: Duration)

examples/src/workflow-sustained/main.rs:229

Functionfraud_detection

(ctx: WorkflowContext)

examples/src/workflow-history-propagation/main.rs:184

(_error: ParseIntError)

dapr/src/error.rs:80

((key, value): (K, Vec<u8>))

dapr/src/client/mod.rs:1434

(val: ActorStateOperation)

dapr/src/server/actor/context_client.rs:18

(inner: Arc<T>)

dapr/src/dapr/dapr.proto.runtime.v1.rs:1427

(inner: Arc<T>)

examples/src/invoke/protos/helloworld.rs:156

Build a `ClientOptions` from environment variables only, returning an error if any present-but-invalid value cannot be parsed (e.g. `DAPR_CLIENT_TIMEO

dapr/src/client/config.rs:127

Construct a layer that reads the expected token from `APP_API_TOKEN`. Permissive when the env var is unset or empty.

dapr/src/client/interceptor.rs:128

Methodfrom_options

Create a new Dapr client from an explicit [`ClientOptions`]. # Errors See [`Client::new`]. # Examples ```no_run # async fn run() -> Result<(), dap

dapr/src/client/mod.rs:1318

Methodfrom_request

(req: Request<Body>, state: &S)

dapr/src/server/utils.rs:27

Methodfrom_str_name

Creates an enum from field names used in the ProtoBuf definition.

dapr/src/dapr/dapr.proto.runtime.v1.rs:767

Methodfrom_str_name

Creates an enum from field names used in the ProtoBuf definition.

dapr/src/dapr/dapr.proto.common.v1.rs:67

Methodget_actor_reminder

Gets an actor reminder.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4696

Methodget_actor_state

Gets the state for a specific actor.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4671

Methodget_actor_state

Retrieves a keyed state value within the scope of this instance of the actor. # Arguments `key` - The key of the state to retrieve.

dapr/src/server/actor/context_client.rs:62

Methodget_bulk_secret

Gets a bulk of secrets

dapr/src/dapr/dapr.proto.runtime.v1.rs:4487

Methodget_bulk_state

Gets a bulk of state items for a list of keys

dapr/src/dapr/dapr.proto.runtime.v1.rs:4175

Methodget_configuration

GetConfiguration gets configuration from configuration store.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4805

Methodget_configuration_alpha1

GetConfiguration gets configuration from configuration store.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4775

Gets a scheduled job

dapr/src/dapr/dapr.proto.runtime.v1.rs:5757

Methodget_job_alpha1

(&mut self, name: &str)

dapr/src/client/mod.rs:660

Methodget_job_alpha1

( &mut self, request: impl tonic::IntoRequest<super::GetJobRequest>, )

dapr/src/dapr/dapr.proto.runtime.v1.rs:5735

Methodget_metadata

Gets metadata of the sidecar

dapr/src/dapr/dapr.proto.runtime.v1.rs:5053

Methodget_secret

Get the secret for a specific key. # Arguments `store_name` - The name of secret store. `key` - The name of secret key.

dapr/src/client/mod.rs:213

Methodget_secret

Gets secrets from secret stores.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4462

Methodget_state

Gets the state for a specific key.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4150

Functionget_work_batch

(ctx: ActivityContext, input: Option<String>)

examples/src/workflow-parallel/main.rs:32

Methodget_workflow_alpha1

( &mut self, request: impl tonic::IntoRequest<super::GetWorkflowRequest>, )

dapr/src/dapr/dapr.proto.runtime.v1.rs:5321

Methodget_workflow_beta1

Gets details about a started workflow instance

dapr/src/dapr/dapr.proto.runtime.v1.rs:5506

Functionhandle_a_event

examples/src/pubsub/subscriber.rs:20

Functionhandle_b_event

(refund: Refund)

examples/src/pubsub/subscriber.rs:25

Methodhas_token

Returns `true` when a non-empty token has been configured.

dapr/src/client/interceptor.rs:70

Methodhealth_check

dapr/src/dapr/dapr.proto.runtime.v1.rs:1941

Functioninterceptor_empty_token_is_noop

dapr/src/client/interceptor.rs:215

Functioninterceptor_injects_token

dapr/src/client/interceptor.rs:223

Functioninterceptor_no_token_is_noop

dapr/src/client/interceptor.rs:208

Functioninterceptor_rejects_invalid_metadata

dapr/src/client/interceptor.rs:230

Methodinto_response

dapr/src/server/utils.rs:48

Methodinto_response

dapr/src/server/actor/mod.rs:47

Methodinvoke_actor

InvokeActor calls a method on an actor.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4750

Methodinvoke_binding

Invokes binding data to specific output bindings

dapr/src/dapr/dapr.proto.runtime.v1.rs:4437

Methodinvoke_output_binding

Invoke a Dapr output binding without expecting a response payload. # Arguments `name` - The name of the output binding to invoke. `operation` - The

dapr/src/client/mod.rs:161

Functioninvoke_reminder

( State(runtime): State<Arc<ActorRuntime>>, Path((actor_type, actor_id, reminder_name)): Path<(String,

dapr/src/server/http.rs:319

Methodinvoke_service

Invokes a method on a remote Dapr app. Deprecated: Use proxy mode service invocation instead.

dapr/src/dapr/dapr.proto.runtime.v1.rs:4125

Functioninvoke_timer

( State(runtime): State<Arc<ActorRuntime>>, Path((actor_type, actor_id, timer_name)): Path<(String, St

dapr/src/server/http.rs:349

Methodis_enforcing

Returns `true` when this layer will reject requests without a valid token.

dapr/src/client/interceptor.rs:134

Functionis_method_not_found

Returns `true` when a [`tonic::Status`] indicates the called gRPC method does not exist on the server. Dapr ≤ 1.17 routes unknown methods through its

dapr/src/client/mod.rs:27

Methodlist_actor_reminders

( &mut self, request: impl tonic::IntoRequest<super::ListActorRemindersRequest>,

dapr/src/dapr/dapr.proto.runtime.v1.rs:4644

Methodlist_input_bindings

( &self, _request: Request<()>, )

dapr/src/appcallback.rs:147

Methodlist_input_bindings

Lists all input bindings subscribed by this app.

dapr/src/dapr/dapr.proto.runtime.v1.rs:1218

Methodlist_input_bindings

( &self, _request: Request<()>, )

examples/src/app-api-token/main.rs:66

Methodlist_input_bindings

Lists all input bindings subscribed by this app. NOTE: Dapr runtime will call this method to get the list of bindings the app wants to subscribe to. I

examples/src/bindings/input.rs:44

Methodlist_input_bindings

Lists all input bindings subscribed by this app.

examples/src/invoke/grpc/server.rs:78

Methodlist_jobs

Lists all scheduled jobs

dapr/src/client/mod.rs:710

Methodlist_jobs

dapr/src/dapr/dapr.proto.runtime.v1.rs:5916

Methodlist_jobs_alpha1

( &mut self, request: impl tonic::IntoRequest<super::ListJobsRequestAlpha1>, )

dapr/src/dapr/dapr.proto.runtime.v1.rs:5891

Methodlist_topic_subscriptions

( &self, _request: Request<()>, )

dapr/src/appcallback.rs:110

Methodlist_topic_subscriptions

Lists all topics subscribed by this app.

dapr/src/dapr/dapr.proto.runtime.v1.rs:1161

Methodlist_topic_subscriptions

( &self, _request: Request<()>, )

examples/src/app-api-token/main.rs:50

Methodlist_topic_subscriptions

Lists all topics subscribed by this app.

examples/src/bindings/input.rs:25

Methodlist_topic_subscriptions

Lists all topics subscribed by this app. NOTE: Dapr runtime will call this method to get the list of topics the app wants to subscribe to. In this ex

examples/src/invoke/grpc/server.rs:61

proto-gen/src/main.rs:5

examples/src/client/client.rs:2

examples/src/app-api-token/main.rs:99

examples/src/crypto/main.rs:9

examples/src/workflow-sustained/main.rs:49

examples/src/configuration/main.rs:7

examples/src/conversation-alpha1/main.rs:5

examples/src/jobs/jobs.rs:49

examples/src/client-config/main.rs:18

examples/src/query_state/query1.rs:4

examples/src/query_state/query2.rs:4

examples/src/jobs-failurepolicy/jobs_failurepolicy.rs:49

examples/src/bindings/input.rs:88

examples/src/bindings/output.rs:4

examples/src/conversation-alpha2/main.rs:9

examples/src/pubsub/publisher.rs:21

examples/src/pubsub/subscriber.rs:30

examples/src/actors/server.rs:63

examples/src/actors/client.rs:14

examples/src/invoke/grpc/server.rs:111

examples/src/invoke/grpc/client.rs:11

examples/src/invoke/grpc-proxying/server.rs:31

examples/src/invoke/grpc-proxying/client.rs:12

← previous next →201–300 of 462, ranked by callers