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
↓ 3 callersFunctioninstall_recorder
Build a recorder + handle without binding a socket. Tolerates "global already set".
rsky-relay/src/metrics.rs:82
↓ 3 callersFunctionis_banned_from_tv
(subject: &String)
rsky-feedgen/src/apis/mod.rs:1145
↓ 3 callersFunctionis_bearer_token
(request: &Request)
rsky-pds/src/auth_verifier.rs:949
↓ 3 callersFunctionis_included
( dids: Vec<&String>, conn: &mut PgConnection, )
rsky-feedgen/src/apis/mod.rs:491
↓ 3 callersMethodis_leaf
(&self)
rsky-repo/src/mst/mod.rs:311
↓ 3 callersMethodlabel_live_len
(&self)
rsky-wintermute/src/storage.rs:798
↓ 3 callersFunctionleading_zeros_on_hash
(key: &[u8])
rsky-repo/src/mst/util.rs:163
↓ 3 callersMethodleaf_count
Returns total leaf count
rsky-repo/src/mst/mod.rs:1353
↓ 3 callersFunctionload_env
Load environment variables from the PDS configuration file
rsky-pdsadmin/src/util/env.rs:17
↓ 3 callersFunctionmake_request
(req_init: RequestBuilder)
rsky-pds/src/pipethrough.rs:425
↓ 3 callersMethodmanifest_path
(&self)
rsky-wintermute/src/bin/car_loader.rs:84
↓ 3 callersMethodmove_object
(&self, keys: MoveObject)
rsky-pds/src/actor_store/aws/s3.rs:195
↓ 3 callersFunctionnormalize_and_validate_handle
( opts: HandleValidationOpts, ctx: HandleValidationContext<'_>, )
rsky-pds/src/handle/mod.rs:20
↓ 3 callersFunctionopen_keyspace
(path: &std::path::Path)
rsky-relay/src/types.rs:27
↓ 3 callersMethodparse
(data: &[u8])
rsky-relay/src/validator/event.rs:249
↓ 3 callersFunctionparse_data_key
(key: &String)
rsky-repo/src/util.rs:169
↓ 3 callersFunctionparse_hosts_relays
Parser used by the `HOSTS_RELAYS` `LazyLock`; testable independently of env mutation.
rsky-relay/src/config.rs:73
↓ 3 callersFunctionparse_key_endpoint
(endpoint: Option<&str>, key: Option<&str>)
rsky-relay/src/validator/resolver.rs:355
↓ 3 callersFunctionparse_proxy_res
(res: Response)
rsky-pds/src/pipethrough.rs:463
↓ 3 callersMethodpersist
(&mut self)
rsky-relay/src/validator/manager.rs:160
↓ 3 callersFunctionpipethrough
( req: &ProxyRequest<'_>, requester: Option<String>, override_opts: OverrideOpts, )
rsky-pds/src/pipethrough.rs:143
↓ 3 callersMethodpoll
(&mut self, idx: usize)
rsky-relay/src/crawler/worker.rs:186
↓ 3 callersFunctionpref_in_scope
(scope: AuthScope, pref_type: String)
rsky-pds/src/actor_store/preference/util.rs:5
↓ 3 callersFunctionpref_match_namespace
(namespace: &String, fullname: &String)
rsky-pds/src/actor_store/preference/mod.rs:140
↓ 3 callersFunctionprepare_update
(opts: PrepareUpdateOpts)
rsky-pds/src/repo/prepare.rs:204
↓ 3 callersMethodprocess_loop
Continuous pipeline: a dequeue task feeds jobs into a channel, N worker tasks consume from the channel and process repos independently. No batch barri
rsky-wintermute/src/backfiller/mod.rs:90
↓ 3 callersFunctionqueue_delete
( url: String, records: Vec<rsky_firehose::models::DeleteOp>, client: &reqwest::Client, )
rsky-firehose/src/main.rs:34
↓ 3 callersMethodread_firehose_event
(&self, seq: i64)
rsky-wintermute/src/storage.rs:164
↓ 3 callersMethodread_obj_and_bytes
( &'a self, cid: &'a Cid, check: Box<dyn Fn(CborValue) -> bool + Send + Sync>, )
rsky-repo/src/storage/readable_blockstore.rs:42
↓ 3 callersFunctionread_stream_car_with_root
( bytes: R, )
rsky-repo/src/car.rs:153
↓ 3 callersFunctionrecord_firehose_head
(seq: u64)
rsky-relay/src/metrics.rs:162
↓ 3 callersFunctionrecord_frame_emitted
(frame_type: &'static str, op: i8)
rsky-relay/src/metrics.rs:106
↓ 3 callersFunctionrecord_validator_deferred
(reason: &'static str)
rsky-relay/src/metrics.rs:147
↓ 3 callersFunctionrecord_validator_published
(reason: &'static str)
rsky-relay/src/metrics.rs:142
↓ 3 callersMethodremove_backfill
(&self, _key: &[u8])
rsky-wintermute/src/storage.rs:269
↓ 3 callersMethodremove_backfill_by_did
Remove all entries for a specific DID from `repo_backfill` Returns the number of entries removed
rsky-wintermute/src/storage.rs:824
↓ 3 callersMethodremove_entry
remove entry at index
rsky-repo/src/mst/mod.rs:943
↓ 3 callersFunctionrow_to_job
(row: &tokio_postgres::Row)
rsky-video/src/db/mod.rs:426
↓ 3 callersMethodsend_operation
(&self, did: &String, op: &OpOrTombstone)
rsky-pds/src/plc/mod.rs:43
↓ 3 callersFunctionserialize_node_data
(entries: &[NodeEntry])
rsky-repo/src/mst/util.rs:69
↓ 3 callersFunctionservice_auth_headers
(did: &str, aud: &str, lxm: &str)
rsky-pds/src/context.rs:16
↓ 3 callersMethodset_hostname
(&mut self, v: String)
rsky-syntax/src/aturi.rs:121
↓ 3 callersMethodset_rkey
(&mut self, v: String)
rsky-syntax/src/aturi.rs:174
↓ 3 callersFunctionset_test_env
Helper to set up test environment
rsky-pdsadmin/src/commands/account/tests/mod.rs:105
↓ 3 callersMethodshutdown
(self)
rsky-relay/src/crawler/worker.rs:73
↓ 3 callersFunctionsign_commit
(unsigned: UnsignedCommit, keypair: &Keypair)
rsky-repo/src/util.rs:20
↓ 3 callersMethodsplice_in
inserts entry at index
rsky-repo/src/mst/mod.rs:1038
↓ 3 callersMethodstep_over
(&mut self)
rsky-repo/src/mst/walker.rs:62
↓ 3 callersMethodsub
(self, rhs: u64)
rsky-relay/src/types.rs:144
↓ 3 callersFunctionsubscribe_url
()
rsky-wintermute/src/ingester/mod.rs:1182
↓ 3 callersMethodsuccessor
(self)
rsky-relay/src/types.rs:81
↓ 3 callersMethodto_bytes
(&self)
rsky-pds/src/xrpc_server/stream/frames.rs:59
↓ 3 callersMethodupdate_profile_view_basic
( &self, view: ProfileViewBasic, record: Profile, )
rsky-pds/src/read_after_write/viewer.rs:475
↓ 3 callersMethodverify_blob_and_make_permanent
(&self, blob: PreparedBlobRef)
rsky-pds/src/actor_store/blob/mod.rs:344
↓ 3 callersMethodwalk_leaves_from
(&mut self, key: &String)
rsky-repo/src/mst/mod.rs:1214
↓ 3 callersMethodwrite_firehose_event
( &self, seq: i64, event: &FirehoseEvent, )
rsky-wintermute/src/storage.rs:150
↓ 2 callersMethodactivate_account
(&self, did: &str)
rsky-pds/src/account_manager/mod.rs:208
↓ 2 callersFunctionadd_posts_to_thread
( local_viewer: &LocalViewer, original: ThreadViewPost, posts: Vec<RecordDescript<Post>>, )
rsky-pds/src/apis/app/bsky/feed/get_post_thread.rs:217
↓ 2 callersMethodadd_set
(&mut self, to_merge: CidSet)
rsky-repo/src/cid_set.rs:25
↓ 2 callersFunctionadd_visitor
( user: String, service: String, requested_feed: String, )
rsky-feedgen/src/apis/mod.rs:1098
↓ 2 callersFunctionadmin_post
Make a POST request to the PDS with admin authentication
rsky-pdsadmin/src/util/http_client.rs:111
↓ 2 callersFunctionassert_valid_did_documents_for_service
(did: String)
rsky-pds/src/apis/com/atproto/server/mod.rs:93
↓ 2 callersMethodassert_valid_email_token
( &self, did: &str, purpose: EmailTokenPurpose, token: &str, )
rsky-pds/src/account_manager/mod.rs:484
↓ 2 callersFunctionassert_valid_record
(record: &RepoRecord)
rsky-pds/src/repo/prepare.rs:140
↓ 2 callersMethodassociate_blob
(&self, blob: PreparedBlobRef, _record_uri: String)
rsky-pds/src/actor_store/blob/mod.rs:382
↓ 2 callersFunctionatproto_sign
(obj: &T, key: &SecretKey)
rsky-common/src/sign.rs:8
↓ 2 callersFunctionbearer_token_from_req
(request: &Request)
rsky-pds/src/auth_verifier.rs:963
↓ 2 callersFunctionblobs_for_write
(record: RepoRecord, validate: bool)
rsky-pds/src/repo/prepare.rs:48
↓ 2 callersMethodbuild
(row: Self::Row)
rsky-feedgen/src/models/post.rs:75
↓ 2 callersFunctionbuild_rocket
(cfg: Option<RocketConfig>)
rsky-pds/src/lib.rs:197
↓ 2 callersMethodcache_did
(&mut self, did: String, doc: DidDocument)
rsky-identity/src/types.rs:95
↓ 2 callersFunctioncbor_to_lex
(val: Vec<u8>)
rsky-repo/src/util.rs:94
↓ 2 callersMethodchild
(self)
rsky-relay/src/validator/types.rs:179
↓ 2 callersMethodchild_mut
(&mut self)
rsky-relay/src/validator/types.rs:171
↓ 2 callersMethodcid
(&self)
rsky-repo/src/types.rs:139
↓ 2 callersFunctioncid_for_safe_record
(record: RepoRecord)
rsky-pds/src/repo/prepare.rs:166
↓ 2 callersMethodcompare_key
Compares a provided `key` against the overall range of keys represented by a `Node`. This method will set the Dirty flag on this node, and any child n
rsky-relay/src/validator/types.rs:635
↓ 2 callersMethodcompare_to
newer > older
rsky-common/src/tid.rs:57
↓ 2 callersMethodconnect
(hostname: &str, mut cursor: Option<Cursor>)
rsky-relay/src/crawler/connection.rs:46
↓ 2 callersFunctionconnect_and_stream
( _storage: &Storage, labeler_host: &str, pool: &Arc<Pool>, semaphore: &Arc<Semaphore>, )
rsky-wintermute/src/ingester/labels.rs:66
↓ 2 callersFunctioncopy_insert_feed_items
Bulk insert `feed_item` records using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:364
↓ 2 callersFunctioncopy_update_handles
Bulk-update actor handles using COPY protocol. Only updates actors with NULL handles if null_only is true. Returns the number of actors updated.
rsky-wintermute/src/bin/plc_import.rs:119
↓ 2 callersFunctioncreate_admin_client
Create a new HTTP client with admin authentication
rsky-pdsadmin/src/util/http_client.rs:9
↓ 2 callersFunctioncreate_client
Create a new HTTP client without authentication
rsky-pdsadmin/src/util/http_client.rs:38
↓ 2 callersMethodcreate_invite_codes
( &self, to_create: Vec<AccountCodes>, use_count: i32, )
rsky-pds/src/account_manager/mod.rs:335
↓ 2 callersFunctioncreate_label_message_with_neg
( seq: i64, labels: Vec<(&str, &str, &str, &str, bool)>, // (src, uri, val, cts, neg) )
rsky-wintermute/src/ingester/tests.rs:473
↓ 2 callersMethodcreate_parent
(mut self)
rsky-repo/src/mst/mod.rs:1177
↓ 2 callersFunctioncreate_service_auth_headers
(params: ServiceJwtParams)
rsky-pds/src/xrpc_server/auth.rs:23
↓ 2 callersFunctioncreate_service_jwt
(params: ServiceJwtParams)
rsky-pds/src/account_manager/helpers/auth.rs:146
↓ 2 callersFunctioncreate_update_op
( last_op: CompatibleOp, signer: &SecretKey, func: G, )
rsky-pds/src/plc/operations.rs:186
↓ 2 callersMethodcursor_to_labeled_result
(&self, cursor: Cursor)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:73
↓ 2 callersMethoddeactivate_account
(&self, did: &str, delete_after: Option<String>)
rsky-pds/src/account_manager/mod.rs:204
↓ 2 callersMethoddelete_account
(&self, did: &str)
rsky-pds/src/account_manager/mod.rs:185
↓ 2 callersFunctiondelete_all_for_user
(did: &String, excluding_seqs: Option<Vec<i64>>)
rsky-pds/src/sequencer/mod.rs:307
↓ 2 callersMethoddelete_key
(&self, key: String)
rsky-pds/src/actor_store/aws/s3.rs:170
↓ 2 callersMethoddequeue_prioritized_jobs
(&self)
rsky-wintermute/src/indexer/mod.rs:776
↓ 2 callersFunctiondrain_client_until_n_binary
(client: &mut WsClient, n: usize, max_iter: usize)
rsky-relay/src/publisher/worker.rs:232
↓ 2 callersMethodenqueue_backfill_immediate
Enqueue a backfill job with IMMEDIATE priority (timestamp 0) These items are processed FIRST, before all other priority items
rsky-wintermute/src/storage.rs:215
↓ 2 callersFunctionensure_valid_at_uri
Human-readable constraints on ATURI: - following regular URLs, a 8KByte hard total length limit - follows ATURI docs on website - all ASCII characters
rsky-syntax/src/aturi_validation.rs:47
↓ 2 callersFunctionensure_valid_datetime
( dt_str: S, )
rsky-syntax/src/datetime.rs:20
← previousnext →301–400 of 2,046, ranked by callers