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
↓ 4 callersMethodall_nodes
Walks tree & returns all nodes
rsky-repo/src/mst/mod.rs:1310
↓ 4 callersFunctionappend_cursor_param
Append the cursor query param when a start cursor is set, including cursor=0.
rsky-wintermute/src/ingester/mod.rs:1147
↓ 4 callersMethodapply_commit
( &'a self, commit: CommitData, is_create: Option<bool>, )
rsky-pds/src/actor_store/repo/sql_repo.rs:305
↓ 4 callersFunctioncbor_to_struct
(bytes: Vec<u8>)
rsky-common/src/lib.rs:61
↓ 4 callersFunctioncreate_atproto_update_op
( last_op: CompatibleOp, signer: &SecretKey, opts: CreateAtprotoUpdateOpOpts, )
rsky-pds/src/plc/operations.rs:135
↓ 4 callersFunctioncreate_pool
( database_url: &str, pool_size: usize, )
rsky-wintermute/src/bin/fix_blob_refs.rs:147
↓ 4 callersMethoddelete
(&self, cid: String)
rsky-pds/src/actor_store/aws/s3.rs:138
↓ 4 callersMethoddelete
(&self, key: &str)
rsky-wintermute/src/ingester/backfill_queue.rs:43
↓ 4 callersMethodenqueue_label_live
Label live queue (future implementation)
rsky-wintermute/src/storage.rs:719
↓ 4 callersFunctionensure_valid_mst_key
(key: &str)
rsky-repo/src/mst/util.rs:45
↓ 4 callersFunctionensure_valid_nsid
Human readable constraints on NSID: - a valid domain in reversed notation - followed by an additional period-separated name, which is alphanumeric and
rsky-syntax/src/nsid.rs:38
↓ 4 callersMethodentries
(&self)
rsky-repo/src/block_map.rs:86
↓ 4 callersFunctionfail_job
Mark job as failed
rsky-video/src/db/mod.rs:304
↓ 4 callersMethodformat_commit
( &mut self, to_write: RecordWriteEnum, keypair: &Keypair, )
rsky-repo/src/repo.rs:217
↓ 4 callersFunctionformat_edit
( repo: &mut Repo, prev_data: RepoContents, keypair: Keypair, params: FormatEd
rsky-repo/src/repo.rs:488
↓ 4 callersMethodget_cid
(&self)
rsky-lexicon/src/blob_refs.rs:57
↓ 4 callersMethodget_op
(&self)
rsky-pds/src/xrpc_server/stream/frames.rs:55
↓ 4 callersFunctionget_posts_by_membership
( lang: Option<String>, limit: Option<i64>, params_cursor: Option<&str>, only_posts: bool,
rsky-feedgen/src/apis/mod.rs:26
↓ 4 callersFunctionget_random_str
()
rsky-common/src/lib.rs:48
↓ 4 callersMethodget_record
( &mut self, collection: String, rkey: String, )
rsky-repo/src/repo.rs:106
↓ 4 callersMethodget_record
( &mut self, uri: &AtUri, cid: Option<String>, include_soft_deleted: Option<bo
rsky-pds/src/actor_store/record/mod.rs:181
↓ 4 callersMethodget_tmp_path
(&self, key: &String)
rsky-pds/src/actor_store/aws/s3.rs:43
↓ 4 callersMethodhas
(&self, cid: Cid)
rsky-repo/src/cid_set.rs:41
↓ 4 callersMethodis_finished
Check if encoding is complete
rsky-video/src/bunny/types.rs:88
↓ 4 callersMethodis_host_banned
(&self, hostname: &str)
rsky-relay/src/server/server.rs:639
↓ 4 callersMethodis_storage_corrupted
(&self)
rsky-wintermute/src/types.rs:27
↓ 4 callersFunctionis_valid_datetime
(dt_str: S)
rsky-syntax/src/datetime.rs:70
↓ 4 callersMethodlist
( &mut self, count: Option<usize>, after: Option<String>, before: Option<Strin
rsky-repo/src/mst/mod.rs:1240
↓ 4 callersMethodpeek_backfill
Peek at the first N items in `repo_backfill` without removing them
rsky-wintermute/src/storage.rs:803
↓ 4 callersFunctionprepare_create
(opts: PrepareCreateOpts)
rsky-pds/src/repo/prepare.rs:174
↓ 4 callersFunctionprepare_delete
(opts: PrepareDeleteOpts)
rsky-pds/src/repo/prepare.rs:231
↓ 4 callersMethodprocess_write_blobs
(&self, writes: Vec<PreparedWrite>)
rsky-pds/src/actor_store/blob/mod.rs:222
↓ 4 callersMethodprocess_writes
( &mut self, writes: Vec<PreparedWrite>, swap_commit_cid: Option<Cid>, )
rsky-pds/src/actor_store/mod.rs:197
↓ 4 callersFunctionqueue_create
( url: String, records: Vec<rsky_firehose::models::CreateOp<T>>, client: &reqwest::Client, )
rsky-firehose/src/main.rs:53
↓ 4 callersFunctionqueue_create
( url: String, records: Vec<rsky_jetstream_subscriber::models::CreateOp<T>>, client: &reqwest::Cli
rsky-jetstream-subscriber/src/main.rs:30
↓ 4 callersFunctionqueue_delete
( url: String, records: Vec<rsky_jetstream_subscriber::models::DeleteOp>, client: &reqwest::Client
rsky-jetstream-subscriber/src/main.rs:11
↓ 4 callersFunctionrandom_cid
( storage: &mut Option<&mut (dyn RepoStorage + '_)>, rev: Option<String>, )
rsky-repo/src/mst/util.rs:188
↓ 4 callersFunctionread_car_with_root
(bytes: Vec<u8>)
rsky-repo/src/car.rs:149
↓ 4 callersFunctionrecord_discovery_round
(outcome: &'static str)
rsky-relay/src/metrics.rs:174
↓ 4 callersMethodrun
(mut self)
rsky-relay/src/server/server.rs:244
↓ 4 callersFunctionsanitize_text
(s: &str)
rsky-wintermute/src/indexer/mod.rs:60
↓ 4 callersMethodsend_req
(&mut self, web: Option<&str>, plc: Option<&str>)
rsky-relay/src/validator/resolver.rs:188
↓ 4 callersFunctionset_cursor_in_postgres
( pool: &Pool, service: &str, cursor: i64, )
rsky-wintermute/src/ingester/mod.rs:1153
↓ 4 callersMethodupdate
(&mut self, seq: &mut Cursor)
rsky-relay/src/publisher/worker.rs:104
↓ 4 callersMethodupdate_entry
update entry in place
rsky-repo/src/mst/mod.rs:930
↓ 4 callersMethodupdate_handle
@NOTE should always be paired with a sequenceHandle().
rsky-pds/src/account_manager/mod.rs:199
↓ 4 callersFunctionvalidate_bearer_token
( request: &Request, scopes: Vec<AuthScope>, verify_options: Option<VerificationOptions>, )
rsky-pds/src/auth_verifier.rs:754
↓ 3 callersFunctionadd_signature
( mut obj: CompatibleOpOrTombstone, key: &SecretKey, )
rsky-pds/src/plc/operations.rs:233
↓ 3 callersMethodas_raw_fd
(&self)
rsky-relay/src/publisher/connection.rs:42
↓ 3 callersMethodas_raw_fd
(&self)
rsky-relay/src/crawler/connection.rs:32
↓ 3 callersFunctionassert_valid_token
( did: &str, purpose: EmailTokenPurpose, token: &str, expiration_len: Option<i32>, db: &Db
rsky-pds/src/account_manager/helpers/email_token.rs:40
↓ 3 callersMethodbatch_remove_firehose_backfill
Helper to batch remove items from `firehose_backfill` queue using LMDB
rsky-wintermute/src/storage.rs:685
↓ 3 callersFunctionbuild_pds_url
Build a PDS API URL
rsky-pdsadmin/src/util/http_client.rs:72
↓ 3 callersFunctionbulk_update
Bulk-update OpenSearch documents via the Bulk API. Each entry in `updates` is (doc_id, update_body_json).
palomar-sync/src/main.rs:106
↓ 3 callersFunctioncbor_to_lex_record
(val: Vec<u8>)
rsky-repo/src/util.rs:99
↓ 3 callersMethodclear_repo_backfill
Clear all items from `repo_backfill`
rsky-wintermute/src/storage.rs:847
↓ 3 callersMethodclose
(&mut self)
rsky-relay/src/crawler/connection.rs:63
↓ 3 callersFunctioncompare_files
Compare two files to see if they are identical
rsky-pdsadmin/src/commands/update/mod.rs:101
↓ 3 callersFunctioncreate_label_message
Helper to create properly formatted label messages with header + body
rsky-wintermute/src/ingester/tests.rs:460
↓ 3 callersFunctioncreate_tokens
(opts: CreateTokensOpts)
rsky-pds/src/account_manager/helpers/auth.rs:76
↓ 3 callersFunctiondecode_refresh_token
@NOTE unsafe for verification, should only be used w/ direct output from createRefreshToken() or createTokens()
rsky-pds/src/account_manager/helpers/auth.rs:188
↓ 3 callersMethoddecompose
(self)
rsky-relay/src/crawler/types.rs:27
↓ 3 callersMethoddelete_cursor
(&self, name: &str)
rsky-wintermute/src/storage.rs:772
↓ 3 callersMethoddequeue_firehose_backfill_batch
Batch dequeue up to `limit` jobs from `firehose_backfill` in a single iteration LMDB provides consistent sub-ms latency regardless of queue size
rsky-wintermute/src/storage.rs:497
↓ 3 callersFunctiondeserialize
(d: D)
rsky-relay/src/validator/types.rs:955
↓ 3 callersFunctiondeserialize_node_data
( storage: Arc<RwLock<dyn RepoStorage>>, data: &NodeData, layer: Option<u32>, )
rsky-repo/src/mst/util.rs:108
↓ 3 callersMethoddid
(&self)
rsky-relay/src/validator/event.rs:349
↓ 3 callersFunctionempty_cid
()
rsky-relay/src/validator/event.rs:377
↓ 3 callersMethodenqueue_firehose_backfill_priority
Enqueue a firehose backfill job with HIGH priority (prefix "0:") Priority items are indexed BEFORE all normal backfill items
rsky-wintermute/src/storage.rs:388
↓ 3 callersFunctionensure_http_prefix
(str: String)
rsky-pds/src/plc/operations.rs:266
↓ 3 callersMethodensure_resolve
( &mut self, did: &String, force_refresh: Option<bool>, )
rsky-identity/src/did/did_resolver.rs:142
↓ 3 callersFunctionensure_valid_did
Human-readable constraints: - valid W3C DID (https://www.w3.org/TR/did-core/#did-syntax) - entire URI is ASCII: [a-zA-Z0-9._:%-] - always starts "did:
rsky-syntax/src/did.rs:30
↓ 3 callersFunctionensure_valid_handle_regex
(handle: S)
rsky-syntax/src/handle.rs:127
↓ 3 callersFunctionexecute
(command: &AccountCommands)
rsky-pdsadmin/src/commands/account/mod.rs:52
↓ 3 callersFunctionextract_multikey
(did: &String)
rsky-crypto/src/utils.rs:10
↓ 3 callersFunctionextract_prefixed_bytes
(multikey: String)
rsky-crypto/src/utils.rs:17
↓ 3 callersMethodfind_insertion_index
Determines index where a new entry (child or value) would be inserted, relevant to the given key. If the key would "split" an existing child entry, th
rsky-relay/src/validator/types.rs:697
↓ 3 callersFunctionformat_account_status
(account: Option<ActorAccount>)
rsky-pds/src/account_manager/helpers/account.rs:471
↓ 3 callersMethodformat_and_insert_posts_in_feed
( &self, mut feed: Vec<FeedViewPost>, posts: Vec<RecordDescript<Post>>, )
rsky-pds/src/read_after_write/viewer.rs:221
↓ 3 callersFunctionformat_did_key
(jwt_alg: String, key_bytes: Vec<u8>)
rsky-crypto/src/did.rs:51
↓ 3 callersFunctionformat_headers
( req: &ProxyRequest<'_>, aud: String, lxm: String, requester: Option<String>, )
rsky-pds/src/pipethrough.rs:281
↓ 3 callersMethodformat_simple_embed
(&self, embed: MediaUnion)
rsky-pds/src/read_after_write/viewer.rs:318
↓ 3 callersFunctionformat_url_and_aud
( req: &ProxyRequest<'_>, aud_override: Option<String>, )
rsky-pds/src/pipethrough.rs:233
↓ 3 callersFunctionfrom_millis_to_utc
(millis: i64)
rsky-common/src/time.rs:62
↓ 3 callersFunctionfrom_str_to_micros
Parse a datetime string to microseconds since epoch. Tries the primary RFC3339 variant format first, then falls back to full RFC 3339 parsing (handles
rsky-common/src/time.rs:24
↓ 3 callersFunctionfrom_str_to_millis
(str: &str)
rsky-common/src/time.rs:33
↓ 3 callersMethodget_account_by_email
( &self, email: &str, flags: Option<AvailabilityFlags>, )
rsky-pds/src/account_manager/mod.rs:95
↓ 3 callersMethodget_authenticated_agent_for_nsid
( &self, nsid: &str, )
rsky-pds/src/read_after_write/viewer.rs:612
↓ 3 callersFunctionget_blacksky_trending_cached
Cached version of get_blacksky_trending.
rsky-feedgen/src/apis/mod.rs:338
↓ 3 callersMethodget_blocks
( &'a self, cids: Vec<Cid>, )
rsky-pds/src/actor_store/repo/sql_repo.rs:88
↓ 3 callersMethodget_bytes
( &'a self, cid: &'a Cid, )
rsky-repo/src/storage/sync_storage.rs:26
↓ 3 callersMethodget_cursor
(&self, name: &str)
rsky-wintermute/src/storage.rs:756
↓ 3 callersFunctionget_env_var
Get a required environment variable
rsky-pdsadmin/src/util/env.rs:52
↓ 3 callersFunctionget_invite_codes_uses_v2
( codes: Vec<String>, db: &DbConn, )
rsky-pds/src/account_manager/helpers/invite.rs:193
↓ 3 callersMethodget_mime_type
(&self)
rsky-lexicon/src/blob_refs.rs:64
↓ 3 callersMethodget_root
(&'a self)
rsky-pds/src/actor_store/repo/sql_repo.rs:172
↓ 3 callersFunctionget_service_endpoint
(doc: DidDocument, opts: GetServiceEndpointOpts)
rsky-common/src/lib.rs:125
↓ 3 callersMethodget_type
(&self)
rsky-pds/src/xrpc_server/stream/frames.rs:49
↓ 3 callersFunctionhas_prefix
(bytes: &Vec<u8>, prefix: &Vec<u8>)
rsky-crypto/src/utils.rs:25
↓ 3 callersFunctioningest_collection_allowed
(collection: &str)
rsky-wintermute/src/config.rs:214
← previousnext →201–300 of 2,046, ranked by callers