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 callersFunctionset_bunny_video_id
Update job with bunny video ID and content CID
rsky-video/src/db/mod.rs:222
↓ 1 callersFunctionset_cursor_in_postgres
( pool: &Pool, service: &str, cursor: i64, )
rsky-wintermute/src/ingester/labels.rs:305
↓ 1 callersFunctionset_cursor_in_postgres
( pool: &Pool, service: &str, cursor: i64, )
rsky-wintermute/src/ingester/backfill_queue.rs:225
↓ 1 callersMethodset_nodelay
(&mut self, nodelay: bool)
rsky-relay/src/publisher/types.rs:117
↓ 1 callersFunctionset_pds_blob_ref
Store the PDS blob reference (from com.atproto.repo.uploadBlob)
rsky-video/src/db/mod.rs:245
↓ 1 callersMethodset_search
(&mut self, v: String)
rsky-syntax/src/aturi.rs:133
↓ 1 callersMethodset_sig
(&mut self, sig: String)
rsky-pds/src/plc/types.rs:72
↓ 1 callersFunctionsha256_to_cid
(hash: Vec<u8>)
rsky-common/src/ipld.rs:24
↓ 1 callersFunctionshow_stats
(storage: &Storage)
rsky-wintermute/src/bin/queue_backfill.rs:445
↓ 1 callersFunctionshow_status
(storage: &Storage)
rsky-wintermute/src/bin/queue_backfill.rs:357
↓ 1 callersMethodshutdown
(&mut self)
rsky-relay/src/publisher/types.rs:55
↓ 1 callersMethodshutdown
(self)
rsky-relay/src/publisher/manager.rs:68
↓ 1 callersMethodshutdown
(self)
rsky-relay/src/crawler/manager.rs:107
↓ 1 callersFunctionsign
(mut op: Operation, private_key: &SecretKey)
rsky-pds/src/plc/operations.rs:281
↓ 1 callersMethodsign_jwt
Sign a JWT with the service's private key
rsky-video/src/signing/mod.rs:107
↓ 1 callersMethodsize
(&self)
rsky-repo/src/cid_set.rs:45
↓ 1 callersMethodspawn_index_job_tasks
( &self, jobs: Vec<(Vec<u8>, IndexJob, QueueSource)>, )
rsky-wintermute/src/indexer/mod.rs:808
↓ 1 callersFunctionspawn_progress_logger
Log throughput (records/s, repos/s, percent via the state file) every 30s.
rsky-wintermute/src/bin/car_loader.rs:447
↓ 1 callersFunctionspawn_repo_enqueuer
Spawn the manifest reader on a blocking thread (rusqlite is synchronous).
rsky-wintermute/src/bin/car_loader.rs:469
↓ 1 callersMethodsplit_entries
(mut self, idx: usize)
rsky-relay/src/validator/types.rs:437
↓ 1 callersFunctionsubscribe_labels
( storage: Arc<Storage>, labeler_host: String, database_url: String, )
rsky-wintermute/src/ingester/labels.rs:16
↓ 1 callersFunctionsync_evt_data_from_commit
(mut commit_data: CommitDataWithOps)
rsky-pds/src/sequencer/events.rs:341
↓ 1 callersFunctionsync_followers
Keyset-paginated followersFuzzy sync. Fetches batch_size rows at a time ordered by did, using did > $last_did to avoid statement timeouts on large tab
palomar-sync/src/main.rs:169
↓ 1 callersFunctionsync_labeler
( labeler_host: &str, pool: &Arc<deadpool_postgres::Pool>, semaphore: &Arc<Semaphore>, stop_at
rsky-wintermute/src/bin/label_sync.rs:96
↓ 1 callersFunctionsync_pagerank
Export follow graph and actor list using psql COPY for streaming large tables, then run the external pagerank binary and index results to OpenSearch.
palomar-sync/src/main.rs:232
↓ 1 callersFunctiontag_subject
( agent: &AtpAgent<MemorySessionStore, ReqwestClient>, subject_ref: EmitEventInputSubjectRefs, )
rsky-labeler/src/main.rs:163
↓ 1 callersFunctiontakedown_account
Takedown an account
rsky-pdsadmin/src/commands/account/mod.rs:325
↓ 1 callersMethodtakedown_account
(&self, did: &str, takedown: StatusAttr)
rsky-pds/src/account_manager/mod.rs:190
↓ 1 callersMethodtrack_untethered_blob
(&self, metadata: BlobMetadata)
rsky-pds/src/actor_store/blob/mod.rs:172
↓ 1 callersMethodtree
(&self, root: Cid)
rsky-relay/src/validator/types.rs:120
↓ 1 callersMethodtree_add
(&mut self, cid: Cid, bytes: Vec<u8>)
rsky-repo/src/data_diff.rs:143
↓ 1 callersMethodtree_delete
(&mut self, cid: Cid)
rsky-repo/src/data_diff.rs:152
↓ 1 callersMethodtrim_top
(self)
rsky-repo/src/mst/mod.rs:1075
↓ 1 callersFunctiontry_client_handshake
(request: Request, config: Option<WebSocketConfig>)
rsky-relay/src/crawler/client.rs:39
↓ 1 callersFunctiontry_resolve_from_app_view
(handle: &String)
rsky-pds/src/apis/com/atproto/identity/resolve_handle.rs:11
↓ 1 callersMethodunban_host
(&self, hostname: &str)
rsky-relay/src/server/server.rs:621
↓ 1 callersMethodunpack
(&self, cursor_str: Option<String>)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:102
↓ 1 callersMethodunpack
(&self, cursor_str: Option<String>)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:103
↓ 1 callersMethodunpack_cursor
(&self, cursor_str: Option<String>)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:116
↓ 1 callersMethodunquarantine
(&self, cid: Cid)
rsky-pds/src/actor_store/aws/s3.rs:105
↓ 1 callersFunctionuntakedown_account
Remove a takedown from an account
rsky-pdsadmin/src/commands/account/mod.rs:355
↓ 1 callersMethodupdate
(&mut self)
rsky-relay/src/publisher/manager.rs:78
↓ 1 callersMethodupdate
(&mut self, cursor: &mut Cursor)
rsky-relay/src/validator/manager.rs:183
↓ 1 callersMethodupdate
(&mut self)
rsky-relay/src/crawler/worker.rs:140
↓ 1 callersMethodupdate
(&mut self)
rsky-relay/src/crawler/manager.rs:117
↓ 1 callersMethodupdate_blob_takedown_status
(&self, blob: Cid, takedown: StatusAttr)
rsky-pds/src/actor_store/blob/mod.rs:562
↓ 1 callersFunctionupdate_cursor
( url: String, service: String, sequence: &i64, client: &reqwest::Client, )
rsky-jetstream-subscriber/src/main.rs:49
↓ 1 callersFunctionupdate_handle
(did: &str, handle: &str, db: &DbConn)
rsky-pds/src/account_manager/helpers/account.rs:385
↓ 1 callersFunctionupdate_handle_op
( last_op: CompatibleOp, signer: &SecretKey, handle: String, )
rsky-pds/src/plc/operations.rs:81
↓ 1 callersMethodupdate_list
(&self)
rsky-repo/src/data_diff.rs:166
↓ 1 callersMethodupdate_profile_view
(&self, view: ProfileView, record: Profile)
rsky-pds/src/read_after_write/viewer.rs:506
↓ 1 callersMethodupdate_record_takedown_status
( &self, uri: &AtUri, takedown: StatusAttr, )
rsky-pds/src/actor_store/record/mod.rs:474
↓ 1 callersMethodupdate_root
( &'a self, cid: Cid, rev: String, is_create: Option<bool>, )
rsky-pds/src/actor_store/repo/sql_repo.rs:262
↓ 1 callersFunctionupdate_write_to_op
(write: PreparedCreateOrUpdate)
rsky-repo/src/types.rs:263
↓ 1 callersMethodupload_blob_and_get_metadata
( &self, user_suggested_mime: String, blob: Data<'_>, )
rsky-pds/src/actor_store/blob/mod.rs:140
↓ 1 callersMethodupload_blob_with_token
Upload a blob to a PDS by forwarding the client's service auth token The client provides a service auth token from their PDS with: - iss: user's DID
rsky-video/src/pds/mod.rs:181
↓ 1 callersMethodupload_video
Upload video binary data to Bunny Stream
rsky-video/src/bunny/mod.rs:70
↓ 1 callersMethodvalidate
(&self, commit: &Commit, head: &Cid)
rsky-relay/src/validator/types.rs:40
↓ 1 callersFunctionvalidate_access_token
@TODO: Implement DPop/OAuth
rsky-pds/src/auth_verifier.rs:797
↓ 1 callersMethodvalidate_did_doc
(&self, did: String, val: Value)
rsky-identity/src/did/did_resolver.rs:67
↓ 1 callersFunctionvalidate_handle
(handle: &str)
rsky-pds/src/apis/com/atproto/server/mod.rs:79
↓ 1 callersFunctionvalidate_inputs_for_local_pds
Validates Create Account Parameters and builds PLC Operation if needed
rsky-pds/src/apis/com/atproto/server/create_account.rs:236
↓ 1 callersFunctionvalidate_operation_body
(request: SubmitPlcOperationRequest)
rsky-pds/src/apis/com/atproto/identity/submit_plc_operation.rs:140
↓ 1 callersFunctionvalidate_plc_request
( did: &str, op: &Operation, public_endpoint: &str, account_manager: &AccountManager, )
rsky-pds/src/apis/com/atproto/identity/submit_plc_operation.rs:33
↓ 1 callersFunctionvalidate_service_auth
Decode and validate a service auth JWT (basic validation) For MVP, this does: - Decode the JWT payload - Check expiration - Optionally validate audie
rsky-video/src/auth/mod.rs:63
↓ 1 callersFunctionverify
(password: &String, stored_hash: &str)
rsky-pds/src/account_manager/helpers/password.rs:85
↓ 1 callersFunctionverify_account_password
(did: &str, password: &String, db: &DbConn)
rsky-pds/src/account_manager/helpers/password.rs:20
↓ 1 callersFunctionverify_app_password
(did: &str, password: &str, db: &DbConn)
rsky-pds/src/account_manager/helpers/password.rs:40
↓ 1 callersMethodverify_app_password
( &self, did: &str, password_str: &str, )
rsky-pds/src/account_manager/mod.rs:402
↓ 1 callersFunctionverify_blob
(blob: &PreparedBlobRef, found: &models::Blob)
rsky-pds/src/actor_store/blob/mod.rs:618
↓ 1 callersFunctionverify_jwt
(jwtstr: &String, service_did: &String)
rsky-feedgen/src/auth.rs:5
↓ 1 callersFunctionverify_jwt
(jwt: &str, verify_options: Option<VerificationOptions>)
rsky-pds/src/auth_verifier.rs:974
↓ 1 callersFunctionverify_records
( proofs: Vec<u8>, did: &str, signing_key: &String, )
rsky-repo/src/sync/consumer.rs:209
↓ 1 callersFunctionverify_repo
( blocks: &mut BlockMap, head: Cid, did: Option<&String>, signing_key: Option<&String>, op
rsky-repo/src/sync/consumer.rs:39
↓ 1 callersFunctionverify_repo_root
( storage: Arc<RwLock<dyn RepoStorage>>, head: Cid, did: Option<&String>, signing_key: Option<
rsky-repo/src/sync/consumer.rs:111
↓ 1 callersFunctionverify_sig
( public_key: &[u8], data: &[u8], sig: &[u8], opts: Option<VerifyOptions>, )
rsky-crypto/src/p256/operations.rs:21
↓ 1 callersFunctionverify_sig
( public_key: &[u8], data: &[u8], sig: &[u8], opts: Option<VerifyOptions>, )
rsky-crypto/src/secp256k1/operations.rs:21
↓ 1 callersMethodversion
(self)
rsky-repo/src/repo.rs:79
↓ 1 callersFunctionwalk_mst
Recursively walk an MST node
rsky-satnav/src/main.rs:276
↓ 1 callersFunctionwalk_mst_entries
Collect (collection, rkey, record_cid) from MST
rsky-satnav/src/main.rs:266
↓ 1 callersMethodwalk_reachable
Walk reachable branches of tree & emit nodes, consumer can bail at any point by returning false
rsky-repo/src/mst/mod.rs:1363
↓ 1 callersFunctionwebsocket_url
( subscriber_base_path: &str, subscriber_endpoint: &str, subscriber_cursor: Option<&str>, )
rsky-firehose/src/main.rs:335
↓ 1 callersMethodwrite_blocks
Recursively encodes sub-tree, optionally writing to blockstore. Returns root CID. This method will not error if tree is partial.
rsky-relay/src/validator/types.rs:253
↓ 1 callersFunctionwrite_car
( root: Option<&Cid>, user_fn: F, )
rsky-repo/src/car.rs:103
↓ 1 callersFunctionwrite_car
(root: String, blocks: Vec<(usize, BlockView)>)
rsky-satnav/src/main.rs:909
↓ 1 callersMethodwrite_to_car_stream
Sync Protocol
rsky-repo/src/mst/mod.rs:1379
FunctionApp
()
rsky-satnav/src/main.rs:744
FunctionHero
()
rsky-satnav/src/components/hero.rs:6
FunctionMstDiffView
(tree1: CarTree, tree2: CarTree)
rsky-satnav/src/main.rs:395
FunctionMstRepoView
(mst_entries: Vec<MstEntry>)
rsky-satnav/src/main.rs:317
Functionaccount_round_trip
()
rsky-relay/src/validator/event.rs:486
Functionaccount_status_display_matches_debug
()
rsky-relay/src/validator/event.rs:613
Functionactivate_account
( auth: AccessFull, sequencer: &State<SharedSequencer>, s3_config: &State<SdkConfig>, db: DbCo
rsky-pds/src/apis/com/atproto/server/activate_account.rs:63
Methodadd
(&mut self, value: T)
rsky-repo/src/block_map.rs:35
Methodadd
(self, rhs: u64)
rsky-relay/src/types.rs:134
Functionadd_refresh_grace_period
(opts: RefreshGracePeriodOpts, db: &DbConn)
rsky-pds/src/account_manager/helpers/auth.rs:301
Functionadd_sub_round_trip
()
rsky-relay/src/types.rs:202
Functionadds_content_collection
()
rsky-repo/src/repo.rs:653
Functionadds_records
()
rsky-repo/src/mst/mod.rs:1540
Functionadmin_get
Make a GET request to the PDS with admin authentication
rsky-pdsadmin/src/util/http_client.rs:79
← previousnext →1,001–1,100 of 2,046, ranked by callers