MCPcopy Create free account

hub / github.com/denoland/celld / functions

Functions2,867 in github.com/denoland/celld

⨍ Functions 2,867◇ Types & classes 485
↓ 5 callersFunctionextract_endpoint_host
Extracts the host from an endpoint URL, or returns it as-is. Ported from `extractEndpointHost` (replica_url.go:351-362).
crates/ltx/src/replica_url.rs:332
↓ 5 callersMethodfill
(value, start, end, encoding)
crates/celld/js/node_buffer.js:380
↓ 5 callersFunctionformatProperty
(ctx, value, recurseTimes, key, type, desc, original = value)
crates/celld/js/node_util.js:2787
↓ 5 callersMethodfrom
(value, encodingOrOffset, length)
crates/celld/js/node_buffer.js:176
↓ 5 callersFunctionhttp_streams
()
crates/celld/js.rs:364
↓ 5 callersFunctioninit
()
crates/celld/asyncrt.rs:50
↓ 5 callersMethodinvalidate_pos_cache
Clears the cached position so the next `pos()` recomputes from disk. Ported from `invalidatePosCache` (db.go:430-434).
crates/ltx/src/db.rs:492
↓ 5 callersFunctionisError
(e)
crates/celld/js/node_util.js:902
↓ 5 callersFunctionisReadable
(stream)
crates/celld/js/node_stream.js:747
↓ 5 callersFunctionisWritableNodeStream
(obj)
crates/celld/js/node_stream.js:625
↓ 5 callersFunctionl0_path
On-disk path of an L0 file in a fixture replica.
crates/ltx/tests/faults_inject.rs:171
↓ 5 callersFunctionloader_registry
()
crates/celld/js.rs:3148
↓ 5 callersFunctionltx_file_path
Returns the path to a single LTX file for a given transaction range. The filename follows the convention `<minTXID>-<maxTXID>.ltx` with both TXIDs fo
crates/ltx/src/lib.rs:530
↓ 5 callersMethodmessage
(&self, websocket: u64, data: celld::js::WsIn)
crates/celld/main.rs:3097
↓ 5 callersMethodoccupied
(&self)
crates/logic/lib.rs:1191
↓ 5 callersMethodparse
Decodes a header from a 100-byte slice (ltx.go:302-326). All big-endian.
crates/ltx/src/ltx.rs:153
↓ 5 callersFunctionregister_http_stream
(stream_id: u64, source: HttpStreamSource)
crates/celld/js.rs:367
↓ 5 callersFunctionremoveAgnostic
(emitter, name, listener, flags)
crates/celld/js/node_events.js:396
↓ 5 callersFunctionsave_config
(path: &Path, config: &CloudConfig)
crates/celld/control_plane.rs:2562
↓ 5 callersFunctionserialize_storage_value
( scope: &mut v8::PinScope, value: v8::Local<v8::Value>, )
crates/celld/js.rs:5938
↓ 5 callersMethodsign
( &self, request: reqwest::RequestBuilder, method: &str, path_and_query: &str,
crates/celld/peer_auth.rs:112
↓ 5 callersFunctionskip_if_tools_missing
Returns `true` and logs a skip note if either required tool is missing or the wrong era. The differential gate is meaningless without BOTH the real bi
crates/ltx/tests/differential_xtool.rs:121
↓ 5 callersMethodtoString
()
crates/celld/js/node_util.js:4040
↓ 5 callersFunctionvalidateFunction
(value, name)
crates/celld/js/node_util.js:515
↓ 5 callersFunctionvalidateInt32
(value, name, min = -2147483648, max = 2147483647)
crates/celld/js/node_crypto.js:184
↓ 5 callersMethodverify
Ensures the LTX state matches where it left off from the real WAL. Ported branch-for-branch from `DB.verify` (db.go:1296-1436), footgun F-7. This is
crates/ltx/src/db.rs:593
↓ 5 callersFunctionws_unregister
(id: u64)
crates/celld/js.rs:761
↓ 4 callersMethod#sync
()
crates/celld/js/url_search_params.js:142
↓ 4 callersFunction__assertSize
(size)
crates/celld/js/node_buffer.js:155
↓ 4 callersFunction__bodyBytes
(body)
crates/celld/js/harness.js:5
↓ 4 callersFunction__makeNode
(session, path, ctx)
crates/celld/js/harness.js:2320
↓ 4 callersFunction__rpcDes
(bytes)
crates/celld/js/harness.js:2604
↓ 4 callersFunction__stubDisposedError
()
crates/celld/js/harness.js:1686
↓ 4 callersFunction__unwrapStored
(v)
crates/celld/js/harness.js:2526
↓ 4 callersMethod_advanceQueue
()
crates/celld/js/writable_stream.js:436
↓ 4 callersMethod_cancel
(reason)
crates/celld/js/streams.js:416
↓ 4 callersMethod_closing
()
crates/celld/js/writable_stream.js:273
↓ 4 callersMethod_errorStream
(e)
crates/celld/js/writable_stream.js:366
↓ 4 callersFunction_hashName
(hash)
crates/celld/js/crypto.js:33
↓ 4 callersMethod_invalidate
()
crates/celld/js/byte_streams.js:251
↓ 4 callersFunctionacquire_enrollment_lock
(config: &Path)
crates/celld/control_plane.rs:2643
↓ 4 callersMethodadmit_or_queue_activation
( &mut self, id: &str, cell: &mut Cell, start: ColdStart, effects: &mu
crates/logic/lib.rs:1628
↓ 4 callersFunctionalarm_state
(scope: &str)
crates/celld/storage.rs:2240
↓ 4 callersMethodappend
(name, value)
crates/celld/js/headers.js:72
↓ 4 callersFunctionbe_u32
(b: &[u8])
crates/ltx/src/db.rs:1371
↓ 4 callersMethodbegin_eviction
(&mut self, id: &str, rebalance: bool, effects: &mut Vec<Effect>)
crates/logic/lib.rs:3424
↓ 4 callersMethodbegin_node_lease_acquisition
( &mut self, now_ms: u64, spec: NodeLeaseSpec, effects: &mut Vec<Effect>,
crates/logic/lib.rs:1785
↓ 4 callersFunctionbigFromBytes
(u8)
crates/celld/js/node_crypto.js:1012
↓ 4 callersMethodcell_sender
(&self, cell: &str)
crates/celld/runtime.rs:918
↓ 4 callersMethodcheck_database_behind_replica
Detects when the local database has been restored to an earlier state than the replica (a lower TXID) and, if so, seeds the local L0 directory with th
crates/ltx/src/replica.rs:340
↓ 4 callersFunctioncompile_module
( scope: &mut v8::PinScope<'s, '_>, name: &str, src: &str, )
crates/celld/js.rs:7029
↓ 4 callersFunctioncopyU8
(v)
crates/celld/js/node_crypto.js:270
↓ 4 callersFunctiondecode_file_pages
Decodes and verifies a complete LTX file, returning each page's `(pgno, decompressed_data)` in write order. This reuses [`decode_file`] for full veri
crates/ltx/src/ltx.rs:510
↓ 4 callersFunctiondestroyer
(stream, err)
crates/celld/js/node_stream.js:1858
↓ 4 callersFunctiondigestInfo
(name)
crates/celld/js/node_crypto.js:279
↓ 4 callersFunctiondo_call_cancels
( )
crates/celld/js.rs:257
↓ 4 callersFunctionencode_hex
(bytes: &[u8])
crates/celld/peer_probe.rs:208
↓ 4 callersFunctionencode_hex
(bytes: &[u8])
crates/celld/peer_auth.rs:346
↓ 4 callersMethodentries
()
crates/celld/js/harness.js:3881
↓ 4 callersFunctionentry_key
(due_ms: i64, cell: &str)
crates/logic/wake.rs:36
↓ 4 callersMethoderror
(e)
crates/celld/js/byte_streams.js:234
↓ 4 callersFunctionexercise_ltx
Drives EVERY LTX parser entrypoint over one input and asserts none panic. This is the function whose no-panic property the whole suite is protecting.
crates/ltx/tests/fuzz_parsers.rs:157
↓ 4 callersMethodfetch
( &self, url: String, method: String, body: Vec<u8>, headers: Vec<(Str
crates/celld/runtime.rs:1077
↓ 4 callersFunctionfiles
(n: u64)
crates/ltx/src/store.rs:140
↓ 4 callersMethodfirst
()
crates/celld/js/node_stream.js:2123
↓ 4 callersFunctionfmt
(v)
crates/celld/js/node_crypto.js:37
↓ 4 callersFunctionformat_filename
Formats an LTX filename for a transaction range (ltx.go:487-489).
crates/ltx/src/ltx.rs:327
↓ 4 callersMethodget
(name)
crates/celld/js/headers.js:77
↓ 4 callersMethodgetReader
(options)
crates/celld/js/harness.js:117
↓ 4 callersFunctionget_alarm
(scope: &str)
crates/celld/storage.rs:2123
↓ 4 callersFunctionisDestroyed
(stream)
crates/celld/js/node_stream.js:658
↓ 4 callersFunctionisIterable
(obj, isAsync)
crates/celld/js/node_stream.js:645
↓ 4 callersFunctionisWritable
(stream)
crates/celld/js/node_stream.js:764
↓ 4 callersMethodis_active
(&self, id: &str)
crates/logic/lib.rs:1414
↓ 4 callersFunctionloader_throw
(scope: &mut v8::PinScope, message: &str)
crates/celld/js.rs:3152
↓ 4 callersMethodltx_files
( &self, level: i32, _seek: TXID, _md: bool, )
crates/ltx/tests/faults_inject.rs:192
↓ 4 callersFunctionltx_level_dir
Returns the path to the LTX level sub-directory. Ported from `LTXLevelDir` in litestream@v0.5.11 litestream.go:190-191: `return path.Join(LTXDir(root
crates/ltx/src/lib.rs:517
↓ 4 callersMethodltx_level_dir
LTX level sub-directory. Ported from `DB.LTXLevelDir` (db.go:332).
crates/ltx/src/db.rs:315
↓ 4 callersMethodname
()
crates/celld/js/harness.js:3717
↓ 4 callersFunctionnext_request_id
Allocate an id for an ingress or service-binding request so it can be aborted mid-flight.
crates/celld/js.rs:248
↓ 4 callersMethodnode_authoritative
(&self)
crates/logic/lib.rs:1107
↓ 4 callersMethodnode_lease_dependency_count
Distinct local cell lifecycles which require this process's node authority. Hibernated cells do not pin a lazy lease by themselves, but a host-held We
crates/logic/lib.rs:1430
↓ 4 callersFunctionparse_replica_url_with_query
Parses a replica URL into scheme/host/path/query/userinfo. Ported from `ParseReplicaURLWithQuery` (replica_url.go:79-104). The `s3://arn:` Access-Poi
crates/ltx/src/replica_url.rs:126
↓ 4 callersFunctionread_wal_header
Reads the 32-byte WAL header. Ported from `readWALHeader` (litestream.go:138-148): returns the header bytes; errors if the file is missing or shorter
crates/ltx/src/db.rs:1270
↓ 4 callersMethodregister
(&mut self, id: u64, tx: tokio::sync::mpsc::UnboundedSender<WsOut>)
crates/celld/js.rs:666
↓ 4 callersMethodrelease_lease
Ported from `ReleaseLease` (s3/leaser.go:171-200), via the read-then-delete strategy documented in the module header (object_store has no conditional
crates/ltx/src/leaser.rs:554
↓ 4 callersMethodrenew_lease
Ported from `RenewLease` (s3/leaser.go:138-169).
crates/ltx/src/leaser.rs:516
↓ 4 callersFunctionreport_managed_runtime_state
(state: ManagedRuntimeState)
crates/celld/control_plane.rs:124
↓ 4 callersFunctionrequire_sql_healthy
(scope: &str)
crates/celld/storage.rs:1646
↓ 4 callersFunctionresponse_stream_writers
()
crates/celld/js.rs:387
↓ 4 callersFunctionrevive
(v)
crates/celld/js/harness.js:2048
↓ 4 callersMethodset
(name, value)
crates/celld/js/node_util.js:3926
↓ 4 callersMethodshed_one
(&mut self, effects: &mut Vec<Effect>)
crates/logic/lib.rs:3472
↓ 4 callersFunctionsqlite_failure
(database: *mut rusqlite::ffi::sqlite3, operation: &str)
crates/celld/storage.rs:1632
↓ 4 callersFunctionsqlite_operation_failure
( scope: &str, database: *mut rusqlite::ffi::sqlite3, started_in_transaction: bool, result_cod
crates/celld/storage.rs:1653
↓ 4 callersMethodsum64
(&self)
crates/ltx/src/ltx.rs:107
↓ 4 callersFunctiontake
(number, options = void 0)
crates/celld/js/node_stream.js:1578
↓ 4 callersFunctiontake_execution_termination
(scope: &mut v8::PinScope)
crates/celld/js.rs:2064
↓ 4 callersFunctiontotal_changes_for_handle
(database: *mut rusqlite::ffi::sqlite3)
crates/celld/storage.rs:488
↓ 4 callersMethodunshift
(v)
crates/celld/js/node_stream.js:2056
← previousnext →201–300 of 2,867, ranked by callers