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
↓ 9 callersFunctionget_banned_response
()
rsky-feedgen/src/routes.rs:101
↓ 9 callersMethodhandle_command
(&mut self, command: Command, seq: Cursor)
rsky-relay/src/publisher/worker.rs:71
↓ 9 callersFunctionrecord_validator_passed_with_warning
(reason: &'static str)
rsky-relay/src/metrics.rs:157
↓ 9 callersMethodserialize
(self, capacity: usize, seq: Cursor)
rsky-relay/src/validator/event.rs:286
↓ 8 callersMethodadvance
advance the pointer to the next node in the tree, stepping into the current node if necessary
rsky-repo/src/mst/walker.rs:132
↓ 8 callersMethoddelete
(&mut self, cid: Cid)
rsky-repo/src/cid_set.rs:37
↓ 8 callersMethoddequeue_firehose_backfill
( &self, )
rsky-wintermute/src/storage.rs:454
↓ 8 callersMethodfirehose_backfill_len
(&self)
rsky-wintermute/src/storage.rs:785
↓ 8 callersFunctionget_records
( storage: Arc<RwLock<dyn RepoStorage>>, commit_cid: Cid, paths: Vec<RecordPath>, )
rsky-repo/src/sync/provider.rs:54
↓ 8 callersMethodget_stored_path
(&self, cid: Cid)
rsky-pds/src/actor_store/aws/s3.rs:47
↓ 8 callersMethodnext
(&mut self)
rsky-relay/src/types.rs:88
↓ 8 callersFunctionparse_label_message
(data: &[u8])
rsky-wintermute/src/ingester/labels.rs:223
↓ 8 callersFunctionsanitize_opt
(s: Option<&str>)
rsky-wintermute/src/indexer/mod.rs:64
↓ 8 callersFunctionverify_proofs
( proofs: Vec<u8>, claims: Vec<RecordCidClaim>, did: &str, did_key: &String, )
rsky-repo/src/sync/consumer.rs:140
↓ 8 callersFunctionws_pair_for_worker
()
rsky-relay/src/publisher/worker.rs:214
↓ 7 callersFunctionaccess_check
( req: &Request<'_>, scopes: Vec<AuthScope>, opts: Option<ValidateAccessTokenOpts>, )
rsky-pds/src/auth_verifier.rs:216
↓ 7 callersFunctionassert_repo_availability
( did: &String, is_admin_of_self: bool, account_manager: &AccountManager, )
rsky-pds/src/apis/com/atproto/repo/mod.rs:5
↓ 7 callersFunctionblocks_to_car_file
(root: Option<&Cid>, blocks: BlockMap)
rsky-repo/src/car.rs:127
↓ 7 callersMethoddequeue_label_live
( &self, )
rsky-wintermute/src/storage.rs:733
↓ 7 callersMethodenqueue_backfill_priority
Enqueue a backfill job with HIGH priority (prefix "0:") Priority items are processed BEFORE all normal items Use this for manual/on-demand backfill re
rsky-wintermute/src/storage.rs:196
↓ 7 callersMethodflush
(&mut self)
rsky-relay/src/publisher/types.rs:108
↓ 7 callersFunctiongenerate_bulk_data_keys
( count: usize, mut blockstore: Option<&mut (dyn RepoStorage + '_)>, )
rsky-repo/src/mst/util.rs:203
↓ 7 callersMethodget_blocks
( &'a self, cids: Vec<Cid>, )
rsky-repo/src/storage/sync_storage.rs:53
↓ 7 callersMethodget_contents
(&mut self)
rsky-repo/src/repo.rs:124
↓ 7 callersMethodhas
( &'a self, cid: Cid, )
rsky-repo/src/storage/sync_storage.rs:42
↓ 7 callersMethodlayer
return the current layer of the node you are walking
rsky-repo/src/mst/walker.rs:43
↓ 7 callersMethodload
(block_map: &BlockMap, cid: Cid)
rsky-relay/src/validator/types.rs:779
↓ 7 callersFunctionpopulate_backfill_queue
( storage: Arc<Storage>, relay_host: String, database_url: String, )
rsky-wintermute/src/ingester/backfill_queue.rs:51
↓ 7 callersFunctionrecord_validator_dropped
(reason: &'static str)
rsky-relay/src/metrics.rs:152
↓ 7 callersMethodremove_label_live
(&self, _key: &[u8])
rsky-wintermute/src/storage.rs:751
↓ 7 callersMethodstep_into
step into a subtree, throws if currently pointed at a leaf
rsky-repo/src/mst/walker.rs:91
↓ 7 callersMethodupdate
(&mut self, key: &str, value: Cid)
rsky-repo/src/mst/mod.rs:853
↓ 7 callersMethodwalk
Walk full tree & emit nodes, consumer can bail at any point by returning None
rsky-repo/src/mst/mod.rs:1280
↓ 6 callersMethodas_str
(self)
rsky-relay/src/metrics.rs:35
↓ 6 callersFunctionban_from_tv
( subject: &String, reason_param: Option<String>, tags_param: Option<Vec<String>>, )
rsky-feedgen/src/apis/mod.rs:1122
↓ 6 callersFunctioncontents_to_claims
(contents: RepoContents)
rsky-repo/src/repo.rs:459
↓ 6 callersFunctionconvert_record_to_ipld
Convert byte arrays in JSON to CID links (reuses backfiller logic)
rsky-wintermute/src/bin/fix_blob_refs.rs:48
↓ 6 callersMethoddequeue_firehose_backfill_partitioned
Partitioned dequeue for parallel workers - each worker owns a slice of the key space Key space partitioning: - Priority items (prefix "0:") are check
rsky-wintermute/src/storage.rs:558
↓ 6 callersMethoddequeue_firehose_live
(&self)
rsky-wintermute/src/storage.rs:290
↓ 6 callersMethoddestroy
(&mut self)
rsky-pds/src/actor_store/mod.rs:421
↓ 6 callersMethoddid
(&self)
rsky-repo/src/repo.rs:75
↓ 6 callersFunctionescape_copy_opt
Escape an optional COPY field, emitting the \N NULL marker when the value is absent.
rsky-wintermute/src/indexer/bulk.rs:34
↓ 6 callersFunctionestablish_connection_for_sequencer
()
rsky-pds/src/db/mod.rs:19
↓ 6 callersFunctionfixed_time
()
rsky-relay/src/validator/event.rs:372
↓ 6 callersFunctiongenerate_object
()
rsky-repo/src/repo.rs:378
↓ 6 callersMethodget_image_url
(&self, pattern: String, cid: String)
rsky-pds/src/read_after_write/viewer.rs:123
↓ 6 callersMethodget_layer
In most cases, we get the layer of a node from a hint on creation In the case of the topmost node in the tree, we look for a key in the node & determi
rsky-repo/src/mst/mod.rs:667
↓ 6 callersMethodget_many
(&mut self, cids: Vec<Cid>)
rsky-repo/src/block_map.rs:56
↓ 6 callersMethodget_root_detailed
(&self)
rsky-pds/src/actor_store/repo/sql_repo.rs:466
↓ 6 callersFunctionhandle_read_after_write
( nsid: String, requester: String, res: HandlerPipeThrough, munge: MungeFn<T>, s3_config:
rsky-pds/src/read_after_write/util.rs:110
↓ 6 callersFunctionis_user_or_admin
(auth: AccessOutput, did: &String)
rsky-pds/src/auth_verifier.rs:935
↓ 6 callersMethodnode_add
(&mut self, node: NodeEntry)
rsky-repo/src/data_diff.rs:64
↓ 6 callersMethodread_obj
( &'a self, cid: &'a Cid, check: Box<dyn Fn(CborValue) -> bool + Send + Sync>, )
rsky-repo/src/storage/readable_blockstore.rs:54
↓ 6 callersMethodremove_firehose_backfill
(&self, _key: &[u8])
rsky-wintermute/src/storage.rs:713
↓ 6 callersFunctionsetup_test_storage
()
rsky-wintermute/src/ingester/backfill_queue_tests.rs:8
↓ 6 callersMethodtime
(&self)
rsky-relay/src/validator/event.rs:339
↓ 6 callersMethodtimestamp
(&self)
rsky-common/src/tid.rs:48
↓ 6 callersFunctionverify_commit_sig
(commit: Commit, did_key: &String)
rsky-repo/src/util.rs:32
↓ 5 callersMethodapply_writes
( &mut self, to_write: RecordWriteEnum, keypair: &Keypair, )
rsky-repo/src/repo.rs:311
↓ 5 callersFunctionbefore
(config: FeedGenConfig)
rsky-feedgen/src/apis/mod.rs:1255
↓ 5 callersMethodclear
(mut self)
rsky-repo/src/cid_set.rs:49
↓ 5 callersFunctioncreate_commit_message
Helper to create properly formatted test messages with header + body
rsky-wintermute/src/ingester/tests.rs:17
↓ 5 callersMethodcreate_email_token
( &self, did: &str, purpose: EmailTokenPurpose, )
rsky-pds/src/account_manager/mod.rs:505
↓ 5 callersMethodenqueue_firehose_live
Firehose live queue (from ingester)
rsky-wintermute/src/storage.rs:275
↓ 5 callersFunctionestablish_connection
()
rsky-feedgen/src/db/mod.rs:6
↓ 5 callersFunctionexpect_valid
(tid: &str)
rsky-syntax/src/tid.rs:58
↓ 5 callersFunctionfetch_page_with_retry
( fetcher: &F, cursor: Option<&str>, sleep: impl Fn(Duration), )
rsky-relay/src/server/server.rs:60
↓ 5 callersMethodfirehose_live_len
(&self)
rsky-wintermute/src/storage.rs:781
↓ 5 callersFunctionfrom_str_to_utc
Parse a datetime string to a UTC DateTime. Tries the primary RFC3339 variant format first, then falls back to full RFC 3339 parsing (handles `+00:00`
rsky-common/src/time.rs:42
↓ 5 callersFunctionget_admin_token
Fetch PDS_ADMIN_PASS to be used for creating initial accounts */
rsky-pds/tests/common/mod.rs:36
↓ 5 callersFunctionget_client
Start Client for the RSky-PDS and have it use the provided postgres container */
rsky-pds/tests/common/mod.rs:60
↓ 5 callersFunctionget_pds_hostname
Get the PDS hostname from environment variables
rsky-pdsadmin/src/util/http_client.rs:54
↓ 5 callersFunctionget_postgres
Starts a testcontainer for a postgres instance, and runs migrations from rsky-pds */
rsky-pds/tests/common/mod.rs:44
↓ 5 callersMethodis_child
(&self)
rsky-relay/src/validator/types.rs:167
↓ 5 callersFunctionis_verbose
Check if verbose logging is enabled
rsky-pdsadmin/src/commands/mod.rs:71
↓ 5 callersMethodmerge
(&mut self, other: Self)
rsky-relay/src/validator/types.rs:571
↓ 5 callersMethodnode_delete
(&mut self, node: NodeEntry)
rsky-repo/src/data_diff.rs:75
↓ 5 callersFunctionopen_test_keyspace
()
rsky-relay/src/publisher/connection.rs:266
↓ 5 callersMethodpoll
false: closed true: not closed
rsky-relay/src/publisher/connection.rs:89
↓ 5 callersMethodpoll
(&mut self, seq: Cursor, idx: usize)
rsky-relay/src/publisher/worker.rs:167
↓ 5 callersFunctionread
(data: &[u8])
rsky-labeler/src/firehose.rs:33
↓ 5 callersFunctionread
(data: &str)
rsky-jetstream-subscriber/src/jetstream.rs:94
↓ 5 callersFunctionread_actor
( pool: &Pool, did: &str, )
rsky-wintermute/src/ingester/tests.rs:1005
↓ 5 callersMethodremove_firehose_live
(&self, _key: &[u8])
rsky-wintermute/src/storage.rs:306
↓ 5 callersMethodrequest_direct
Force an individual DID lookup from plc.directory, bypassing the export stream. Used when a hostname mismatch suggests the user may have migrated.
rsky-relay/src/validator/resolver.rs:167
↓ 5 callersMethodresolve_owned
( &mut self, did: &str, )
rsky-relay/src/validator/resolver.rs:296
↓ 5 callersFunctionsearch_banned_from_tv
( search_did: Option<String>, search_tag: Option<String>, limit: Option<i64>, offset: Option<i
rsky-feedgen/src/apis/mod.rs:1172
↓ 5 callersFunctionseed_actor
(pool: &Pool, did: &str)
rsky-wintermute/src/ingester/tests.rs:986
↓ 5 callersFunctionsend_template
(opts: MailOpts)
rsky-pds/src/mailer/mod.rs:28
↓ 5 callersMethodsequence_account_evt
( &mut self, did: String, status: AccountStatus, )
rsky-pds/src/sequencer/mod.rs:242
↓ 5 callersMethodsequence_commit
( &mut self, did: String, commit_data: CommitDataWithOps, )
rsky-pds/src/sequencer/mod.rs:219
↓ 5 callersMethodsequence_evt
(&mut self, evt: models::RepoSeq)
rsky-pds/src/sequencer/mod.rs:203
↓ 5 callersMethodsequence_identity_evt
( &mut self, did: String, handle: Option<String>, )
rsky-pds/src/sequencer/mod.rs:233
↓ 5 callersMethodserialize
(&self)
rsky-repo/src/mst/mod.rs:638
↓ 5 callersFunctionsetup_test_pool
()
rsky-wintermute/src/ingester/tests.rs:974
↓ 5 callersMethodswap_cid
(&self)
rsky-repo/src/types.rs:147
↓ 5 callersMethodtype_
(&self)
rsky-relay/src/validator/event.rs:318
↓ 5 callersFunctionunban_from_tv
(subject: &String)
rsky-feedgen/src/apis/mod.rs:1160
↓ 5 callersMethodupdate_repo_root
(&self, did: String, cid: Cid, rev: String)
rsky-pds/src/account_manager/mod.rs:180
↓ 5 callersFunctionvalidate_url
Check protocol and hostname to prevent potential SSRF
rsky-common/src/lib.rs:153
← previousnext →101–200 of 2,046, ranked by callers