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 callersFunctioncreate_op
( opts: CreateAtprotoOpInput, secret_key: SecretKey, )
rsky-pds/src/plc/operations.rs:29
↓ 1 callersFunctioncreate_refresh_token
(opts: CreateTokensOpts)
rsky-pds/src/account_manager/helpers/auth.rs:123
↓ 1 callersMethodcreate_repo
( &self, keypair: &Keypair, writes: Vec<PreparedCreateOrUpdate>, )
rsky-pds/src/actor_store/mod.rs:125
↓ 1 callersFunctioncreate_report
( agent: &AtpAgent<MemorySessionStore, ReqwestClient>, subject_ref: EmitEventInputSubjectRefs, rea
rsky-labeler/src/main.rs:194
↓ 1 callersFunctioncreate_request
(parts: &Parts, uri: &Uri)
rsky-relay/src/crawler/client.rs:66
↓ 1 callersMethodcreate_session
Auth ----------
rsky-pds/src/account_manager/mod.rs:232
↓ 1 callersFunctioncreate_test_command
Helper function to create an executable command
rsky-pdsadmin/tests/external_commands_tests.rs:10
↓ 1 callersMethodcreate_video
Create a new video object in Bunny Stream Returns the video GUID that can be used for uploading
rsky-video/src/bunny/mod.rs:39
↓ 1 callersFunctioncreate_write_to_op
(write: PreparedCreateOrUpdate)
rsky-repo/src/types.rs:253
↓ 1 callersMethodcurr
(&self)
rsky-pds/src/sequencer/mod.rs:68
↓ 1 callersMethodcursor_to_labeled_result
(&self, cursor: Cursor)
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:72
↓ 1 callersMethoddata
(&self)
rsky-repo/src/types.rs:57
↓ 1 callersFunctiondb_path
()
rsky-relay/src/types.rs:23
↓ 1 callersFunctiondeactivate_account
( did: &str, delete_after: Option<String>, db: &DbConn, )
rsky-pds/src/account_manager/helpers/account.rs:322
↓ 1 callersFunctiondecode_service_auth
Decode service auth JWT without audience validation Used for uploadVideo where the token's audience is the user's PDS DID, not the video service DID.
rsky-video/src/auth/mod.rs:120
↓ 1 callersFunctiondecode_uri_component
(input: &str)
rsky-identity/src/common/mod.rs:12
↓ 1 callersFunctiondedash
(str: String)
rsky-common/src/tid.rs:27
↓ 1 callersFunctiondedup_batch
Deduplicate a batch of (did, handle) pairs. For duplicate DIDs, keep the last entry (most recent PLC operation). For duplicate handles, keep the last
rsky-wintermute/src/bin/plc_import.rs:98
↓ 1 callersMethoddefault
()
rsky-pds/src/sequencer/events.rs:105
↓ 1 callersFunctiondefault_service
(req: &ProxyRequest<'_>, nsid: &str)
rsky-pds/src/pipethrough.rs:540
↓ 1 callersFunctiondelete_account
(did: &str, db: &DbConn)
rsky-pds/src/account_manager/helpers/account.rs:272
↓ 1 callersFunctiondelete_account
Delete an account
rsky-pdsadmin/src/commands/account/mod.rs:294
↓ 1 callersFunctiondelete_cursor_from_postgres
(pool: &Pool, service: &str)
rsky-wintermute/src/ingester/mod.rs:1170
↓ 1 callersFunctiondelete_cursor_from_postgres
(pool: &Pool, service: &str)
rsky-wintermute/src/ingester/backfill_queue.rs:242
↓ 1 callersMethoddelete_dereferenced_blobs
(&self, writes: Vec<PreparedWrite>)
rsky-pds/src/actor_store/blob/mod.rs:250
↓ 1 callersFunctiondelete_email_token
(did: &str, purpose: EmailTokenPurpose, db: &DbConn)
rsky-pds/src/account_manager/helpers/email_token.rs:107
↓ 1 callersFunctiondelete_expired_refresh_tokens
(did: &str, now: String, db: &DbConn)
rsky-pds/src/account_manager/helpers/auth.rs:287
↓ 1 callersMethoddelete_list
(&self)
rsky-repo/src/data_diff.rs:170
↓ 1 callersMethoddelete_many
(&self, cids: Vec<Cid>)
rsky-pds/src/actor_store/aws/s3.rs:143
↓ 1 callersMethoddelete_many
(&self, cids: Vec<Cid>)
rsky-pds/src/actor_store/repo/sql_repo.rs:447
↓ 1 callersMethoddelete_many_keys
(&self, keys: Vec<String>)
rsky-pds/src/actor_store/aws/s3.rs:180
↓ 1 callersMethoddelete_record
(&self, uri: &AtUri)
rsky-pds/src/actor_store/record/mod.rs:423
↓ 1 callersMethoddelete_recurse
(&mut self, key: &String)
rsky-repo/src/mst/mod.rs:887
↓ 1 callersFunctiondelete_write_to_op
(write: PreparedDelete)
rsky-repo/src/types.rs:273
↓ 1 callersMethoddequeue_backfill_batch
Bulk dequeue using a single Fjall iterator instead of creating one per item. With 24M+ items in the LSM tree, each `iter()` construction requires merg
rsky-wintermute/src/storage.rs:245
↓ 1 callersMethoddequeue_firehose_backfill_jobs
(&self)
rsky-wintermute/src/indexer/mod.rs:742
↓ 1 callersMethoddequeue_firehose_live_jobs
(&self)
rsky-wintermute/src/indexer/mod.rs:726
↓ 1 callersMethoddequeue_label_jobs
(&self)
rsky-wintermute/src/indexer/mod.rs:758
↓ 1 callersFunctiondiff_to_write_descripts
(diff: &DataDiff)
rsky-repo/src/util.rs:120
↓ 1 callersFunctiondisable_invite_codes
(opts: DisableInviteCodesOpts, db: &DbConn)
rsky-pds/src/account_manager/helpers/invite.rs:295
↓ 1 callersMethoddisable_invite_codes
(&self, opts: DisableInviteCodesOpts)
rsky-pds/src/account_manager/mod.rs:378
↓ 1 callersFunctiondo_plc_operation
(account: &ActorAccount, token: String)
rsky-pds/src/apis/com/atproto/identity/request_plc_operation_signature.rs:70
↓ 1 callersFunctiondo_plc_operation
(plc_url: &str, did: &str, op: Operation)
rsky-pds/src/apis/com/atproto/identity/submit_plc_operation.rs:122
↓ 1 callersFunctionencode_metrics
Encode all metrics in Prometheus text format
rsky-wintermute/src/metrics.rs:391
↓ 1 callersMethodencoding_progress
Get encoding progress as percentage
rsky-video/src/bunny/types.rs:63
↓ 1 callersMethodenqueue_firehose_backfill_batch
Batch enqueue multiple firehose backfill jobs in a single transaction
rsky-wintermute/src/storage.rs:348
↓ 1 callersMethodenqueue_firehose_backfill_priority_batch
Batch enqueue multiple firehose backfill jobs with HIGH priority in a single transaction
rsky-wintermute/src/storage.rs:418
↓ 1 callersFunctionenqueue_repos
Stream manifest rows (skipping already-done DIDs) into the work channel; or the recorded failures when `--retry-failed`.
rsky-wintermute/src/bin/car_loader.rs:480
↓ 1 callersFunctionensure_atproto_prefix
(str: String)
rsky-pds/src/plc/operations.rs:273
↓ 1 callersFunctionensure_creates
( descripts: Vec<RecordWriteDescript>, )
rsky-repo/src/util.rs:107
↓ 1 callersFunctionensure_handle_service_constraints
( handle: &str, available_user_domains: &[String], allow_reserved: bool, )
rsky-pds/src/handle/mod.rs:95
↓ 1 callersMethodensure_heights
TODO: this feels like a hack, and easy to forget
rsky-relay/src/validator/types.rs:802
↓ 1 callersFunctionensure_invite_is_available
(invite_code: String, db: &DbConn)
rsky-pds/src/account_manager/helpers/invite.rs:17
↓ 1 callersMethodensure_last_op
(&self, did: &String)
rsky-pds/src/plc/mod.rs:87
↓ 1 callersFunctionensure_v3_commit
(commit: VersionedCommit)
rsky-repo/src/util.rs:180
↓ 1 callersFunctionensure_valid_at_uri_regex
(uri: S)
rsky-syntax/src/aturi_validation.rs:152
↓ 1 callersFunctionenv_to_cfg
()
rsky-pds/src/config/mod.rs:67
↓ 1 callersFunctionestablish_connection
(database_url: &str)
rsky-pds/tests/common/mod.rs:23
↓ 1 callersFunctionexecute
Execute the CLI command
rsky-pdsadmin/src/commands/mod.rs:124
↓ 1 callersFunctionexecute
Execute the create-invite-code command
rsky-pdsadmin/src/commands/create_invite_code/mod.rs:9
↓ 1 callersFunctionexecute_external_command
Execute an external command
rsky-pdsadmin/src/commands/mod.rs:81
↓ 1 callersMethodexponential_backoff
(&self, mut waker: MutexGuard<Option<Waker>>)
rsky-common/src/async.rs:74
↓ 1 callersFunctionexport_queue
(storage: &Storage, path: &PathBuf, limit: Option<usize>)
rsky-wintermute/src/bin/queue_backfill.rs:480
↓ 1 callersFunctionexternal_command_exists
Check if an external command exists in PATH
rsky-pdsadmin/src/commands/mod.rs:76
↓ 1 callersFunctionextract_cid
Extract the CID string from a BlobRef
rsky-video/src/pds/mod.rs:280
↓ 1 callersFunctionextract_cids
---------------------------------------------------------- MST/Commit logic (unchanged from the table version) ---------------------------------------
rsky-satnav/src/main.rs:69
↓ 1 callersFunctionextract_handle
Extract handle from alsoKnownAs array (format: "at://handle.example.com")
rsky-wintermute/src/bin/plc_import.rs:67
↓ 1 callersFunctionextract_hashtags
(input: &str)
rsky-feedgen/src/apis/mod.rs:526
↓ 1 callersMethodfetch_page
(&self, cursor: Option<&str>)
rsky-relay/src/server/server.rs:49
↓ 1 callersFunctionfetch_plc_operations
Fetch PLC operations from the API using a persistent session.
rsky-relay/crawler.py:128
↓ 1 callersFunctionfetch_targets
(pool: &Pool, limit: usize)
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:143
↓ 1 callersFunctionfind_blob_refs
(val: Lex, path: Option<Vec<String>>, layer: Option<u8>)
rsky-pds/src/repo/prepare.rs:87
↓ 1 callersFunctionfind_compose_file
Find the compose.yaml file for the RSKY PDS
rsky-pdsadmin/src/util/env.rs:62
↓ 1 callersFunctionfind_posts_in_thread
( thread: &ThreadViewPost, posts: Vec<RecordDescript<Post>>, )
rsky-pds/src/apis/app/bsky/feed/get_post_thread.rs:233
↓ 1 callersFunctionfirehose_options
()
rsky-relay/src/types.rs:45
↓ 1 callersMethodformat_commit
( &mut self, writes: Vec<PreparedWrite>, swap_commit: Option<Cid>, )
rsky-pds/src/actor_store/mod.rs:237
↓ 1 callersFunctionformat_did_and_plc_op
(input: CreateAccountInput)
rsky-pds/src/apis/com/atproto/server/create_account.rs:339
↓ 1 callersFunctionformat_multikey
(jwt_alg: String, key_bytes: Vec<u8>)
rsky-crypto/src/did.rs:28
↓ 1 callersMethodformat_post_embed
(&self, post: Post)
rsky-pds/src/read_after_write/viewer.rs:296
↓ 1 callersMethodformat_record_embed_internal
( &self, embed: Record, )
rsky-pds/src/read_after_write/viewer.rs:378
↓ 1 callersMethodformat_record_with_media_embed
( &self, embed: RecordWithMedia, )
rsky-pds/src/read_after_write/viewer.rs:462
↓ 1 callersFunctionformat_req_init_with_value
( req: &ProxyRequest, url: Url, headers: HeaderMap, body: Option<JsonValue>, )
rsky-pds/src/pipethrough.rs:339
↓ 1 callersMethodformat_resign_commit
(&self, rev: String, keypair: &Keypair)
rsky-repo/src/repo.rs:320
↓ 1 callersFunctionformat_seq_account_evt
(did: String, status: AccountStatus)
rsky-pds/src/sequencer/events.rs:300
↓ 1 callersFunctionformat_seq_commit
( did: String, commit_data: CommitDataWithOps, )
rsky-pds/src/sequencer/events.rs:219
↓ 1 callersFunctionformat_seq_handle_update
(did: String, handle: String)
rsky-pds/src/sequencer/events.rs:268
↓ 1 callersFunctionformat_seq_identity_evt
( did: String, handle: Option<String>, )
rsky-pds/src/sequencer/events.rs:281
↓ 1 callersFunctionformat_seq_sync_evt
(did: String, data: SyncEvtData)
rsky-pds/src/sequencer/events.rs:326
↓ 1 callersMethodgen_key
(&self)
rsky-pds/src/actor_store/aws/s3.rs:39
↓ 1 callersFunctionget_account
( requester_did: &str, account_manager: &AccountManager, )
rsky-pds/src/apis/com/atproto/identity/request_plc_operation_signature.rs:26
↓ 1 callersFunctionget_account_admin_status
( did: &str, db: &DbConn, )
rsky-pds/src/account_manager/helpers/account.rs:426
↓ 1 callersMethodget_account_admin_status
( &self, did: &str, )
rsky-pds/src/account_manager/mod.rs:172
↓ 1 callersFunctionget_account_by_email
( _email: &str, flags: Option<AvailabilityFlags>, db: &DbConn, )
rsky-pds/src/account_manager/helpers/account.rs:158
↓ 1 callersFunctionget_account_invite_codes
(did: &str, db: &DbConn)
rsky-pds/src/account_manager/helpers/invite.rs:164
↓ 1 callersMethodget_account_invite_codes
(&self, did: &str)
rsky-pds/src/account_manager/mod.rs:361
↓ 1 callersMethodget_actors_needing_handle_resolution
(&self)
rsky-wintermute/src/indexer/mod.rs:286
↓ 1 callersFunctionget_affected_uris
( pool: &Pool, last_uri: Option<&str>, batch_size: usize, filter: Option<&str>, )
rsky-wintermute/src/bin/fix_blob_refs.rs:166
↓ 1 callersFunctionget_agent
( )
rsky-labeler/src/main.rs:61
↓ 1 callersFunctionget_and_parse_by_kind
( blocks: &BlockMap, cid: Cid, check: impl FnOnce(CborValue) -> bool, )
rsky-repo/src/parse.rs:30
↓ 1 callersMethodget_backlink_conflicts
( &self, uri: &AtUri, record: &RepoRecord, )
rsky-pds/src/actor_store/record/mod.rs:321
← previousnext →601–700 of 2,046, ranked by callers