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
↓ 2 callersFunctionensure_valid_did_regex
(did: S)
rsky-syntax/src/did.rs:70
↓ 2 callersFunctionensure_valid_nsid_regex
(nsid: &str)
rsky-syntax/src/nsid.rs:104
↓ 2 callersFunctionensure_valid_record_key
Validates a record key according to AT Protocol specification. Record Keys constraints: - Must contain only a subset of ASCII characters: alphanumeri
rsky-syntax/src/record_key.rs:27
↓ 2 callersFunctionensure_valid_tid
Validates a TID string according to the atproto specification. TID ("timestamp identifier") is a compact string identifier based on an integer timest
rsky-syntax/src/tid.rs:34
↓ 2 callersFunctionexecute
Execute the request-crawl command
rsky-pdsadmin/src/commands/request_crawl/mod.rs:8
↓ 2 callersMethodexpire
(&mut self, did: &str, time: DateTime<Utc>)
rsky-relay/src/validator/resolver.rs:114
↓ 2 callersMethodexponential_backoff
(&mut self)
rsky-pds/src/sequencer/mod.rs:191
↓ 2 callersFunctionextract_auth_header
Extract and validate the Authorization header
rsky-video/src/auth/mod.rs:40
↓ 2 callersMethodextract_pds_from_did_doc
Extract PDS endpoint from a DID document
rsky-video/src/pds/mod.rs:148
↓ 2 callersFunctionfetch_valid_repo
()
rsky-repo/src/car.rs:184
↓ 2 callersMethodfind_child
Looks for a "child" entry which the key would live under.
rsky-relay/src/validator/types.rs:761
↓ 2 callersMethodfind_value
Looks for a "value" entry in the node with the exact key.
rsky-relay/src/validator/types.rs:745
↓ 2 callersFunctionformat_munged_response
( body: T, lag: Option<usize>, )
rsky-pds/src/read_after_write/util.rs:180
↓ 2 callersMethodformat_record_embed
(&self, embed: Record)
rsky-pds/src/read_after_write/viewer.rs:365
↓ 2 callersFunctionformat_req_init
( req: &ProxyRequest, url: Url, headers: HeaderMap, body: Option<Vec<u8>>, )
rsky-pds/src/pipethrough.rs:301
↓ 2 callersFunctionfrom_micros_to_utc
(micros: i64)
rsky-common/src/time.rs:52
↓ 2 callersFunctiongen_invite_code
generate an invite code preceded by the hostname with '.'s replaced by '-'s, so it is not mistakable for a link ex: blacksky-app-abc234-567xy regex: b
rsky-pds/src/apis/com/atproto/server/mod.rs:63
↓ 2 callersFunctiongen_invite_codes
(count: i32)
rsky-pds/src/apis/com/atproto/server/mod.rs:71
↓ 2 callersFunctiongen_salt_and_hash
We use Argon because it's 3x faster than scrypt.
rsky-pds/src/account_manager/helpers/password.rs:64
↓ 2 callersMethodget
(&self, cid: Cid)
rsky-repo/src/block_map.rs:48
↓ 2 callersFunctionget_account
( _handle_or_did: &str, flags: Option<AvailabilityFlags>, db: &DbConn, )
rsky-pds/src/account_manager/helpers/account.rs:103
↓ 2 callersMethodget_account_status
(&self, handle_or_did: &str)
rsky-pds/src/account_manager/mod.rs:213
↓ 2 callersFunctionget_all_posts
( lang: Option<String>, limit: Option<i64>, params_cursor: Option<&str>, only_posts: bool,
rsky-feedgen/src/apis/mod.rs:358
↓ 2 callersFunctionget_backlinks
@NOTE in the future this can be replaced with a more generic routine that pulls backlinks based on lex docs. For now, we just want to ensure we're tra
rsky-pds/src/actor_store/record/mod.rs:41
↓ 2 callersFunctionget_bunny_video_id
Get bunny video ID from did/cid mapping
rsky-video/src/db/mod.rs:413
↓ 2 callersFunctionget_count
Get the count from the database.
rsky-relay/crawler.py:167
↓ 2 callersFunctionget_did
based on did-doc.ts
rsky-common/src/lib.rs:74
↓ 2 callersMethodget_did_for_actor
( &self, handle_or_did: &str, flags: Option<AvailabilityFlags>, )
rsky-pds/src/account_manager/mod.rs:121
↓ 2 callersMethodget_last_op
(&self, did: &String)
rsky-pds/src/plc/mod.rs:74
↓ 2 callersFunctionget_local_lag
(local: &LocalRecords)
rsky-pds/src/read_after_write/util.rs:83
↓ 2 callersMethodget_object
(&self, cid: Cid)
rsky-pds/src/actor_store/aws/s3.rs:113
↓ 2 callersFunctionget_or_create_quota
Get or create upload quota for a user
rsky-video/src/db/mod.rs:322
↓ 2 callersMethodget_post
(&self, descript: RecordDescript<Post>)
rsky-pds/src/read_after_write/viewer.rs:264
↓ 2 callersMethodget_quarantined_path
(&self, cid: Cid)
rsky-pds/src/actor_store/aws/s3.rs:51
↓ 2 callersFunctionget_random_token
Formatted xxxxx-xxxxx
rsky-pds/src/apis/com/atproto/server/mod.rs:29
↓ 2 callersFunctionget_records_since_rev
(actor_store: &ActorStore, rev: String)
rsky-pds/src/read_after_write/viewer.rs:634
↓ 2 callersFunctionget_repo_rev
(headers: &BTreeMap<String, String>)
rsky-pds/src/read_after_write/util.rs:79
↓ 2 callersMethodhandle_connect
(&mut self, start: Instant, hostname: String, result: HandshakeResult)
rsky-relay/src/crawler/worker.rs:105
↓ 2 callersMethodhandle_connect
(&mut self, mut request_crawl: RequestCrawl)
rsky-relay/src/crawler/manager.rs:178
↓ 2 callersMethodhandle_job_results
(&self, tasks: Vec<tokio::task::JoinHandle<JobTaskResult>>)
rsky-wintermute/src/indexer/mod.rs:833
↓ 2 callersMethodhandle_single_job_result
(&self, result: JobTaskJoinResult)
rsky-wintermute/src/indexer/mod.rs:785
↓ 2 callersMethodhandle_single_label_result
(&self, result: Result<LabelTaskResult, tokio::task::JoinError>)
rsky-wintermute/src/indexer/mod.rs:693
↓ 2 callersMethodhas_key
(&self, key: String)
rsky-pds/src/actor_store/aws/s3.rs:159
↓ 2 callersFunctionhash_app_password
(did: &String, password: &String)
rsky-pds/src/account_manager/helpers/password.rs:92
↓ 2 callersMethodindex_record
( &self, uri: AtUri, cid: Cid, record: Option<RepoRecord>, action: Opt
rsky-pds/src/actor_store/record/mod.rs:353
↓ 2 callersMethodindex_writes
(&self, writes: Vec<PreparedWrite>, rev: &str)
rsky-pds/src/actor_store/mod.rs:375
↓ 2 callersFunctioninstall_listener
Bind an HTTP /metrics listener and install the recorder globally. Returns the handle. MUST be called from within a tokio runtime — the exporter task i
rsky-relay/src/metrics.rs:92
↓ 2 callersMethodinto_stream
(self)
rsky-repo/src/mst/mod.rs:53
↓ 2 callersFunctionipld_to_json_cli_style
(ipld: &Ipld)
rsky-satnav/src/main.rs:119
↓ 2 callersFunctionis_in_container
Check if we're running in a container
rsky-pdsadmin/src/util/env.rs:84
↓ 2 callersFunctionis_valid_chars
(input: &str)
rsky-repo/src/mst/util.rs:18
↓ 2 callersMethodlabel_result
(&self, result: TimeCodeResult)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:59
↓ 2 callersMethodlabeled_result_to_cursor
(&self, labeled: Cursor)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:66
↓ 2 callersMethodleaf_add
(&mut self, key: &str, cid: Cid)
rsky-repo/src/data_diff.rs:97
↓ 2 callersFunctionless_than_ago_s
(time: DateTime<UtcOffset>, range: i32)
rsky-common/src/time.rs:12
↓ 2 callersFunctionload_car_into
---------------- CAR → Blockstore helper --------------------------------
rsky-repo/tests/interop.rs:59
↓ 2 callersFunctionload_from_path
Load environment variables from a specific path
rsky-pdsadmin/src/util/env.rs:46
↓ 2 callersFunctionmake_account
()
rsky-relay/src/validator/event.rs:425
↓ 2 callersFunctionmake_commit
()
rsky-relay/src/validator/event.rs:386
↓ 2 callersMethodmake_get_req
@TODO: Add better failure mode here
rsky-pds/src/plc/mod.rs:24
↓ 2 callersFunctionmake_identity
()
rsky-relay/src/validator/event.rs:416
↓ 2 callersFunctionmake_labels
()
rsky-relay/src/validator/event.rs:451
↓ 2 callersFunctionmake_sync
()
rsky-relay/src/validator/event.rs:406
↓ 2 callersFunctionnormalize_and_ensure_valid_handle
( handle: S, )
rsky-syntax/src/handle.rs:149
↓ 2 callersFunctionnormalize_datetime
Takes a flexible datetime string and normalizes representation. * * This function will work with any valid atproto datetime (eg, anything which is_v
rsky-syntax/src/datetime.rs:88
↓ 2 callersMethodpack
(&self, labeled: Option<Cursor>)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:93
↓ 2 callersMethodpack_cursor
(&self, cursor: Option<Cursor>)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:110
↓ 2 callersMethodparse_dns_result
(&self, results: Vec<String>)
rsky-identity/src/handle/mod.rs:119
↓ 2 callersFunctionparse_multikey
(multikey: String)
rsky-crypto/src/did.rs:12
↓ 2 callersFunctionparse_obj_by_kind
( bytes: Vec<u8>, cid: Cid, check: impl FnOnce(CborValue) -> bool, )
rsky-repo/src/parse.rs:45
↓ 2 callersFunctionparse_repo_to_jobs
Read a repo's CAR, walk its MST, and build index jobs for allowed collections.
rsky-wintermute/src/bin/car_loader.rs:163
↓ 2 callersMethodpeek
(&mut self, buf: &mut [u8])
rsky-relay/src/publisher/types.rs:44
↓ 2 callersFunctionprefixes
(list: &[&str])
rsky-wintermute/src/config.rs:222
↓ 2 callersMethodprove_mutation
helper to mark nodes as "dirty" if they are needed to "prove" something about the key. used to generate invertable operation diffs.
rsky-relay/src/validator/types.rs:590
↓ 2 callersMethodput_block
( &'a self, _cid: Cid, _bytes: Vec<u8>, _rev: String, )
rsky-repo/src/storage/sync_storage.rs:79
↓ 2 callersFunctionread
(data: &[u8])
rsky-firehose/src/firehose.rs:33
↓ 2 callersFunctionread_chunk
(reader: &mut T)
rsky-firehose/src/car.rs:41
↓ 2 callersFunctionread_chunk
(reader: &mut T)
rsky-labeler/src/car.rs:41
↓ 2 callersMethodread_record
( &'a self, cid: &'a Cid, )
rsky-repo/src/storage/readable_blockstore.rs:69
↓ 2 callersFunctionread_stream_car
(bytes: R)
rsky-repo/src/car.rs:164
↓ 2 callersFunctionrecord_collection_allowed
(collection: &str)
rsky-wintermute/src/config.rs:208
↓ 2 callersFunctionrecord_frame_dropped
(reason: DropReason)
rsky-relay/src/metrics.rs:111
↓ 2 callersFunctionrecord_subscriber_lag_seconds
(addr: &str, seconds: f64)
rsky-relay/src/metrics.rs:122
↓ 2 callersMethodreport
(&self)
rsky-wintermute/src/bin/fix_blob_refs.rs:128
↓ 2 callersMethodrequest
(&mut self, did: &str)
rsky-relay/src/validator/resolver.rs:161
↓ 2 callersMethodrequest_inner
(&mut self, did: &str, force_direct: bool)
rsky-relay/src/validator/resolver.rs:171
↓ 2 callersMethodresolve_no_cache
(&self, did: &String)
rsky-identity/src/did/did_resolver.rs:82
↓ 2 callersMethodrun
(mut self)
rsky-relay/src/publisher/worker.rs:53
↓ 2 callersFunctions32decode
(s: String)
rsky-common/src/tid.rs:19
↓ 2 callersFunctionsave_checkpoint
Save checkpoint state.
scripts/priority_backfill_followers.py:58
↓ 2 callersMethodsave_mst
(&self)
rsky-repo/src/mst/mod.rs:1468
↓ 2 callersMethodscan_did
(&mut self, cursor: &mut Cursor, did: &str)
rsky-relay/src/validator/manager.rs:380
↓ 2 callersFunctionselect_account_qb
(flags: Option<AvailabilityFlags>)
rsky-pds/src/account_manager/helpers/account.rs:80
↓ 2 callersMethodsend
(&mut self, seq: Cursor, data: &Bytes)
rsky-relay/src/publisher/worker.rs:145
↓ 2 callersMethodseq
(&self)
rsky-relay/src/validator/event.rs:328
↓ 2 callersMethodsequence_sync_evt
(&mut self, did: String, data: SyncEvtData)
rsky-pds/src/sequencer/mod.rs:251
↓ 2 callersMethodset_account_invites_disabled
(&self, did: &str, disabled: bool)
rsky-pds/src/account_manager/mod.rs:374
↓ 2 callersMethodset_collection
(&mut self, v: String)
rsky-syntax/src/aturi.rs:151
↓ 2 callersFunctionset_collection_name
( collection: &String, mut record: RepoRecord, validate: bool, )
rsky-pds/src/repo/prepare.rs:147
↓ 2 callersMethodshutdown
(self)
rsky-relay/src/publisher/worker.rs:65
← previousnext →401–500 of 2,046, ranked by callers