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
↓ 877 callersMethodto_string
(&self)
rsky-feedgen/src/models/error_code.rs:102
↓ 316 callersMethodeq
(&self, other: &Self)
rsky-repo/src/mst/mod.rs:275
↓ 302 callersMethodget
(&self, key: &str)
rsky-wintermute/src/ingester/backfill_queue.rs:29
↓ 279 callersMethodpush
(&self, item: T)
rsky-common/src/async.rs:38
↓ 271 callersMethodas_str
(&self)
rsky-repo/src/types.rs:618
↓ 175 callersMethodget
(self)
rsky-relay/src/types.rs:75
↓ 150 callersMethoditer
(self)
rsky-repo/src/mst/mod.rs:315
↓ 146 callersMethodinto_iter
(self)
rsky-repo/src/block_map.rs:156
↓ 145 callersFunctionnow
()
rsky-common/src/lib.rs:32
↓ 127 callersMethodinsert
Adds a key/CID entry to a sub-tree defined by a Node. If a previous value existed, returns it. If the insert is a no-op (the key already existed with
rsky-relay/src/validator/types.rs:290
↓ 98 callersMethodrun
(&self, f: F)
rsky-feedgen/src/lib.rs:59
↓ 95 callersMethodas_ref
(&self)
rsky-relay/src/types.rs:111
↓ 77 callersMethodsend
`Ok(true)` = delivered, cursor advanced. `Ok(false)` = backpressured / cursor mismatch, no advance.
rsky-relay/src/publisher/connection.rs:73
↓ 70 callersMethodread
(&mut self, buf: &mut [u8])
rsky-relay/src/publisher/types.rs:92
↓ 69 callersFunctionexpect_invalid
(rkey: &str)
rsky-syntax/src/record_key.rs:70
↓ 68 callersFunctionexpect_valid
(rkey: &str)
rsky-syntax/src/record_key.rs:61
↓ 63 callersFunctionexpect_valid
(uri: &str)
rsky-syntax/src/aturi_validation.rs:191
↓ 62 callersMethodadd
(&mut self, key: &str, value: Cid, known_zeros: Option<u32>)
rsky-repo/src/mst/mod.rs:735
↓ 60 callersFunctionexpect_invalid
(uri: &str)
rsky-syntax/src/aturi_validation.rs:201
↓ 58 callersFunctionescape_copy_field
Escape a field for COPY text format; borrows when no escaping is needed. NUL is stripped (Postgres text columns reject 0x00), the rest are escaped.
rsky-wintermute/src/indexer/bulk.rs:17
↓ 58 callersMethodload
static
rsky-repo/src/repo.rs:51
↓ 54 callersMethodsplit
(mut self, path: &str)
rsky-relay/src/validator/types.rs:410
↓ 52 callersMethodbuild
(s: String)
rsky-pds/src/models/models.rs:207
↓ 49 callersMethodwrite
(&mut self, buf: &[u8])
rsky-relay/src/publisher/types.rs:101
↓ 45 callersFunctionexpect_invalid
(tid: &str)
rsky-syntax/src/tid.rs:63
↓ 44 callersFunctionparse
(str: &str)
rsky-syntax/src/aturi.rs:198
↓ 44 callersMethodset
(&mut self, cid: Cid, bytes: Vec<u8>)
rsky-repo/src/block_map.rs:44
↓ 35 callersFunctionexpect_invalid
(dt: &str)
rsky-syntax/src/datetime.rs:182
↓ 33 callersFunctionenv_str
(name: &str)
rsky-common/src/env.rs:13
↓ 32 callersMethodas_str
(&self)
rsky-pds/src/models/models.rs:178
↓ 31 callersMethodget_account
( &self, handle_or_did: &str, flags: Option<AvailabilityFlags>, )
rsky-pds/src/account_manager/mod.rs:86
↓ 29 callersMethodremove
Removes key/value from the sub-tree provided, returning a new tree, and the previous CID value. If key is not found, returns unmodified subtree, and n
rsky-relay/src/validator/types.rs:455
↓ 26 callersFunctionencode_did_key
(pubkey: &PublicKey)
rsky-crypto/src/utils.rs:51
↓ 25 callersMethodparse
(nsid: S)
rsky-syntax/src/nsid.rs:122
↓ 25 callersMethodpath
(&self)
rsky-relay/src/validator/event.rs:109
↓ 24 callersFunctionexpect_invalid
(nsid: &str)
rsky-syntax/src/nsid.rs:191
↓ 24 callersFunctionexpect_valid
(did: &str)
rsky-syntax/src/did.rs:87
↓ 23 callersMethodadd
(&mut self, cid: Cid)
rsky-repo/src/cid_set.rs:21
↓ 23 callersFunctionensure_valid_handle
Handle constraints, in English: - must be a possible domain name - RFC-1035 is commonly referenced, but has been updated. eg, RFC-3696, section 2. and
rsky-syntax/src/handle.rs:73
↓ 23 callersMethodget_pointer
(&self)
rsky-repo/src/mst/mod.rs:625
↓ 22 callersFunctionexpect_valid
(nsid: &str)
rsky-syntax/src/nsid.rs:186
↓ 22 callersMethodnext
(&mut self, prev: Option<TID>)
rsky-common/src/tid.rs:112
↓ 20 callersMethodappend
append entry to end of the node / Vec is allowed here.
rsky-repo/src/mst/mod.rs:952
↓ 20 callersMethodget_rkey
(&self)
rsky-syntax/src/aturi.rs:167
↓ 20 callersFunctionsetup_test_pool
()
rsky-wintermute/src/indexer/tests.rs:26
↓ 19 callersFunctioncleanup_test_labels
(pool: &Pool, src: &str)
rsky-wintermute/src/indexer/tests.rs:477
↓ 19 callersMethodcommit
(&self)
rsky-relay/src/validator/types.rs:99
↓ 19 callersFunctionenv_int
(name: &str)
rsky-common/src/env.rs:3
↓ 19 callersMethodget_entries
"We don't want to load entries of every subtree, just the ones we need"
rsky-repo/src/mst/mod.rs:580
↓ 19 callersMethodset_cursor
(&self, name: &str, value: i64)
rsky-wintermute/src/storage.rs:767
↓ 18 callersFunctionassert_handle_error
Helper function to check error messages
rsky-syntax/src/handle.rs:196
↓ 18 callersFunctionconvert_record_to_ipld
(record_json: &serde_json::Value)
rsky-wintermute/src/backfiller/mod.rs:395
↓ 18 callersMethodenqueue_backfill
Enqueue a backfill job with normal priority (prefix "1:") Normal priority items are processed after all priority items
rsky-wintermute/src/storage.rs:176
↓ 18 callersFunctionexpect_invalid
(did: &str)
rsky-syntax/src/did.rs:92
↓ 18 callersMethodget
(&mut self, key: &String)
rsky-repo/src/mst/mod.rs:835
↓ 18 callersMethodget_collection
(&self)
rsky-syntax/src/aturi.rs:144
↓ 17 callersMethodat_index
returns entry at index
rsky-repo/src/mst/mod.rs:966
↓ 17 callersFunctioncontains_explicit_slurs
(text: &str)
rsky-common/src/explicit_slurs.rs:5
↓ 16 callersFunctionexpect_valid
(dt: &str)
rsky-syntax/src/datetime.rs:173
↓ 16 callersMethodnext
(&mut self)
rsky-repo/src/mst/mod.rs:67
↓ 16 callersFunctionsetup_test_storage
()
rsky-wintermute/src/storage.rs:872
↓ 15 callersMethodget_hostname
(&self)
rsky-syntax/src/aturi.rs:117
↓ 14 callersMethodadd_map
(&mut self, to_add: BlockMap)
rsky-repo/src/block_map.rs:101
↓ 14 callersFunctiondescribe
Register all relay metrics with descriptions. Idempotent.
rsky-relay/src/metrics.rs:52
↓ 14 callersMethodset
(&self, key: &str, cursor: i64)
rsky-wintermute/src/ingester/backfill_queue.rs:36
↓ 14 callersFunctionsetup_test_storage
()
rsky-wintermute/src/backfiller/tests.rs:11
↓ 13 callersFunctionfill_repo
( mut repo: Repo, keypair: Keypair, items_per_collection: usize, )
rsky-repo/src/repo.rs:383
↓ 13 callersMethodresolve
(&mut self, handle: &String)
rsky-identity/src/handle/mod.rs:28
↓ 13 callersMethodto_list
(&self)
rsky-repo/src/cid_set.rs:53
↓ 13 callersMethoduri
(&self)
rsky-repo/src/types.rs:131
↓ 13 callersFunctionwrite_response
(stream: &mut ErrorOnDropTcpStream, status: &str, body: &str)
rsky-relay/src/server/server.rs:153
↓ 12 callersMethodas_str
(&self)
rsky-pds/src/auth_verifier.rs:44
↓ 12 callersFunctionbuild_worker
()
rsky-relay/src/publisher/worker.rs:206
↓ 12 callersFunctioncleanup_test_data
(pool: &Pool, did: &str)
rsky-wintermute/src/indexer/tests.rs:40
↓ 12 callersMethodclose
(&self)
rsky-common/src/async.rs:66
↓ 12 callersMethodrepo_backfill_len
(&self)
rsky-wintermute/src/storage.rs:777
↓ 12 callersFunctionsetup_test_storage
()
rsky-wintermute/src/ingester/tests.rs:9
↓ 12 callersMethodslice
returns a slice of the node
rsky-repo/src/mst/mod.rs:976
↓ 12 callersFunctionstruct_to_cbor
(obj: &T)
rsky-common/src/lib.rs:57
↓ 11 callersFunctionconnect
Connect to the given WebSocket in blocking mode. The URL may be either ws:// or wss://. To support wss:// URLs, feature `native-tls` or `rustls-tls`
rsky-relay/src/crawler/client.rs:30
↓ 11 callersFunctioncreate_at_uri
Helper function that constructs AtUri using the new() method and returns a Result
rsky-syntax/src/aturi.rs:326
↓ 11 callersMethodcreate_pool
(database_url: &str, size: usize)
rsky-wintermute/src/indexer/mod.rs:129
↓ 11 callersFunctionsetup_test_storage
()
rsky-wintermute/src/indexer/tests.rs:19
↓ 11 callersFunctionsetup_test_storage
()
rsky-wintermute/tests/backfiller_integration.rs:12
↓ 11 callersFunctionws_pair
()
rsky-relay/src/publisher/connection.rs:138
↓ 10 callersMethodapply_commit
(&self, commit_data: CommitData)
rsky-repo/src/repo.rs:302
↓ 10 callersFunctioncid_for_cbor
(data: &T)
rsky-common/src/ipld.rs:12
↓ 10 callersFunctionenv_bool
(name: &str)
rsky-common/src/env.rs:20
↓ 10 callersMethodfor_each
Not really using. Issues with closures
rsky-repo/src/block_map.rs:79
↓ 10 callersMethodname
(&self)
rsky-syntax/src/nsid.rs:147
↓ 10 callersMethodnew_tree
We never mutate an MST, we just return a new MST with updated values
rsky-repo/src/mst/mod.rs:566
↓ 9 callersMethodclose
(&mut self, code: CloseFrame)
rsky-relay/src/publisher/connection.rs:66
↓ 9 callersMethodcreate
static
rsky-repo/src/repo.rs:206
↓ 9 callersMethoddelete
Deletes the value at the given key
rsky-repo/src/mst/mod.rs:881
↓ 9 callersMethoddequeue_backfill
(&self)
rsky-wintermute/src/storage.rs:227
↓ 9 callersMethodenqueue_firehose_backfill
Enqueue a firehose backfill job with normal priority (random prefix 10-ff) The random prefix enables partitioned dequeue where each worker owns a key
rsky-wintermute/src/storage.rs:319
↓ 9 callersFunctionenv_list
(name: &str)
rsky-common/src/env.rs:28
↓ 9 callersMethodfind_gt_or_equal_leaf_index
finds index of first leaf node that is greater than or equal to the value
rsky-repo/src/mst/mod.rs:1193
↓ 9 callersFunctionformat_data_key
(collection: T, rkey: T)
rsky-repo/src/util.rs:46
↓ 9 callersFunctionget_and_parse_record
(blocks: &BlockMap, cid: Cid)
rsky-repo/src/parse.rs:15
next →1–100 of 2,046, ranked by callers