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 callersFunctionprepare_import_repo_writes
Converts list of RecordWriteDescripts into a list of PreparedWrites
rsky-pds/src/apis/com/atproto/repo/import_repo.rs:142
↓ 1 callersMethodprepend
prepend entry to end of the node
rsky-repo/src/mst/mod.rs:959
↓ 1 callersFunctionprint_help
Print the help information
rsky-pdsadmin/src/commands/mod.rs:180
↓ 1 callersFunctionprocess
(message: Vec<u8>, client: &reqwest::Client)
rsky-firehose/src/main.rs:92
↓ 1 callersFunctionprocess
( message: Vec<u8>, agent: &AtpAgent<MemorySessionStore, ReqwestClient>, )
rsky-labeler/src/main.rs:227
↓ 1 callersFunctionprocess
(message: String, client: &reqwest::Client)
rsky-jetstream-subscriber/src/main.rs:70
↓ 1 callersFunctionprocess_did
( pool: &deadpool_postgres::Pool, http_client: &reqwest::Client, did: &str, )
rsky-wintermute/src/bin/direct_index.rs:79
↓ 1 callersMethodprocess_firehose_backfill_loop
(&self)
rsky-wintermute/src/indexer/mod.rs:432
↓ 1 callersMethodprocess_firehose_live_loop
(&self)
rsky-wintermute/src/indexer/mod.rs:336
↓ 1 callersMethodprocess_handle_resolution_loop
(&self)
rsky-wintermute/src/indexer/mod.rs:184
↓ 1 callersMethodprocess_import_repo
( &mut self, commit: CommitData, writes: Vec<PreparedWrite>, )
rsky-pds/src/actor_store/mod.rs:177
↓ 1 callersFunctionprocess_label_event_safe
Process a label event: only apply negations to existing labels. Skips all positive labels entirely -- never inserts new rows. Returns (negations_appli
rsky-wintermute/src/bin/label_sync.rs:215
↓ 1 callersFunctionprocess_labels
(message: Vec<u8>, client: &reqwest::Client)
rsky-firehose/src/main.rs:279
↓ 1 callersMethodprocess_labels_loop
(&self)
rsky-wintermute/src/indexer/mod.rs:599
↓ 1 callersFunctionprocess_one
( pool: &Pool, http: &reqwest::Client, plc_url: &str, did: &str, dry_run: bool, )
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:157
↓ 1 callersFunctionprocess_uri
( pool: &Pool, uri: &str, dry_run: bool, stats: &Stats, )
rsky-wintermute/src/bin/fix_blob_refs.rs:228
↓ 1 callersMethodput_many
( &'a self, _to_put: BlockMap, _rev: String, )
rsky-repo/src/storage/sync_storage.rs:88
↓ 1 callersMethodput_many
( &'a self, to_put: BlockMap, rev: String, )
rsky-pds/src/actor_store/repo/sql_repo.rs:213
↓ 1 callersMethodput_preferences
( &self, values: Vec<RefPreferences>, namespace: String, scope: AuthScope,
rsky-pds/src/actor_store/preference/mod.rs:60
↓ 1 callersMethodquarantine
(&self, cid: Cid)
rsky-pds/src/actor_store/aws/s3.rs:97
↓ 1 callersMethodquery_db
(&mut self, did: &str)
rsky-relay/src/validator/resolver.rs:137
↓ 1 callersMethodquery_hosts
(&mut self)
rsky-relay/src/server/server.rs:536
↓ 1 callersMethodquery_hosts_with_fetcher
( &mut self, fetcher: &F, sleep: impl Fn(Duration) + Copy, seen: &mut hashbrown::HashSet<Strin
rsky-relay/src/server/server.rs:557
↓ 1 callersFunctionqueue_dids
(storage: &Storage, dids: &[String], priority: bool, immediate: bool)
rsky-wintermute/src/bin/queue_backfill.rs:303
↓ 1 callersFunctionqueue_from_csv
( storage: &Storage, path: &PathBuf, priority: bool, immediate: bool, )
rsky-wintermute/src/bin/queue_backfill.rs:145
↓ 1 callersFunctionqueue_from_pds
(storage: &Storage, host: &str, priority: bool)
rsky-wintermute/src/bin/queue_backfill.rs:223
↓ 1 callersFunctionqueue_options
()
rsky-relay/src/types.rs:40
↓ 1 callersFunctionrandom_bytes
(len: usize)
rsky-crypto/src/utils.rs:29
↓ 1 callersMethodreachable_leaves
(self)
rsky-repo/src/mst/mod.rs:1367
↓ 1 callersFunctionread_after_write_internal
( nsid: String, requester: String, res: HandlerPipeThrough, munge: MungeFn<T>, s3_config:
rsky-pds/src/read_after_write/util.rs:145
↓ 1 callersFunctionread_after_write_not_found
( local_viewer: LocalViewer, uri: String, parentHeight: u16, requester: String, headers: O
rsky-pds/src/apis/app/bsky/feed/get_post_thread.rs:350
↓ 1 callersFunctionread_array_buffer_res
(res: Response)
rsky-pds/src/pipethrough.rs:570
↓ 1 callersFunctionread_blocks
(mut reader: &mut T)
rsky-firehose/src/car.rs:61
↓ 1 callersFunctionread_blocks
(mut reader: &mut T)
rsky-labeler/src/car.rs:61
↓ 1 callersFunctionread_commit
Reads the commit from the single root
rsky-satnav/src/main.rs:151
↓ 1 callersFunctionread_header
(reader: &mut T)
rsky-firehose/src/car.rs:54
↓ 1 callersFunctionread_header
(reader: &mut T)
rsky-labeler/src/car.rs:54
↓ 1 callersFunctionread_labels
(data: &[u8])
rsky-firehose/src/firehose.rs:94
↓ 1 callersFunctionread_mst_node
Reads and decodes an MST node from the block map
rsky-satnav/src/main.rs:199
↓ 1 callersFunctionread_uvarint64
(reader: &mut T)
rsky-firehose/src/car.rs:16
↓ 1 callersFunctionread_uvarint64
(reader: &mut T)
rsky-labeler/src/car.rs:16
↓ 1 callersFunctionrecord_allowed
(allow: &[String], collection: &str)
rsky-wintermute/src/config.rs:192
↓ 1 callersFunctionrecord_invite_use
( did: String, invite_code: Option<String>, now: String, db: &DbConn, )
rsky-pds/src/account_manager/helpers/invite.rs:52
↓ 1 callersFunctionrecord_queue_depth_bytes
(bytes: u64)
rsky-relay/src/metrics.rs:168
↓ 1 callersFunctionrecord_subscriber_count
(n: i64)
rsky-relay/src/metrics.rs:116
↓ 1 callersFunctionrecord_upstream_disconnect
(host: &str, reason: &'static str)
rsky-relay/src/metrics.rs:132
↓ 1 callersFunctionrecord_upstream_event
(host: &str, kind: &'static str)
rsky-relay/src/metrics.rs:127
↓ 1 callersFunctionrecord_validator_rejected
(reason: &'static str)
rsky-relay/src/metrics.rs:137
↓ 1 callersMethodrecycle
(&self, _: &mut Message)
rsky-relay/src/types.rs:67
↓ 1 callersMethodrefresh_bans
(&mut self)
rsky-relay/src/crawler/manager.rs:210
↓ 1 callersMethodrefresh_cache
(&mut self, did: String)
rsky-identity/src/did/did_resolver.rs:89
↓ 1 callersFunctionregister_account
( did: String, email: String, password: String, db: &DbConn, )
rsky-pds/src/account_manager/helpers/account.rs:246
↓ 1 callersFunctionregister_actor
( did: String, handle: String, deactivated: Option<bool>, db: &DbConn, )
rsky-pds/src/account_manager/helpers/account.rs:207
↓ 1 callersFunctionrelative_regex
(input: &str)
rsky-syntax/src/aturi.rs:20
↓ 1 callersMethodremove_backlinks_by_uri
(&self, uri: &AtUri)
rsky-pds/src/actor_store/record/mod.rs:444
↓ 1 callersMethodremove_child
internal helper
rsky-relay/src/validator/types.rs:539
↓ 1 callersFunctionremove_from_queue
(storage: &Storage, did: &str)
rsky-wintermute/src/bin/queue_backfill.rs:501
↓ 1 callersMethodreplace_with_split
replaces an entry with [ Some(tree), Leaf, Some(tree) ]
rsky-repo/src/mst/mod.rs:1051
↓ 1 callersFunctionreport_status
Print percent-complete and recent rate from the state file (safe to run during a load).
rsky-wintermute/src/bin/car_loader.rs:609
↓ 1 callersMethodrequest_seq_range
(&self, opts: RequestSeqRangeOpts)
rsky-pds/src/sequencer/mod.rs:109
↓ 1 callersFunctionreset_password
Reset the password for an account
rsky-pdsadmin/src/commands/account/mod.rs:381
↓ 1 callersMethodreset_password
(&self, opts: ResetPasswordOpts)
rsky-pds/src/account_manager/mod.rs:411
↓ 1 callersMethodresolve
( &mut self, did: String, force_refresh: Option<bool>, )
rsky-identity/src/did/did_resolver.rs:101
↓ 1 callersMethodresolve
(&mut self, did: &str)
rsky-relay/src/validator/resolver.rs:124
↓ 1 callersMethodresolve_backup_dns
(&mut self, handle: &String)
rsky-identity/src/handle/mod.rs:83
↓ 1 callersMethodresolve_dns
(&self, handle: &String)
rsky-identity/src/handle/mod.rs:43
↓ 1 callersMethodresolve_http
(&self, handle: &String)
rsky-identity/src/handle/mod.rs:59
↓ 1 callersMethodresolve_no_check
(&self, did: String)
rsky-identity/src/did/did_resolver.rs:17
↓ 1 callersFunctionresolve_pds
(plc_url: &str, did: &str)
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:249
↓ 1 callersMethodresolve_pds_endpoint
Resolve a DID to find the PDS endpoint
rsky-video/src/pds/mod.rs:90
↓ 1 callersFunctionresolve_start_cursor
Resolve the start cursor for a connection: a saved cursor wins; otherwise fall back to the configured initial cursor (None = start live, Some(0) = old
rsky-wintermute/src/ingester/mod.rs:1142
↓ 1 callersMethodrevoke_app_password
(&self, did: String, name: String)
rsky-pds/src/account_manager/mod.rs:445
↓ 1 callersFunctionrevoke_refresh_token
(id: String, db: &DbConn)
rsky-pds/src/account_manager/helpers/auth.rs:230
↓ 1 callersMethodrevoke_refresh_token
(&self, id: String)
rsky-pds/src/account_manager/mod.rs:328
↓ 1 callersMethodrkey
(&self)
rsky-repo/src/types.rs:244
↓ 1 callersMethodroot
Returns the overall root-node CID for the MST. If possible, lazily returned a known value. If necessary, recursively encodes tree nodes to compute CID
rsky-relay/src/validator/types.rs:241
↓ 1 callersMethodrotate_refresh_token
(&self, id: &String)
rsky-pds/src/account_manager/mod.rs:256
↓ 1 callersFunctionrun
()
rsky-pdsadmin/src/main.rs:29
↓ 1 callersMethodrun
(mut self)
rsky-relay/src/publisher/manager.rs:60
↓ 1 callersMethodrun
(mut self)
rsky-relay/src/crawler/manager.rs:99
↓ 1 callersMethodrun
(self)
rsky-wintermute/src/backfiller/mod.rs:65
↓ 1 callersMethodrun
(self)
rsky-wintermute/src/indexer/mod.rs:142
↓ 1 callersFunctionrun_diesel_cli
Run migrations using diesel CLI
rsky-pdsadmin/src/commands/rsky_pds/mod.rs:71
↓ 1 callersFunctionrun_embedded_migrations
Run embedded migrations using diesel_migrations
rsky-pdsadmin/src/commands/rsky_pds/mod.rs:51
↓ 1 callersFunctionrun_full_load
Run the full load: enqueue repos from the manifest, parse them in worker tasks, and write the resulting records to Postgres in cross-repo batches.
rsky-wintermute/src/bin/car_loader.rs:267
↓ 1 callersFunctionrun_migrations
Run database migrations
rsky-video/src/db/mod.rs:53
↓ 1 callersFunctionrun_single
----------------- one-shot test runner ----------------------------------
rsky-repo/tests/interop.rs:74
↓ 1 callersFunctionrun_state_store
Owns the state SQLite on a single thread: records done/failed repos, failed records, and periodic progress samples.
rsky-wintermute/src/bin/car_loader.rs:536
↓ 1 callersFunctionsafe_resolve_did_doc
( id_resolver: &State<SharedIdResolver>, did: &String, force_refresh: Option<bool>, )
rsky-pds/src/apis/com/atproto/server/mod.rs:41
↓ 1 callersFunctionsave_video_mapping
Save video mapping (did/cid -> bunny_video_id)
rsky-video/src/db/mod.rs:390
↓ 1 callersFunctionsearch_queue
(storage: &Storage, did: &str, limit: Option<usize>)
rsky-wintermute/src/bin/queue_backfill.rs:405
↓ 1 callersFunctionsend_account_delete
(to: String, params: TokenParam)
rsky-pds/src/mailer/mod.rs:72
↓ 1 callersFunctionsend_confirm_email
(to: String, params: TokenParam)
rsky-pds/src/mailer/mod.rs:84
↓ 1 callersFunctionsend_plc_operation
(to: String, params: TokenParam)
rsky-pds/src/mailer/mod.rs:108
↓ 1 callersFunctionsend_reset_password
(to: String, params: IdentifierAndTokenParams)
rsky-pds/src/mailer/mod.rs:59
↓ 1 callersFunctionsend_update_email
(to: String, params: TokenParam)
rsky-pds/src/mailer/mod.rs:96
↓ 1 callersMethodseq
(&self)
rsky-pds/src/sequencer/events.rs:209
↓ 1 callersMethodsequence_handle_update
(&mut self, did: String, handle: String)
rsky-pds/src/sequencer/mod.rs:228
↓ 1 callersMethodservice_auth_headers
(&self, did: &str, lxm: &str)
rsky-pds/src/read_after_write/viewer.rs:138
↓ 1 callersFunctionset_account_invites_disabled
(did: &str, disabled: bool, db: &DbConn)
rsky-pds/src/account_manager/helpers/invite.rs:280
← previousnext →901–1,000 of 2,046, ranked by callers