MCPcopy Create free account

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

Functions462 in github.com/dapr/rust-sdk

⨍ Functions 462◇ Types & classes 361
↓ 1 callersFunctionhealth_check
()
dapr/src/server/http.rs:287
↓ 1 callersMethodincrement_on_activate
(&self, actor_id: &str)
dapr/src/server/actor/tests.rs:261
↓ 1 callersMethodincrement_on_deactivate
(&self, actor_id: &str)
dapr/src/server/actor/tests.rs:272
↓ 1 callersMethodinvoke_actor
Invoke a method in a Dapr actor. # Arguments `actor_type` - Type of the actor. `actor_id` - Id of the actor. `method_name` - Name of the method to i
dapr/src/client/mod.rs:433
↓ 1 callersMethodinvoke_reminder
( &self, name: &str, id: &str, reminder_name: &str, data: Vec<u8>,
dapr/src/server/actor/runtime/mod.rs:268
↓ 1 callersMethodinvoke_service
Invoke a method in a Dapr enabled app. # Arguments `app_id` - Id of the application running. `method_name` - Name of the method to invoke. `data` -
dapr/src/client/mod.rs:104
↓ 1 callersMethodinvoke_timer
( &self, name: &str, id: &str, timer_name: &str, data: Vec<u8>, )
dapr/src/server/actor/runtime/mod.rs:280
↓ 1 callersMethodlist_registered_actors
(&self)
dapr/src/server/actor/runtime/mod.rs:292
↓ 1 callersMethodon_activate
(&self)
dapr/src/server/actor/tests.rs:38
↓ 1 callersMethodon_bulk_topic_event
( &self, _request: Request<TopicEventBulkRequest>, )
dapr/src/appcallback.rs:161
↓ 1 callersMethodon_job_event
( &self, request: Request<runtime::v1::JobEventRequest>, )
dapr/src/appcallback.rs:168
↓ 1 callersMethodon_reminder
(&self, _reminder_name: &str, _data: Vec<u8>)
dapr/src/server/actor/tests.rs:48
↓ 1 callersMethodon_timer
(&self, _timer_name: &str, _data: Vec<u8>)
dapr/src/server/actor/tests.rs:52
↓ 1 callersFunctionprint_summary
(workflow_count: usize, summary: &WorkflowRunSummary, elapsed: Duration)
examples/src/workflow-sustained/main.rs:177
↓ 1 callersMethodraise_event
Raise an event to a workflow instance. # Arguments `instance_id` - ID of the workflow instance to raise the event on. `event_name` - Name of the eve
dapr/src/workflow/client.rs:134
↓ 1 callersFunctionread_concurrency
(workflow_count: usize)
examples/src/workflow-sustained/main.rs:89
↓ 1 callersFunctionread_workflow_count
()
examples/src/workflow-sustained/main.rs:81
↓ 1 callersMethodregister_actor
Registers an actor type with the Dapr runtime. # Arguments: `registration` - The [ActorTypeRegistration] struct, carries the methods that can be invo
dapr/src/server/http.rs:200
↓ 1 callersMethodresume_workflow
Resume a suspended workflow instance. # Arguments `instance_id` - ID of the workflow instance to resume. `reason` - Human-readable reason for resumi
dapr/src/workflow/client.rs:119
↓ 1 callersFunctionrun_workflows
( scheduling_client: WorkflowSchedulingClient, workflow_count: usize, concurrency: usize, )
examples/src/workflow-sustained/main.rs:97
↓ 1 callersMethodsave_bulk_states
Save an array of state objects. # Arguments `store_name` - The name of state store. `items` - The array of the state items.
dapr/src/client/mod.rs:316
↓ 1 callersMethodsay_hello
( &self, request: Request<HelloRequest>, )
examples/src/invoke/grpc-proxying/server.rs:14
↓ 1 callersMethodscheduling_client
Create a lightweight scheduling client that shares the underlying gRPC connection. Useful for high-throughput scenarios where many tasks need to sched
dapr/src/workflow/client.rs:78
↓ 1 callersMethodsignal_auth_ok
(&self, method: &str)
examples/src/app-api-token/main.rs:35
↓ 1 callersMethodsubscribe_configuration
Subscribe to configuration changes
dapr/src/client/mod.rs:498
↓ 1 callersMethodsucceeded
(&self)
examples/src/workflow-sustained/main.rs:24
↓ 1 callersMethodsuspend_workflow
Suspend a running workflow instance. # Arguments `instance_id` - ID of the workflow instance to suspend. `reason` - Human-readable reason for suspen
dapr/src/workflow/client.rs:105
↓ 1 callersFunctionunsubscribe
Function to unsubscribe from configuration updates and exit the app
examples/src/configuration/main.rs:46
↓ 1 callersMethodunsubscribe_configuration
Unsubscribe from configuration changes
dapr/src/client/mod.rs:516
↓ 1 callersMethodwait_for_external_event_typed
( &self, name: &str, timeout: Option<Duration>, )
dapr/src/workflow/context.rs:168
↓ 1 callersMethodwait_for_workflow_start
Wait for a workflow to start. # Arguments `instance_id` - ID of the workflow instance to wait for.
dapr/src/workflow/client.rs:162
↓ 1 callersMethodwith_app_api_token_layer
Override the [`AppApiTokenLayer`] used to authenticate inbound requests from the Dapr sidecar. By default, the server reads `APP_API_TOKEN` from the
dapr/src/server/http.rs:181
↓ 1 callersMethodwith_failure_policy
(mut self, policy: JobFailurePolicy)
dapr/src/client/mod.rs:1500
↓ 1 callersMethodwith_graceful_shutdown
(self, signal: F)
dapr/src/server/http.rs:186
↓ 1 callersMethodwith_metadata
(mut self, metadata: HashMap<String, String>)
dapr/src/client/mod.rs:1674
↓ 1 callersMethodwith_start_time
Set the scheduled start time for the workflow. # Arguments `start_time` - Earliest time at which the workflow should begin executing.
dapr/src/workflow/options.rs:64
↓ 1 callersMethodwith_temperature
(mut self, temp: f64)
dapr/src/client/mod.rs:1682
Methodaccept_compressed
(mut self, encoding: CompressionEncoding)
dapr/src/dapr/dapr.proto.runtime.v1.rs:1111
Methodaccept_compressed
(mut self, encoding: CompressionEncoding)
examples/src/invoke/protos/helloworld.rs:83
Functionactivity_options_into_parts_carries_input
()
dapr/src/workflow/options.rs:430
Functionactivity_options_into_parts_defaults_to_null_input
()
dapr/src/workflow/options.rs:424
Functionactivity_options_into_parts_with_retry_and_propagation_compiles
()
dapr/src/workflow/options.rs:436
Functionactor
(_attr: TokenStream, item: TokenStream)
dapr-macros/src/lib.rs:79
Methodadd_job_handler
(&mut self, job_name: String, handler: Box<dyn JobHandlerMethod>)
dapr/src/appcallback.rs:259
Methodadd_job_handler
(&mut self, job_name: String, handler: Box<dyn JobHandlerMethod>)
dapr/src/server/appcallbackalpha.rs:19
Functionapp_layer_enforces_when_token_set
()
dapr/src/client/interceptor.rs:245
Functionapp_layer_permissive_passes_through
()
dapr/src/client/interceptor.rs:308
Functionapp_layer_permissive_when_no_token
()
dapr/src/client/interceptor.rs:239
Functionapp_layer_rejects_unauthenticated_axum_requests
()
dapr/src/client/interceptor.rs:254
Methodas_str_name
String value of the enum field names used in the ProtoBuf definition. The values are not transformed in any way and thus are considered stable (if th
dapr/src/dapr/dapr.proto.runtime.v1.rs:759
Methodas_str_name
String value of the enum field names used in the ProtoBuf definition. The values are not transformed in any way and thus are considered stable (if th
dapr/src/dapr/dapr.proto.common.v1.rs:52
Functionaverage
(latencies: &[Duration])
examples/src/workflow-sustained/main.rs:218
Functionbackup_job_handler
(request: JobEventRequest)
examples/src/jobs/jobs.rs:34
Functionbackup_job_handler
(request: JobEventRequest)
examples/src/jobs-failurepolicy/jobs_failurepolicy.rs:33
Functionbanner
(msg: &str)
examples/src/workflow-history-propagation/main.rs:412
Functionbatch_processing_workflow
(ctx: WorkflowContext)
examples/src/workflow-parallel/main.rs:8
Methodbinding
(binding_name: String)
dapr/src/appcallback.rs:83
Functionbuilder_overrides_take_precedence
()
dapr/src/client/config.rs:336
Methodbulk_publish_event
Bulk Publishes multiple events to the specified topic.
dapr/src/dapr/dapr.proto.runtime.v1.rs:4375
Methodbulk_publish_event_alpha1
( &mut self, request: impl tonic::IntoRequest<super::BulkPublishRequest>, )
dapr/src/dapr/dapr.proto.runtime.v1.rs:4345
Methodcall
(&mut self, req: http::Request<B>)
dapr/src/dapr/dapr.proto.runtime.v1.rs:1489
Methodcall
(&mut self, req: http::Request<B>)
examples/src/invoke/protos/helloworld.rs:218
Methodcall_sub_workflow_typed
( &self, name: &str, input: I, )
dapr/src/workflow/context.rs:132
Functioncheck_spending_limits
( ctx: ActivityContext, input: Option<String>, )
examples/src/workflow-history-propagation/main.rs:289
Methodconnect
Attempt to create a new client by connecting to a given endpoint.
dapr/src/dapr/dapr.proto.runtime.v1.rs:1057
Methodconnect
Attempt to create a new client by connecting to a given endpoint.
examples/src/invoke/protos/helloworld.rs:29
Functionconnect_intercepted
( addr: String, )
dapr/src/client/mod.rs:842
Functionconnect_plain
Implement `DaprInterface` for both the plain and intercepted tonic clients. The actual RPC method bodies are identical (the generated tonic client has
dapr/src/client/mod.rs:836
Methodconnect_with_address
Create a new Dapr client connected to an explicit address. All other settings are read from the environment. # Examples ```no_run # async fn run() -
dapr/src/client/mod.rs:1351
Methodconnect_with_port
(addr: String, port: String)
dapr/src/client/mod.rs:83
Functionconnect_with_port_returns_parse_error_for_invalid_port
()
dapr/src/client/mod.rs:1774
Methodconnect_with_retry
Connect to the Dapr sidecar with exponential-backoff retries.
dapr/src/server/http.rs:142
Methodconverse_alpha1
Converse with a LLM service
dapr/src/dapr/dapr.proto.runtime.v1.rs:5941
Methodconverse_alpha2
Converse with a LLM service via alpha2 api
dapr/src/dapr/dapr.proto.runtime.v1.rs:5966
Functiondeactivate_actor
( State(runtime): State<Arc<ActorRuntime>>, Path((actor_type, actor_id)): Path<(String, String)>, )
dapr/src/server/http.rs:300
Methoddecrypt_alpha1
DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.
dapr/src/dapr/dapr.proto.runtime.v1.rs:5028
Methoddefault
()
dapr/src/appcallback.rs:216
Methoddefault
Read all options from the environment, silently falling back to defaults if any value is missing or invalid. Use [`ClientOptions::from_env`] if you w
dapr/src/client/config.rs:186
Methoddefault
()
dapr/src/server/appcallbackalpha.rs:25
Functiondefault_address_prefers_endpoint_env
()
dapr/src/client/config.rs:272
Functiondefault_address_uses_built_in_default_when_unset
()
dapr/src/client/config.rs:249
Functiondefault_address_uses_port_env
()
dapr/src/client/config.rs:259
Methoddelete_bulk_state
Delete an array of state objects. # Arguments `store_name` - The name of state store. `states` - The array of the state key values.
dapr/src/client/mod.rs:361
Methoddelete_bulk_state
Deletes a bulk of state items for a list of keys
dapr/src/dapr/dapr.proto.runtime.v1.rs:4271
Methoddelete_job
Delete a job
dapr/src/dapr/dapr.proto.runtime.v1.rs:5807
Methoddelete_job_alpha1
(&mut self, name: &str)
dapr/src/client/mod.rs:686
Methoddelete_job_alpha1
( &mut self, request: impl tonic::IntoRequest<super::DeleteJobRequest>, )
dapr/src/dapr/dapr.proto.runtime.v1.rs:5780
Methoddelete_jobs_by_prefix
Deletes all jobs whose name starts with the given prefix. Pass `None` to delete all jobs for the app. # Arguments prefix - The name prefix to match
dapr/src/client/mod.rs:699
Methoddelete_jobs_by_prefix
Delete jobs by name prefix
dapr/src/dapr/dapr.proto.runtime.v1.rs:5863
Methoddelete_jobs_by_prefix_alpha1
( &mut self, request: impl tonic::IntoRequest<super::DeleteJobsByPrefixRequestAlpha1>,
dapr/src/dapr/dapr.proto.runtime.v1.rs:5833
Methoddelete_state
Deletes the state for a specific key.
dapr/src/dapr/dapr.proto.runtime.v1.rs:4249
Functiondescribe_event
(event: &impl std::fmt::Debug)
examples/src/workflow-history-propagation/main.rs:391
Functiondescribe_history
(history: Option<&PropagatedHistory>)
examples/src/workflow-history-propagation/main.rs:371
Functiondescribe_scope
(scope: HistoryPropagationScope)
examples/src/workflow-history-propagation/main.rs:384
Methoddo_stuff
(&self, Json(req): Json<MyRequest>)
dapr/src/server/actor/tests.rs:58
Methoddo_stuff
(&self, DaprJson(req): DaprJson<MyRequest>)
examples/src/actors/server.rs:30
Functiondo_work
(ctx: ActivityContext, input: Option<String>)
examples/src/workflow-sustained/main.rs:36
Methoddrop
(&mut self)
dapr/src/workflow/client.rs:481
Functionempty_api_token_clears
()
dapr/src/client/config.rs:347
Methodencrypt_alpha1
EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.
dapr/src/dapr/dapr.proto.runtime.v1.rs:5003
← previousnext →101–200 of 462, ranked by callers