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
Methodall_cids
(self)
rsky-repo/src/mst/mod.rs:1324
Functionall_options
()
rsky-feedgen/src/main.rs:68
Functionall_options
()
rsky-pds/src/lib.rs:169
Functionappend_cursor_param_emits_zero_explicitly
()
rsky-wintermute/src/ingester/mod.rs:1200
Functionappend_cursor_param_omits_when_none
()
rsky-wintermute/src/ingester/mod.rs:1207
Functionappend_cursor_param_sets_positive_seq
()
rsky-wintermute/src/ingester/mod.rs:1214
Functionapplies_first_event_when_column_is_null
()
rsky-wintermute/src/ingester/tests.rs:1021
Methodapply_commit
( &'a self, commit: CommitData, _is_create: Option<bool>, )
rsky-repo/src/storage/memory_blockstore.rs:123
Methodapply_commit
( &'a self, _commit: CommitData, _is_create: Option<bool>, )
rsky-repo/src/storage/sync_storage.rs:105
Functionapply_decision_active_marks_recovered
()
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:272
Functionapply_decision_inactive_with_status
()
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:281
Functionapply_decision_missing_active_defaults_inactive
()
rsky-wintermute/src/bin/cleanup_stale_deactivated.rs:291
Functionapply_writes
( body: Json<ApplyWritesInput>, auth: AccessStandardIncludeChecks, sequencer: &State<SharedSequenc
rsky-pds/src/apis/com/atproto/repo/apply_writes.rs:130
Functionas_ref_returns_be_bytes
()
rsky-relay/src/types.rs:237
Methodasync_eq
(&self, other: &Self)
rsky-repo/src/mst/mod.rs:353
Methodauthority
(&self)
rsky-syntax/src/nsid.rs:138
Methodbackfill_worker_loop
( worker_id: usize, storage: Arc<Storage>, pool: Pool, batch_size: usize,
rsky-wintermute/src/indexer/mod.rs:504
Functionbad_request
()
rsky-feedgen/src/main.rs:40
Functionban_user
( body: Json<crate::models::BannedFromTvRequest>, _key: ApiKey<'_>, )
rsky-feedgen/src/routes.rs:559
Functionbanned_host_and_list_bans_round_trip
()
rsky-relay/src/server/types.rs:108
Methodbatch_ensure_actors
( client: &deadpool_postgres::Client, dids: &[&str], )
rsky-wintermute/src/indexer/mod.rs:1783
Methodbatch_insert_blocks
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2205
Methodbatch_insert_follows
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2064
Methodbatch_insert_likes
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2004
Methodbatch_insert_posts
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:1925
Methodbatch_insert_profiles
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2254
Methodbatch_insert_record_table
( client: &deadpool_postgres::Client, jobs: &[ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:1807
Methodbatch_insert_records
Batch insert records using `PostgreSQL` `COPY` protocol for high throughput. Uses parallel COPY operations for different collection types to maximize
rsky-wintermute/src/indexer/mod.rs:1497
Methodbatch_insert_reposts
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2114
Methodblob_count
(&self)
rsky-pds/src/actor_store/blob/mod.rs:403
Functionbsky_api_get_forwarder
( nsid: Nsid, query: Option<&str>, auth: AccessStandard, req: ProxyRequest<'_>, )
rsky-pds/src/apis/mod.rs:35
Functionbsky_api_post_forwarder
( body: Data<'_>, _nsid: Nsid, auth: AccessStandard, req: ProxyRequest<'_>, )
rsky-pds/src/apis/mod.rs:66
Functionbunny_webhook
POST /webhook/bunny - Handle Bunny Stream webhook callbacks
rsky-video/src/xrpc/mod.rs:339
Methodbyte_size
(&self)
rsky-repo/src/block_map.rs:112
Methodcalls
(&self)
rsky-relay/src/server/server.rs:678
Functioncan_determine_record_proofs_from_car_file
()
rsky-repo/src/repo.rs:1111
Functioncapacity_message_too_long_is_not_backpressure
()
rsky-relay/src/publisher/connection.rs:188
Functioncheck_account_status
( auth: AccessFull, s3_config: &State<SdkConfig>, db: DbConn, account_manager: AccountManager,
rsky-pds/src/apis/com/atproto/server/check_account_status.rs:62
Methodclear
(&mut self)
rsky-identity/src/types.rs:147
Methodclear
(&mut self)
rsky-repo/src/block_map.rs:74
Methodclock_id
(&self)
rsky-common/src/tid.rs:52
Functionclose_emits_close_frame_to_client
()
rsky-relay/src/publisher/connection.rs:243
Functionclose_frames_have_expected_codes
()
rsky-relay/src/publisher/connection.rs:201
Functioncommand_debug_renders_variants
()
rsky-relay/src/crawler/types.rs:75
Methodcommit
(&self)
rsky-relay/src/validator/event.rs:360
Functioncommit_op_is_valid
()
rsky-relay/src/validator/event.rs:639
Functioncommit_op_path_and_eq
()
rsky-relay/src/validator/event.rs:623
Functioncommit_round_trip
()
rsky-relay/src/validator/event.rs:456
Functioncompress_pubkey
(pubkey_bytes: Vec<u8>)
rsky-crypto/src/p256/encoding.rs:4
Functioncompress_pubkey
(pubkey_bytes: Vec<u8>)
rsky-crypto/src/secp256k1/encoding.rs:4
Functionconfirm_email
( body: Json<ConfirmEmailInput>, auth: AccessStandardIncludeChecks, account_manager: AccountManage
rsky-pds/src/apis/com/atproto/server/confirm_email.rs:66
Methodconnect
( addr: SocketAddr, stream: MaybeTlsStream<TcpStream>, cursor: Cursor, )
rsky-relay/src/publisher/connection.rs:51
Methodconnect_and_stream
( _storage: &Storage, hostname: &str, pool: &Arc<Pool>, semaphore: &Arc<Semaph
rsky-wintermute/src/ingester/mod.rs:217
Functionconnect_succeeds_and_returns_raw_fd
()
rsky-relay/src/publisher/connection.rs:207
Functionconnection_closed_is_not_backpressure
()
rsky-relay/src/publisher/connection.rs:182
Methodconstruct_selection
()
rsky-feedgen/src/models/post.rs:124
Methodcopy_batch_insert_blocks
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2842
Methodcopy_batch_insert_follows
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], compute_agg: bool,
rsky-wintermute/src/indexer/mod.rs:2736
Methodcopy_batch_insert_likes
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2689
Methodcopy_batch_insert_posts
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], compute_agg: bool,
rsky-wintermute/src/indexer/mod.rs:2453
Methodcopy_batch_insert_reposts
( client: &deadpool_postgres::Client, jobs: &[&ParsedJob<'_>], )
rsky-wintermute/src/indexer/mod.rs:2775
Functioncopy_clone_semantics
()
rsky-relay/src/types.rs:250
Methodcreate
( storage: Arc<RwLock<dyn RepoStorage>>, entries: Option<Vec<NodeEntry>>, layer: Optio
rsky-repo/src/mst/mod.rs:532
Methodcreate
(authority: &str, name: &str)
rsky-syntax/src/nsid.rs:130
Functioncreate_app_password
( body: Json<CreateAppPasswordInput>, auth: AccessFull, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/create_app_password.rs:13
Methodcreate_from_commit
static
rsky-repo/src/repo.rs:194
Functioncreate_invite_code
( body: Json<CreateInviteCodeInput>, _auth: AdminToken, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/create_invite_code.rs:16
Functioncreate_invite_codes
( body: Json<CreateInviteCodesInput>, _auth: AdminToken, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/create_invite_codes.rs:15
Functioncreate_mock_compose_file
Helper function to create a mock compose.yaml file
rsky-pdsadmin/src/commands/update/tests/mod.rs:10
Methodcreate_pds_upload_token
Create a service auth token for uploading a blob to a PDS # Arguments `pds_did` - The DID of the target PDS `user_did` - The DID of the user on whose
rsky-video/src/signing/mod.rs:79
Functioncreate_record
( body: Json<CreateRecordInput>, auth: AccessStandardIncludeChecks, sequencer: &State<SharedSequen
rsky-pds/src/apis/com/atproto/repo/create_record.rs:120
Methodcreate_repo_legacy
( &self, keypair: &Keypair, writes: Vec<PreparedCreateOrUpdate>, )
rsky-pds/src/actor_store/mod.rs:90
Functioncreate_session
( body: Json<CreateSessionInput>, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/create_session.rs:108
Functioncreates_repo
()
rsky-repo/src/repo.rs:561
Methodcreator
(params: LocalViewerCreatorParams)
rsky-pds/src/read_after_write/viewer.rs:93
Methodcreator
(cfg: &SdkConfig)
rsky-pds/src/actor_store/aws/s3.rs:35
Methodcreator
()
rsky-pds/src/account_manager/mod.rs:82
Functioncursor_get_round_trips_u64
()
rsky-relay/src/types.rs:167
Functiondb_lazylock_initializes_against_env_path
()
rsky-relay/src/types.rs:314
Functiondb_path_defaults_to_db_when_unset
()
rsky-relay/src/types.rs:271
Functiondb_path_reads_env_var_when_set
()
rsky-relay/src/types.rs:286
Functiondeactivate_account
( body: Json<DeactivateAccountInput>, auth: AccessFull, account_manager: AccountManager, )
rsky-pds/src/apis/com/atproto/server/deactivate_account.rs:14
Functiondeactivated_with_status
()
rsky-wintermute/src/ingester/tests.rs:1168
Functiondebug_and_display_match_u64
()
rsky-relay/src/types.rs:216
Functiondebug_renders_plain_variant
()
rsky-relay/src/publisher/types.rs:188
Methoddecode_token_claims
Decode a JWT token without verification to extract claims The PDS will verify the token when we use it for upload
rsky-video/src/pds/mod.rs:60
Functiondecompose_handshake_failure_propagates_error
()
rsky-relay/src/crawler/types.rs:92
Functiondecompress_pubkey
(compressed: Vec<u8>)
rsky-crypto/src/p256/encoding.rs:9
Functiondecompress_pubkey
(compressed: Vec<u8>)
rsky-crypto/src/secp256k1/encoding.rs:9
Methoddefault
()
rsky-feedgen/src/models/error_code.rs:173
Methoddefault
()
rsky-feedgen/src/models/not_found_error_code.rs:22
Methoddefault
()
rsky-feedgen/src/models/internal_error_code.rs:46
Methoddefault
()
rsky-repo/src/block_map.rs:23
Methoddefault
()
rsky-repo/src/data_diff.rs:42
Methoddefault
()
rsky-repo/src/storage/memory_blockstore.rs:21
Methoddefault
()
rsky-common/src/tid.rs:139
Methoddefault
()
rsky-pds/src/apis/com/atproto/sync/list_repos.rs:48
Methoddefault
()
rsky-pds/src/apis/com/atproto/admin/get_invite_codes.rs:49
Methoddefault
()
rsky-lexicon/src/app/bsky/embed/record.rs:64
Functiondefault_catcher
()
rsky-feedgen/src/main.rs:58
← previousnext →1,101–1,200 of 2,046, ranked by callers