MCPcopy Create free account

hub / github.com/blacksky-algorithms/rsky / functions

Functions2,046 in github.com/blacksky-algorithms/rsky

⨍ Functions 2,046◇ Types & classes 3,275
↓ 1 callersFunctioninner_request_account_delete
( auth: AccessStandardIncludeChecks, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/request_account_delete.rs:10
↓ 1 callersFunctioninner_request_email_confirmation
( auth: AccessStandardIncludeChecks, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/request_email_confirmation.rs:10
↓ 1 callersFunctioninner_request_email_update
( auth: AccessStandardIncludeChecks, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/request_email_update.rs:12
↓ 1 callersFunctioninner_request_password_reset
( body: Json<RequestPasswordResetInput>, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/request_password_reset.rs:12
↓ 1 callersFunctioninner_resolve_handle
( handle: String, id_resolver: &State<SharedIdResolver>, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/identity/resolve_handle.rs:39
↓ 1 callersFunctioninner_send_email
( body: Json<SendMailInput>, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/admin/send_email.rs:10
↓ 1 callersFunctioninner_update_account_email
( body: Json<UpdateAccountEmailInput>, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/admin/update_account_email.rs:9
↓ 1 callersFunctioninner_update_account_handle
( body: Json<UpdateAccountHandleInput>, sequencer: &State<SharedSequencer>, server_config: &State<
rsky-pds/src/apis/com/atproto/admin/update_account_handle.rs:15
↓ 1 callersFunctioninner_update_email
( body: Json<UpdateEmailInput>, auth: AccessFull, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/update_email.rs:10
↓ 1 callersFunctioninner_update_handle
( body: Json<UpdateHandleInput>, sequencer: &State<SharedSequencer>, server_config: &State<ServerC
rsky-pds/src/apis/com/atproto/identity/update_handle.rs:16
↓ 1 callersFunctioninner_update_subject_status
( body: Json<SubjectStatus>, sequencer: &State<SharedSequencer>, s3_config: &State<SdkConfig>,
rsky-pds/src/apis/com/atproto/admin/update_subject_status.rs:17
↓ 1 callersFunctioninner_upload_blob
( auth: AccessStandardIncludeChecks, blob: Data<'_>, content_type: ContentType, s3_config: &St
rsky-pds/src/apis/com/atproto/repo/upload_blob.rs:40
↓ 1 callersMethodinsert_child
inserts a node "below" this node in tree; either creating a new child entry or re-using an existing one
rsky-relay/src/validator/types.rs:372
↓ 1 callersFunctioninsert_into_thread_replies
( local_viewer: &'a LocalViewer, view: ThreadViewPost, descript: RecordDescript<Post>, )
rsky-pds/src/apis/app/bsky/feed/get_post_thread.rs:259
↓ 1 callersFunctioninsert_operations
Insert operations into the database.
rsky-relay/crawler.py:144
↓ 1 callersMethodinsert_parent
inserts a node "above" this node in tree, possibly splitting the current node
rsky-relay/src/validator/types.rs:355
↓ 1 callersMethodinto_node
Transforms an encoded `NodeData` to `Node` data structure format
rsky-relay/src/validator/types.rs:839
↓ 1 callersMethodinvert
(&mut self, op: &SubscribeReposCommitOperation)
rsky-relay/src/validator/types.rs:198
↓ 1 callersFunctionipld_to_lex
(val: Ipld)
rsky-repo/src/util.rs:73
↓ 1 callersFunctionis_backpressure
(err: &tungstenite::Error)
rsky-relay/src/publisher/connection.rs:122
↓ 1 callersFunctionis_basic_token
(request: &Request)
rsky-pds/src/auth_verifier.rs:956
↓ 1 callersFunctionis_blocking_error
(error: &io::Error)
rsky-relay/src/crawler/client.rs:95
↓ 1 callersFunctionis_compact_format
(sig: &[u8])
rsky-crypto/src/p256/operations.rs:39
↓ 1 callersFunctionis_compact_format
(sig: &[u8])
rsky-crypto/src/secp256k1/operations.rs:45
↓ 1 callersMethodis_encoding_complete
Check if encoding is complete (status 3 or 4)
rsky-video/src/bunny/types.rs:53
↓ 1 callersMethodis_encoding_failed
Check if encoding failed (status 5)
rsky-video/src/bunny/types.rs:58
↓ 1 callersFunctionis_excluded
( dids: Vec<&String>, conn: &mut PgConnection, )
rsky-feedgen/src/apis/mod.rs:506
↓ 1 callersMethodis_failed
Check if encoding failed
rsky-video/src/bunny/types.rs:98
↓ 1 callersMethodis_resolution_finished
Check if a resolution finished (video playable)
rsky-video/src/bunny/types.rs:93
↓ 1 callersFunctionis_running_as_root
()
rsky-pdsadmin/src/main.rs:48
↓ 1 callersFunctionis_running_in_container
()
rsky-pdsadmin/src/main.rs:63
↓ 1 callersFunctionis_safe_url
(url: Url)
rsky-pds/src/pipethrough.rs:580
↓ 1 callersFunctionis_service_domain
(handle: &str, available_user_domains: &[String])
rsky-pds/src/handle/mod.rs:89
↓ 1 callersFunctionis_users_feed
(feed: &AuthorFeed, requester: &String)
rsky-pds/src/apis/app/bsky/feed/get_author_feed.rs:201
↓ 1 callersMethodis_valid
(&self)
rsky-relay/src/validator/event.rs:118
↓ 1 callersFunctionis_valid_repo_mst_path
Restricted to a subset of ASCII characters — the allowed characters are alphanumeric (A-Za-z0-9), period, dash, underscore, colon, or tilde (.-_:~) Mu
rsky-repo/src/mst/util.rs:29
↓ 1 callersFunctionis_valid_tld
(handle: S)
rsky-syntax/src/handle.rs:46
↓ 1 callersMethoditer_reachable
(&self)
rsky-repo/src/mst/mod.rs:330
↓ 1 callersMethodlabel_result
(&self, result: TimeDidResult)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:58
↓ 1 callersFunctionlabel_subject
( agent: &AtpAgent<MemorySessionStore, ReqwestClient>, subject_ref: EmitEventInputSubjectRefs, )
rsky-labeler/src/main.rs:125
↓ 1 callersMethodlabeled_result_to_cursor
(&self, labeled: Cursor)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:65
↓ 1 callersFunctionlayer_for_entries
(entries: &[NodeEntry])
rsky-repo/src/mst/util.rs:151
↓ 1 callersMethodleaf_delete
(&mut self, key: &str, cid: Cid)
rsky-repo/src/data_diff.rs:128
↓ 1 callersMethodleaf_update
(&mut self, key: &str, prev: Cid, cid: Cid)
rsky-repo/src/data_diff.rs:112
↓ 1 callersMethodleaves
Walks tree & returns all leaves
rsky-repo/src/mst/mod.rs:1341
↓ 1 callersFunctionlex_to_ipld
(val: Lex)
rsky-repo/src/util.rs:50
↓ 1 callersFunctionlist_accounts
List all accounts on the PDS
rsky-pdsadmin/src/commands/account/mod.rs:67
↓ 1 callersFunctionlist_app_passwords
(did: &str, db: &DbConn)
rsky-pds/src/account_manager/helpers/password.rs:138
↓ 1 callersMethodlist_app_passwords
(&self, did: &str)
rsky-pds/src/account_manager/mod.rs:393
↓ 1 callersMethodlist_bans
(&self)
rsky-relay/src/server/server.rs:627
↓ 1 callersMethodlist_blobs
(&self, opts: ListBlobsOpts)
rsky-pds/src/actor_store/blob/mod.rs:491
↓ 1 callersMethodlist_collections
(&mut self)
rsky-pds/src/actor_store/record/mod.rs:105
↓ 1 callersMethodlist_hosts
(&self, url: &Url)
rsky-relay/src/server/server.rs:440
↓ 1 callersMethodlist_missing_blobs
( &self, opts: ListMissingBlobsOpts, )
rsky-pds/src/actor_store/blob/mod.rs:433
↓ 1 callersMethodlist_records_for_collection
( &mut self, collection: String, limit: i64, reverse: bool, cursor: Op
rsky-pds/src/actor_store/record/mod.rs:124
↓ 1 callersFunctionload_car
---------------------------------------------------------- CAR loading logic is unchanged. We store blocks for MST decoding and build `mst_entries` fo
rsky-satnav/src/main.rs:830
↓ 1 callersFunctionload_checkpoint
Load checkpoint state (completed DIDs and follower set).
scripts/priority_backfill_followers.py:50
↓ 1 callersFunctionload_dids
Load DIDs from a text file (one per line).
scripts/priority_backfill_followers.py:39
↓ 1 callersFunctionload_single_repo
Parse and write a single repo with verbose logging (for verifying one DID).
rsky-wintermute/src/bin/car_loader.rs:654
↓ 1 callersFunctionmain
()
rsky-relay/crawler.py:185
↓ 1 callersFunctionmain
()
rsky-relay/main.py:1
↓ 1 callersFunctionmain
()
scripts/priority_backfill_followers.py:124
↓ 1 callersFunctionmake_label
()
rsky-relay/src/validator/event.rs:435
↓ 1 callersMethodmake_permanent
(&self, key: String, cid: Cid)
rsky-pds/src/actor_store/aws/s3.rs:69
↓ 1 callersFunctionmark_event_at_now
(pool: &Pool, did: &str)
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:238
↓ 1 callersFunctionmst_diff
(curr: &mut MST, prev: Option<&mut MST>)
rsky-repo/src/mst/diff.rs:17
↓ 1 callersFunctionmultibase_to_bytes
(mb: String)
rsky-crypto/src/multibase.rs:4
↓ 1 callersFunctionmulticodec_wrap
https://github.com/gnunicorn/rust-multicodec/blob/master/src/lib.rs#L249-L260
rsky-crypto/src/utils.rs:36
↓ 1 callersMethodnew_element
(&self)
rsky-relay/src/types.rs:63
↓ 1 callersMethodnewer_than
(&self, other: &TID)
rsky-common/src/tid.rs:71
↓ 1 callersFunctionnodejs_format
(format: &str, args: &[&dyn std::fmt::Display])
rsky-pds/src/read_after_write/util.rs:198
↓ 1 callersFunctionnormalize_datetime_always
Variant of normalizeDatetime() which always returns a valid datetime string. * * If a InvalidDatetimeError is encountered, returns the UNIX epoch ti
rsky-syntax/src/datetime.rs:162
↓ 1 callersFunctionnormalize_handle
(handle: S)
rsky-syntax/src/handle.rs:144
↓ 1 callersFunctionnormalize_op
(op: CompatibleOp)
rsky-pds/src/plc/operations.rs:242
↓ 1 callersMethodnotify_of_update
(&mut self)
rsky-pds/src/crawlers.rs:30
↓ 1 callersFunctionnull_diff
(tree: MST)
rsky-repo/src/mst/diff.rs:7
↓ 1 callersMethodolder_than
(&self, other: &TID)
rsky-common/src/tid.rs:75
↓ 1 callersMethodpack
(&self, labeled: Option<Cursor>)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:92
↓ 1 callersMethodpack_cursor
(&self, cursor: Option<Cursor>)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:109
↓ 1 callersMethodpack_from_result
(&self, results: Vec<TimeDidResult>)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:85
↓ 1 callersMethodpack_from_result
(&self, results: Vec<TimeCodeResult>)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:86
↓ 1 callersMethodpaginate
( &self, opts: KeySetPaginateOpts, db: &DbConn, )
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:132
↓ 1 callersMethodpaginate
(&self, opts: KeySetPaginateOpts, db: &DbConn)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:133
↓ 1 callersFunctionparse_active_flag
Parses the `active` boolean out of a `com.atproto.sync.getRepoStatus` JSON body. Returns `Some(true)`/`Some(false)` if present, `None` if missing or m
rsky-wintermute/src/ingester/mod.rs:1120
↓ 1 callersFunctionparse_b64_url_to_json
(b64: &str)
rsky-pds/src/xrpc_server/auth.rs:31
↓ 1 callersFunctionparse_basic_auth
(token: &str)
rsky-pds/src/auth_verifier.rs:989
↓ 1 callersFunctionparse_did_doc
(input: &Bytes)
rsky-relay/src/validator/resolver.rs:330
↓ 1 callersFunctionparse_did_key
(did: &String)
rsky-crypto/src/did.rs:46
↓ 1 callersFunctionparse_payload
(b64: &str)
rsky-pds/src/xrpc_server/auth.rs:39
↓ 1 callersFunctionparse_plc_doc
(input: &str)
rsky-relay/src/validator/resolver.rs:318
↓ 1 callersFunctionparse_proxy_header
(req: &ProxyRequest<'_>)
rsky-pds/src/pipethrough.rs:377
↓ 1 callersFunctionparse_relative
(str: &str)
rsky-syntax/src/aturi.rs:223
↓ 1 callersFunctionparse_req_nsid
(req: &ProxyRequest)
rsky-pds/src/pipethrough.rs:412
↓ 1 callersFunctionparse_res
(_nsid: String, res: HandlerPipeThrough)
rsky-pds/src/pipethrough.rs:563
↓ 1 callersFunctionpeek_queue
(storage: &Storage, count: usize)
rsky-wintermute/src/bin/queue_backfill.rs:372
↓ 1 callersFunctionpipethrough_procedure_post
( req: &ProxyRequest<'_>, requester: Option<String>, body: Option<Data<'_>>, )
rsky-pds/src/pipethrough.rs:181
↓ 1 callersMethodpoll
( &mut self, )
rsky-relay/src/validator/resolver.rs:311
↓ 1 callersMethodpoll_inner
(&mut self)
rsky-relay/src/validator/resolver.rs:213
↓ 1 callersFunctionpost_no_fail
Make a POST request to the PDS without requiring success
rsky-pdsadmin/src/util/http_client.rs:162
↓ 1 callersMethodpost_op_url
(&self, did: &String)
rsky-pds/src/plc/mod.rs:19
← previousnext →801–900 of 2,046, ranked by callers