Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/blacksky-algorithms/rsky
/ functions
Functions
2,046 in github.com/blacksky-algorithms/rsky
⨍
Functions
2,046
◇
Types & classes
3,275
↓ 2 callers
Function
sign_without_indexmap
(obj: &T, key: &SecretKey)
rsky-common/src/sign.rs:28
↓ 2 callers
Method
size
(&self)
rsky-repo/src/block_map.rs:108
↓ 2 callers
Method
split_around
(&mut self, key: &str)
rsky-repo/src/mst/mod.rs:1092
↓ 2 callers
Method
start
(&mut self)
rsky-pds/src/sequencer/mod.rs:49
↓ 2 callers
Function
store_refresh_token
( payload: RefreshToken, app_password_name: Option<String>, db: &DbConn, )
rsky-pds/src/account_manager/helpers/auth.rs:205
↓ 2 callers
Function
stream_to_buffer
Collects a stream of byte chunks into a single buffer
rsky-repo/src/util.rs:212
↓ 2 callers
Function
thread_post_view
( local_viewer: &LocalViewer, descript: RecordDescript<Post>, )
rsky-pds/src/apis/app/bsky/feed/get_post_thread.rs:333
↓ 2 callers
Function
tid
()
rsky-relay/src/validator/event.rs:382
↓ 2 callers
Method
unpack_cursor
(&self, cursor_str: Option<String>)
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:117
↓ 2 callers
Method
update
(&mut self)
rsky-relay/src/server/server.rs:251
↓ 2 callers
Method
update_account_password
(&self, opts: UpdateAccountPasswordOpts)
rsky-pds/src/account_manager/mod.rs:427
↓ 2 callers
Function
update_cursor
( url: String, service: String, sequence: &i64, client: &reqwest::Client, )
rsky-firehose/src/main.rs:72
↓ 2 callers
Method
update_email
(&self, opts: UpdateEmailOpts)
rsky-pds/src/account_manager/mod.rs:474
↓ 2 callers
Function
update_job_state
Update job state
rsky-video/src/db/mod.rs:268
↓ 2 callers
Method
update_profile_detailed
( &self, view: ProfileViewDetailed, record: Profile, )
rsky-pds/src/read_after_write/viewer.rs:546
↓ 2 callers
Method
update_queue_metrics
(&self)
rsky-wintermute/src/indexer/mod.rs:710
↓ 2 callers
Function
update_root
(did: String, cid: Cid, rev: String, db: &DbConn)
rsky-pds/src/account_manager/helpers/repo.rs:7
↓ 2 callers
Method
user_did
Get the user DID - uses sub if present, otherwise iss
rsky-video/src/auth/mod.rs:34
↓ 2 callers
Method
verify_account_password
(&self, did: &str, password_str: &String)
rsky-pds/src/account_manager/mod.rs:397
↓ 2 callers
Function
verify_commit_event
(commit: &SubscribeReposCommit, root: Cid, prev: &RepoState)
rsky-relay/src/validator/utils.rs:77
↓ 2 callers
Function
verify_commit_sig
( labels: &[SubscribeLabel], key: &[u8; 35], )
rsky-relay/src/validator/utils.rs:27
↓ 2 callers
Function
verify_diff
( mut repo: Option<Repo>, update_blocks: &mut BlockMap, update_root: Cid, did: Option<&String>
rsky-repo/src/sync/consumer.rs:54
↓ 2 callers
Function
verify_service_jwt
( request: &Request<'_>, id_resolver: &State<SharedIdResolver>, opts: ServiceJwtOpts, )
rsky-pds/src/auth_verifier.rs:885
↓ 2 callers
Function
verify_signature
( did_key: &String, data: &[u8], sig: &[u8], opts: Option<VerifyOptions>, )
rsky-crypto/src/verify.rs:6
↓ 2 callers
Function
wait
(ms: u64)
rsky-common/src/lib.rs:38
↓ 2 callers
Function
write_batch
Write one accumulated cross-repo batch to Postgres and mark its repos done.
rsky-wintermute/src/bin/car_loader.rs:404
↓ 2 callers
Function
write_car_stream
( root: Option<&Cid>, user_fn: F, )
rsky-repo/src/car.rs:25
↓ 1 callers
Function
accepted_mime
(mime: String, accepted: Vec<String>)
rsky-pds/src/actor_store/blob/mod.rs:598
↓ 1 callers
Method
action
(&self)
rsky-repo/src/types.rs:155
↓ 1 callers
Function
activate_account
(did: &str, db: &DbConn)
rsky-pds/src/account_manager/helpers/account.rs:341
↓ 1 callers
Method
add_backlinks
(&self, backlinks: Vec<Backlink>)
rsky-pds/src/actor_store/record/mod.rs:457
↓ 1 callers
Function
add_bad_commit
(mut repo: Repo, keypair: Keypair)
rsky-repo/src/repo.rs:413
↓ 1 callers
Method
add_blocks_for_path
(&mut self, key: String, blocks: &mut BlockMap)
rsky-repo/src/mst/mod.rs:1452
↓ 1 callers
Method
add_list
(&self)
rsky-repo/src/data_diff.rs:162
↓ 1 callers
Method
append_merge
(&mut self, mut to_merge: Self)
rsky-repo/src/mst/mod.rs:1140
↓ 1 callers
Function
apply_decision
(pool: &Pool, did: &str, status: &RepoStatus, dry_run: bool)
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:203
↓ 1 callers
Method
appview_auth_headers
(&self, did: &str, lxm: &str)
rsky-pds/src/config/mod.rs:168
↓ 1 callers
Function
assert_valid_doc_contents
(contents: AssertionContents)
rsky-pds/src/apis/com/atproto/server/mod.rs:115
↓ 1 callers
Method
assert_valid_email_token_and_cleanup
( &self, did: &str, purpose: EmailTokenPurpose, token: &str, )
rsky-pds/src/account_manager/mod.rs:494
↓ 1 callers
Function
assert_valid_token_and_find_did
( purpose: EmailTokenPurpose, token: &str, expiration_len: Option<i32>, db: &DbConn, )
rsky-pds/src/account_manager/helpers/email_token.rs:75
↓ 1 callers
Function
atp_uri_regex
(input: &str)
rsky-syntax/src/aturi.rs:7
↓ 1 callers
Method
attempt_get_layer
(&mut self)
rsky-repo/src/mst/mod.rs:676
↓ 1 callers
Method
attempt_read
( &'a self, cid: &'a Cid, check: Box<dyn Fn(CborValue) -> bool + Send + Sync>, )
rsky-repo/src/storage/readable_blockstore.rs:28
↓ 1 callers
Method
attempt_read_record
( &'a self, cid: &'a Cid, )
rsky-repo/src/storage/readable_blockstore.rs:62
↓ 1 callers
Function
backfiller_timeout
()
rsky-wintermute/src/config.rs:139
↓ 1 callers
Method
ban_host
(&self, hostname: &str)
rsky-relay/src/server/server.rs:614
↓ 1 callers
Function
base_normalize_and_validate
(handle: &str)
rsky-pds/src/handle/mod.rs:82
↓ 1 callers
Function
beginning_of_time
()
rsky-common/src/lib.rs:42
↓ 1 callers
Function
blob_ref_to_json
Convert atrium BlobRef to JSON value for storage
rsky-video/src/pds/mod.rs:288
↓ 1 callers
Function
blocks_to_car_stream
Converts a BlockMap to a CAR stream
rsky-repo/src/car.rs:115
↓ 1 callers
Function
build_pg_pool
Build the Postgres connection pool.
rsky-wintermute/src/bin/car_loader.rs:152
↓ 1 callers
Function
build_trending_cache_key
Build a cache key from the parameters.
rsky-feedgen/src/apis/mod.rs:319
↓ 1 callers
Method
cache_rev
Proactively cache all blocks from a particular commit (to prevent multiple roundtrips)
rsky-pds/src/actor_store/repo/sql_repo.rs:425
↓ 1 callers
Function
calculate_codes_to_create
* WARNING: TRICKY SUBTLE MATH - DON'T MESS WITH THIS FUNCTION UNLESS YOU'RE VERY CONFIDENT * if the user wishes to create available codes & the serve
rsky-pds/src/apis/com/atproto/server/get_account_invite_codes.rs:29
↓ 1 callers
Function
car_to_blocks
( car: CarReader<R>, )
rsky-repo/src/car.rs:133
↓ 1 callers
Function
check_admin_auth
(headers: &[httparse::Header<'_>])
rsky-relay/src/server/server.rs:651
↓ 1 callers
Method
check_cache
(&self, did: String)
rsky-identity/src/types.rs:120
↓ 1 callers
Function
check_diesel_cli
Check if diesel CLI is installed
rsky-pdsadmin/src/util/env.rs:79
↓ 1 callers
Function
cid_for_entries
(entries: &[NodeEntry])
rsky-repo/src/mst/util.rs:53
↓ 1 callers
Method
cids
(&self)
rsky-repo/src/block_map.rs:97
↓ 1 callers
Method
cids_for_path
(&mut self, key: String)
rsky-repo/src/mst/mod.rs:1433
↓ 1 callers
Method
clear_entry
(&mut self, did: String)
rsky-identity/src/types.rs:142
↓ 1 callers
Function
clear_queue
(storage: &Storage, confirm: bool)
rsky-wintermute/src/bin/queue_backfill.rs:516
↓ 1 callers
Function
clear_status
(pool: &Pool, did: &str)
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:227
↓ 1 callers
Method
cmp
(&self, other: &Self)
rsky-relay/src/validator/event.rs:103
↓ 1 callers
Method
collection
(&self)
rsky-repo/src/types.rs:236
↓ 1 callers
Function
complete_job
Mark job as completed with blob ref
rsky-video/src/db/mod.rs:286
↓ 1 callers
Method
confirm_email
Email Tokens ----------
rsky-pds/src/account_manager/mod.rs:455
↓ 1 callers
Function
connect_pg
(database_url: &str)
palomar-sync/src/main.rs:84
↓ 1 callers
Function
connect_pg
(database_url: &str)
rsky-wintermute/src/bin/plc_import.rs:75
↓ 1 callers
Function
connect_to_some
(addrs: impl ToSocketAddrs, uri: &Uri)
rsky-relay/src/crawler/client.rs:94
↓ 1 callers
Function
connect_with_config
( request: Req, config: Option<WebSocketConfig>, max_redirects: u8, )
rsky-relay/src/crawler/client.rs:36
↓ 1 callers
Function
convert_ipld_cli_style
(ipld: &Ipld)
rsky-satnav/src/main.rs:89
↓ 1 callers
Function
copy_ensure_actors
Bulk insert actors using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:168
↓ 1 callers
Function
copy_insert_blocks
Bulk insert blocks using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:840
↓ 1 callers
Function
copy_insert_follows
Bulk insert follows using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:544
↓ 1 callers
Function
copy_insert_likes
Bulk insert likes using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:453
↓ 1 callers
Function
copy_insert_post_embed_images
Bulk insert `post_embed_image` records using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:929
↓ 1 callers
Function
copy_insert_post_embed_videos
Bulk insert `post_embed_video` records using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:1013
↓ 1 callers
Function
copy_insert_posts
Bulk insert posts using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:244
↓ 1 callers
Function
copy_insert_quotes
Bulk insert quotes using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:754
↓ 1 callers
Function
copy_insert_records
Bulk insert records using `COPY` protocol. Returns vector of booleans indicating which records were applied (not stale).
rsky-wintermute/src/indexer/bulk.rs:57
↓ 1 callers
Function
copy_insert_reposts
Bulk insert reposts using `COPY` protocol.
rsky-wintermute/src/indexer/bulk.rs:663
↓ 1 callers
Method
count_blocks
(&self)
rsky-pds/src/actor_store/repo/sql_repo.rs:405
↓ 1 callers
Function
count_lines
(path: &Path)
palomar-sync/src/main.rs:411
↓ 1 callers
Function
count_prefix_len
(a: String, b: String)
rsky-repo/src/mst/util.rs:58
↓ 1 callers
Function
create_access_token
(opts: CreateTokensOpts)
rsky-pds/src/account_manager/helpers/auth.rs:101
↓ 1 callers
Function
create_account
Creates a mock account for testing purposes */
rsky-pds/tests/common/mod.rs:76
↓ 1 callers
Function
create_account
Create a new account
rsky-pdsadmin/src/commands/account/mod.rs:213
↓ 1 callers
Method
create_account
(&self, opts: CreateAccountOpts)
rsky-pds/src/account_manager/mod.rs:132
↓ 1 callers
Function
create_account_invite_codes
( for_account: &str, codes: Vec<String>, expected_total: usize, disabled: bool, db: &DbCon
rsky-pds/src/account_manager/helpers/invite.rs:110
↓ 1 callers
Method
create_account_invite_codes
( &self, for_account: &str, codes: Vec<String>, expected_total: usize,
rsky-pds/src/account_manager/mod.rs:344
↓ 1 callers
Function
create_app_password
create an app password with format: 1234-abcd-5678-efgh
rsky-pds/src/account_manager/helpers/password.rs:100
↓ 1 callers
Method
create_app_password
( &self, did: String, name: String, )
rsky-pds/src/account_manager/mod.rs:385
↓ 1 callers
Method
create_child
(&mut self)
rsky-repo/src/mst/mod.rs:1172
↓ 1 callers
Function
create_database
Create SQLite database and table if they don't exist.
rsky-relay/crawler.py:14
↓ 1 callers
Function
create_email_token
( did: &str, purpose: EmailTokenPurpose, db: &DbConn, )
rsky-pds/src/account_manager/helpers/email_token.rs:10
↓ 1 callers
Function
create_email_token
( requester: &str, account_manager: &AccountManager, )
rsky-pds/src/apis/com/atproto/identity/request_plc_operation_signature.rs:53
↓ 1 callers
Function
create_invite_codes
( to_create: Vec<AccountCodes>, use_count: i32, db: &DbConn, )
rsky-pds/src/account_manager/helpers/invite.rs:75
↓ 1 callers
Function
create_job
Create a new video job
rsky-video/src/db/mod.rs:162
← previous
next →
501–600 of 2,046, ranked by callers