MCPcopy Create free account

hub / github.com/actix/examples / functions

Functions527 in github.com/actix/examples

⨍ Functions 527◇ Types & classes 153
↓ 1 callersMethodhb
helper method that sends ping to client every 5 seconds (HEARTBEAT_INTERVAL). also this method checks heartbeats from client
websockets/chat/src/session.rs:37
↓ 1 callersMethodhb
helper method that sends ping to client every 5 seconds (HEARTBEAT_INTERVAL). also this method checks heartbeats from client
websockets/chat-tcp/src/main.rs:201
↓ 1 callersMethodhb
helper method that sends ping to client every second. also this method check heartbeats from client
websockets/chat-tcp/src/session.rs:158
↓ 1 callersMethodinc
(&mut self)
json/jsonrpc/src/main.rs:123
↓ 1 callersFunctioninit_item_cache
()
background-jobs/src/ephemeral_jobs.rs:9
↓ 1 callersFunctioninit_pool
(database_url: &str)
basics/todo/src/db.rs:5
↓ 1 callersFunctioninit_rustls_provider
Load default rustls provider, to be done once for the process.
examples-common/src/lib.rs:17
↓ 1 callersFunctioninsert_bank_data
Insert data into the database table `bank_details`.
databases/mysql/src/persistence.rs:183
↓ 1 callersFunctioninsert_branch_data
Insert data into the database table `branch_details`.
databases/mysql/src/persistence.rs:202
↓ 1 callersFunctioninsert_customer_data
Insert data into the database table `customer_details`.
databases/mysql/src/persistence.rs:240
↓ 1 callersFunctioninsert_new_item
Run query using Diesel to insert a new database row and return the result.
databases/diesel-async/src/actions.rs:28
↓ 1 callersFunctioninsert_new_user
Run query using Diesel to insert a new database row and return the result.
databases/diesel/src/actions.rs:24
↓ 1 callersFunctioninsert_teller_data
Insert data into the database table `teller_details`.
databases/mysql/src/persistence.rs:221
↓ 1 callersMethodlang_id
(&self)
templating/fluent/src/lang_choice.rs:26
↓ 1 callersMethodlist_rooms
(&mut self, ctx: &mut ws::WebsocketContext<Self>)
websockets/chat-broker/src/session.rs:48
↓ 1 callersFunctionload_encrypted_private_key
()
https-tls/openssl/src/main.rs:56
↓ 1 callersFunctionload_rustls_config
()
https-tls/rustls/src/main.rs:44
↓ 1 callersFunctionload_rustls_config
()
https-tls/cert-watch/src/main.rs:109
↓ 1 callersFunctionload_rustls_config
(cert: Certificate)
https-tls/acme-letsencrypt/src/main.rs:183
↓ 1 callersFunctionmain
(url, loop)
websockets/chat-broker/client.py:56
↓ 1 callersFunctionmain
(url, loop)
websockets/chat-tcp/client.py:56
↓ 1 callersMethodnew_client
Registers client with broadcaster, returning an SSE response body.
server-sent-events/src/broadcast.rs:67
↓ 1 callersFunctionopentelemetry_tracer
(app_name: &str)
tracing/mainmatter-workshop/src/logging.rs:34
↓ 1 callersMethodput_object_from_file
(&self, local_path: &str, key: &str)
forms/multipart-s3/src/client.rs:83
↓ 1 callersFunctionquery
( invitation_id: String, password: String, pool: web::Data<Pool>, )
auth/simple-auth-server/src/register_handler.rs:35
↓ 1 callersFunctionrand_delay_with_jitter
Returns a duration close to 1 second.
background-jobs/src/persistent_jobs.rs:49
↓ 1 callersMethodregister
Sets the server handle to stop.
shutdown-server/src/main.rs:56
↓ 1 callersMethodremove_stale_clients
Removes all non-responsive clients from broadcast list.
server-sent-events/src/broadcast.rs:48
↓ 1 callersFunctionreq
()
json/json/client.py:10
↓ 1 callersFunctionrpc_select
( app_state: &AppState, method: &str, params: Vec<Value>, )
json/jsonrpc/src/main.rs:47
↓ 1 callersFunctionrun_app
(tx: mpsc::Sender<ServerHandle>)
run-in-thread/src/main.rs:14
↓ 1 callersFunctionrustls_config
Create simple `rustls` client config.
https-tls/awc-https/src/main.rs:67
↓ 1 callersFunctionselect_bank_details
Lists all banks' details.
databases/mysql/src/persistence.rs:259
↓ 1 callersFunctionselect_branch_details
Lists all branches' details.
databases/mysql/src/persistence.rs:275
↓ 1 callersFunctionselect_customer_details
Lists all customers' details.
databases/mysql/src/persistence.rs:307
↓ 1 callersFunctionselect_teller_details
Lists all tellers' details.
databases/mysql/src/persistence.rs:291
↓ 1 callersFunctionsend_invitation
(invitation: &Invitation)
auth/simple-auth-server/src/email_service.rs:11
↓ 1 callersMethodsend_msg
(&self, msg: &str)
websockets/chat-broker/src/session.rs:64
↓ 1 callersFunctionspawn_cache_sweep
(cache: Arc<ItemCache>, stop_signal: CancellationToken)
background-jobs/src/ephemeral_jobs.rs:27
↓ 1 callersFunctionstart_client
(url, loop)
websockets/chat-broker/client.py:13
↓ 1 callersFunctionstart_client
(loop, url)
websockets/echo/websocket-client.py:9
↓ 1 callersFunctionstart_client
(url: str)
websockets/chat/client.py:12
↓ 1 callersFunctionstart_client
(url, loop)
websockets/chat-tcp/client.py:13
↓ 1 callersFunctionstart_processing_email_queue
()
background-jobs/src/persistent_jobs.rs:30
↓ 1 callersMethodtake_room
(&mut self, room_name: &str)
websockets/chat-broker/src/server.rs:17
↓ 1 callersFunctiontcp_server
Define TCP server that will accept incoming TCP connection and create chat actors.
websockets/chat-tcp/src/session.rs:180
↓ 1 callersFunctiontick
()
websockets/chat-broker/client.py:51
↓ 1 callersFunctiontick
()
websockets/chat-tcp/client.py:51
↓ 1 callersFunctiontoggle
( pool: web::Data<SqlitePool>, params: web::Path<UpdateParams>, )
basics/todo/src/api.rs:92
↓ 1 callersFunctiontoggle_task
(id: i32, pool: &SqlitePool)
basics/todo/src/db.rs:24
↓ 1 callersMethodupload
(&self, file: &TempFile, key_prefix: &str)
forms/multipart-s3/src/client.rs:74
↓ 1 callersMethodupload_and_remove
(&self, file: TempFile, key_prefix: &str)
forms/multipart-s3/src/client.rs:68
↓ 1 callersMethodupload_files
( &self, temp_files: Vec<TempFile>, key_prefix: &str, )
forms/multipart-s3/src/client.rs:53
↓ 1 callersMethodurl
(&self, key: &str)
forms/multipart-s3/src/client.rs:26
↓ 1 callersMethoduser
(context: &Context, id: String)
graphql/juniper-advanced/src/schemas/root.rs:37
↓ 1 callersFunctionverify
(hash: &str, password: &str)
auth/simple-auth-server/src/utils.rs:22
Functionadd_bank
( web::Json(bank_data): web::Json<BankData>, data: web::Data<mysql::Pool>, )
databases/mysql/src/routes.rs:17
Functionadd_branch
( web::Json(branch_data): web::Json<BranchData>, data: web::Data<mysql::Pool>, )
databases/mysql/src/routes.rs:30
Functionadd_customer
( web::Json(customer_data): web::Json<CustomerData>, data: web::Data<mysql::Pool>, )
databases/mysql/src/routes.rs:56
Functionadd_item
( pool: web::Data<DbPool>, form: web::Json<models::NewItem>, )
databases/diesel-async/src/main.rs:57
Functionadd_part
(_new_part: web::Json<Product>)
basics/nested-routing/src/handlers/parts.rs:9
Functionadd_product
(_new_product: web::Json<Product>)
basics/nested-routing/src/handlers/products.rs:9
Functionadd_teller
( web::Json(teller_data): web::Json<TellerData>, data: web::Data<mysql::Pool>, )
databases/mysql/src/routes.rs:43
Functionadd_user
(client: web::Data<Client>, form: web::Form<User>)
databases/mongodb/src/main.rs:16
Functionadd_user
( user: web::Json<User>, ThinData(db_pool): web::ThinData<Pool>, )
databases/postgres/src/main.rs:27
Functionadd_user
(client: &Client, user_info: User)
databases/postgres/src/db.rs:21
Functionadd_user
( pool: web::Data<DbPool>, form: web::Json<models::NewUser>, )
databases/diesel/src/main.rs:58
Functionagain
()
docker/src/main.rs:9
Methodall
(connection: &SqlitePool)
basics/todo/src/model.rs:17
Functionan_expensive_function
(n: web::Path<u64>)
cache/redis/src/main.rs:24
Functionapi_versioning
()
guards/src/main.rs:83
Functionapp_config
(config: &mut web::ServiceConfig)
forms/form/src/main.rs:20
Methodappears_in
Which movies they appear in.
graphql/async-graphql/src/star_wars/model.rs:52
Functionasyncio_weather
Version 1: Calls 4 queries in sequential order, as an asynchronous handler
databases/sqlite/src/main.rs:25
Functionbad_request
(res: dev::ServiceResponse<B>)
basics/todo/src/api.rs:117
Functionbroadcast_msg
( broadcaster: web::Data<Broadcaster>, Path((msg,)): Path<(String,)>, )
server-sent-events/src/main.rs:42
Functionbroadcast_ws
Handshake and start broadcast WebSocket handler with heartbeats.
websockets/echo-actorless/src/main.rs:55
Functionbroadcast_ws
Broadcast text & binary messages received from a client, respond to ping messages, and monitor connection health to detect network issues and free up
websockets/echo-actorless/src/handler.rs:162
Functioncache_item
( cache: Data<ItemCache>, web::Json(form): web::Json<CacheInsert>, )
background-jobs/src/routes.rs:25
Functioncache_middleware
( req: ServiceRequest, next: Next<impl MessageBody>, )
cache/redis/src/main.rs:55
Functioncache_stuff
( web::Json(info): web::Json<CacheInfo>, redis: web::Data<redis::Client>, )
databases/redis/src/main.rs:27
Methodcall
(&self, req: ServiceRequest)
middleware/rate-limit/src/rate_limit.rs:35
Methodcall
(&self, mut req: ServiceRequest)
middleware/various/src/read_request_body.rs:52
Methodcall
(&self, req: ServiceRequest)
middleware/various/src/read_response_body.rs:49
Methodcall
(&self, request: ServiceRequest)
middleware/various/src/redirect.rs:45
Methodcall
(&self, req: ServiceRequest)
middleware/request-extensions/src/add_msg.rs:32
Functionchat_route
Entry point for our websocket route
websockets/chat/src/main.rs:24
Functionchat_route
Entry point for our route
websockets/chat-tcp/src/main.rs:23
Functionchat_ws
(req: HttpRequest, stream: web::Payload)
websockets/chat-broker/src/main.rs:15
Functionchat_ws
Handshake and start WebSocket handler with heartbeats.
websockets/chat-actorless/src/main.rs:33
Functionchat_ws
Echo text & binary messages received from the client, respond to ping messages, and monitor connection health to detect network issues and free up res
websockets/chat-actorless/src/handler.rs:17
Methodcheck
(&self, ctx: &GuardContext<'_>)
guards/src/main.rs:17
Functionconfig_app
(cfg: &mut web::ServiceConfig)
basics/nested-routing/src/app_config.rs:5
Methodcreate
Constructs new broadcaster and spawns ping loop.
server-sent-events/src/broadcast.rs:24
Methodcreate_human
(new_human: NewHuman)
graphql/juniper/src/schema.rs:47
Methodcreate_product
(context: &Context, product: ProductInput)
graphql/juniper-advanced/src/schemas/root.rs:126
Functioncreate_something
( some_data: web::Json<SomeData>, client: web::Data<Client>, )
json/json-validation/src/main.rs:65
Methodcreate_user
(context: &Context, user: UserInput)
graphql/juniper-advanced/src/schemas/root.rs:94
Methoddefault
()
middleware/http-response/src/main.rs:15
Methoddefault
()
middleware/http-response/src/simple.rs:22
← previousnext →101–200 of 527, ranked by callers