MCPcopy Create free account

hub / github.com/denoland/celld / functions

Functions2,867 in github.com/denoland/celld

⨍ Functions 2,867◇ Types & classes 485
↓ 2 callersMethodltx_files
( &self, level: i32, seek: TXID, _use_metadata: bool, )
crates/ltx/src/client/file.rs:40
↓ 2 callersMethodmac
(&self, request: &CanonicalRequest<'_>)
crates/celld/peer_auth.rs:238
↓ 2 callersFunctionmachine_hostname
()
crates/celld/control_plane.rs:2748
↓ 2 callersFunctionmake
(format, decompress)
crates/celld/js/compression_streams.js:24
↓ 2 callersFunctionmakeStub
(idPromise, evictable)
crates/celld/js/harness.js:1339
↓ 2 callersFunctionmake_incoming_request
Like `make_request`, but marks the request as incoming. Its signal is registered only if the handler actually suspends, preserving the synchronous req
crates/celld/js.rs:7637
↓ 2 callersFunctionmake_request
( tc: &mut v8::PinScope<'s, '_>, url: &str, method: &str, body: &[u8], headers: &[(String,
crates/celld/js.rs:7698
↓ 2 callersMethodmarshal
Encodes the header to 100 bytes (ltx.go:283-299).
crates/ltx/src/ltx.rs:178
↓ 2 callersFunctionmatchValues
(input, baseURL)
crates/celld/js/url_pattern.js:30
↓ 2 callersMethodmax_ltx_file_info
Metadata about the last LTX file for a given level (highest `max_txid`), or a zero `FileInfo` if none exist. Ported from `Replica.MaxLTXFileInfo` (rep
crates/ltx/src/replica.rs:299
↓ 2 callersFunctionmutate
Mutates `seed_bytes` in place with one randomly-chosen strategy and returns the result. Strategies are weighted toward "structurally almost valid" mut
crates/ltx/tests/fuzz_parsers.rs:239
↓ 2 callersFunctionneedFinish
(state)
crates/celld/js/node_stream.js:3916
↓ 2 callersFunctionnext
()
crates/celld/js/node_stream.js:2374
↓ 2 callersMethodnext
()
crates/celld/js/harness.js:610
↓ 2 callersMethodnext_byte
(&mut self)
crates/ltx/tests/fuzz_parsers.rs:82
↓ 2 callersMethodnext_u64
(&mut self)
crates/ltx/tests/fuzz_parsers.rs:74
↓ 2 callersMethodno_checksum
True if checksum tracking is disabled for this file.
crates/ltx/src/ltx.rs:148
↓ 2 callersMethodnode
(&self)
crates/celld/runtime.rs:222
↓ 2 callersFunctionnode_config
Node-level object-store config (no per-cell prefix). `build_store` on this yields the one shared client; per-cell clients set only `path`.
crates/celld/ltx_repl.rs:490
↓ 2 callersMethodnode_lease_read
( &mut self, op: OpId, now_ms: u64, result: Result<Option<NodeLeaseRecord>, Fa
crates/logic/lib.rs:2893
↓ 2 callersFunctionnode_record_is_dead
A listed node record is GC-eligible only when its identity still matches its object key and its wall-clock lease is no longer live.
crates/logic/dead_node_reconciliation.rs:38
↓ 2 callersFunctionnormalizeEncoding
(enc)
crates/celld/js/node_stream.js:78
↓ 2 callersFunctionnormalizeString
(path, allowAboveRoot, separator, isPathSeparator2)
crates/celld/js/node_path.js:50
↓ 2 callersFunctionnormalized_control_url
(value: &str)
crates/celld/control_plane.rs:2709
↓ 2 callersFunctionnow_ms
()
crates/celld/peer_auth.rs:335
↓ 2 callersFunctionnow_unix_millis
Current time as Unix milliseconds (the LTX header timestamp).
crates/ltx/src/db.rs:1362
↓ 2 callersMethodoffset
Returns the file offset of the last frame read, or `0` if no frame has been read yet. Ported from `Offset` in litestream@v0.5.11 wal_reader.go:82-87.
crates/ltx/src/wal.rs:341
↓ 2 callersFunctiononce
(callback)
crates/celld/js/node_stream.js:92
↓ 2 callersFunctionop_do_call_impl
( scope: &mut v8::PinScope, args: v8::FunctionCallbackArguments, rv: &mut v8::ReturnValue<v8::Valu
crates/celld/js.rs:3514
↓ 2 callersFunctionop_svc_call_impl
( scope: &mut v8::PinScope, args: v8::FunctionCallbackArguments, rv: &mut v8::ReturnValue<v8::Valu
crates/celld/js.rs:3046
↓ 2 callersFunctionopen
( bucket: &str, endpoint: Option<&str>, region: &str, managed: Option<&crate::control_plane::M
crates/celld/fleet.rs:43
↓ 2 callersFunctionopen_enrollment_lock
(config: &Path)
crates/celld/control_plane.rs:2654
↓ 2 callersMethodopen_ltx_file
( &self, level: i32, min_txid: TXID, max_txid: TXID, offset: i64,
crates/ltx/src/client/file.rs:83
↓ 2 callersFunctionopen_writer
Opens an application writer connection in WAL mode (the analog of the host's own SQLite handle writing alongside the managed `Db`).
crates/ltx/tests/integration_file.rs:100
↓ 2 callersFunctionopen_writer
Opens an application writer connection in WAL mode — the host's own SQLite handle writing alongside the managed `Db`, exactly as a library embedder do
crates/ltx/tests/differential_xtool.rs:145
↓ 2 callersFunctionoptions_from_env
()
crates/celld/control_plane.rs:2446
↓ 2 callersMethodowner_cas_completed
( &mut self, op: OpId, result: Result<CasOutcome, Failure>, effects: &mut Vec<
crates/logic/lib.rs:3091
↓ 2 callersMethodowner_read
( &mut self, op: OpId, now_ms: u64, result: Result<Option<OwnerRecord>, Failur
crates/logic/lib.rs:2762
↓ 2 callersFunctionparse_advertise
Parse `--advertise`, accepting `IP:PORT` or `HOST:PORT`.
crates/celld/startup.rs:235
↓ 2 callersFunctionparse_page_index
Parses the varint page index (decoder.go:309-346): tuples of `(pgno, offset, size)` terminated by a `pgno == 0` marker.
crates/ltx/src/ltx.rs:604
↓ 2 callersFunctionparse_request_id
(value: &str)
crates/celld/js.rs:276
↓ 2 callersFunctionparse_scheme
Extracts and lowercases the URL scheme (matching Go `net/url`, which lowercases schemes). Returns `("", s)` when there is no valid leading `scheme:` (
crates/ltx/src/replica_url.rs:108
↓ 2 callersFunctionparse_txid
Parses a TXID from its canonical 16-character lowercase hex representation. Returns an error if the string is not exactly 16 hex characters or contai
crates/ltx/src/lib.rs:167
↓ 2 callersFunctionpause
()
crates/celld/js/node_stream.js:2893
↓ 2 callersFunctionpbkdf2Check
(password, salt, iterations, keylen, digest)
crates/celld/js/node_crypto.js:781
↓ 2 callersFunctionpending_aborts
()
crates/celld/js.rs:915
↓ 2 callersFunctionpending_arm_gates
()
crates/celld/js.rs:173
↓ 2 callersFunctionphase_holds_activation
(phase: &Phase)
crates/logic/lib.rs:4072
↓ 2 callersMethodping
(&self)
crates/ltx/src/leaser.rs:705
↓ 2 callersFunctionpoll_and_apply
( client: &reqwest::Client, config: &CloudConfig, bucket: &Bucket, )
crates/celld/control_plane.rs:1636
↓ 2 callersMethodpos
The current replicated position. Ported from `Replica.Pos` (replica.go:237-241).
crates/ltx/src/replica.rs:156
↓ 2 callersFunctionprepareAsymmetricKey
(key, ctx)
crates/celld/js/node_crypto.js:621
↓ 2 callersFunctionprependListener
(emitter, event, fn)
crates/celld/js/node_stream.js:1965
↓ 2 callersFunctionprobe_payload
(node: &str, advertise: &str, challenge: &str)
crates/celld/peer_probe.rs:192
↓ 2 callersFunctionprocessGeneratePrimeOptions
(options)
crates/celld/js/node_crypto.js:1130
↓ 2 callersFunctionproject_relative_path
(value: &str, key: &str)
crates/celld/deploy.rs:834
↓ 2 callersFunctionprune_remote_aborts
(aborts: &mut HashMap<js::RequestId, Instant>)
crates/celld/runtime.rs:26
↓ 2 callersMethodpublished
(&mut self, op: OpId, result: Result<(), Failure>, effects: &mut Vec<Effect>)
crates/logic/lib.rs:3259
↓ 2 callersMethodpublished_epoch
(&self, cell: &str)
crates/celld/runtime.rs:781
↓ 2 callersFunctionpump
()
crates/celld/js/node_stream.js:1260
↓ 2 callersFunctionput_many_serialized
(scope: &str, entries: &[(String, Vec<u8>)])
crates/celld/storage.rs:1463
↓ 2 callersFunctionput_serialized
(scope: &str, key: &str, value: &[u8])
crates/celld/storage.rs:1412
↓ 2 callersMethodput_with_meta
Plain write carrying `x-amz-meta-*` user metadata.
crates/celld/bucket.rs:180
↓ 2 callersFunctionrandomPrime
(size, safe, addBuf, remBuf)
crates/celld/js/node_crypto.js:1074
↓ 2 callersFunctionrandom_peer_key
()
crates/celld/main.rs:5124
↓ 2 callersMethodread_frame_inner
Frame-read core shared by [`Self::read_frame`] and the offset constructor. When `verify_checksum` is `false`, the running checksum is *set* from the
crates/ltx/src/wal.rs:427
↓ 2 callersMethodread_lease
Reads the current lock object. Returns `Ok(None)` when the object is absent (the Go `os.ErrNotExist` path, s3/leaser.go:210-212); otherwise the decode
crates/ltx/src/leaser.rs:355
↓ 2 callersFunctionread_node
(bucket: &Bucket, key: &str)
crates/celld/dead_node_gc.rs:324
↓ 2 callersMethodread_node_lease_with
( &self, bucket: &Bucket, owner: &str, )
crates/celld/ownership_store.rs:190
↓ 2 callersFunctionread_response
( scope: &mut v8::PinScope, ret: v8::Local<v8::Value>, cell_rx: Option<&std::sync::mpsc::Receiver<
crates/celld/js.rs:7717
↓ 2 callersFunctionread_wal_page
Reads one page's worth of bytes from an in-memory WAL buffer at the frame `offset` (the offset is the start of the *frame header*; the page data follo
crates/ltx/src/db.rs:1298
↓ 2 callersMethodready_to_serve
Whether the process can accept new traffic. An idle lazy node is ready even though it intentionally holds no authority: a DO request first acquires th
crates/logic/lib.rs:1123
↓ 2 callersMethodrebalances
Does an eviction made for room hand the cell away?
crates/logic/lib.rs:3420
↓ 2 callersMethodrecord_acquisition
(&mut self, spec: &RestoreSpec)
crates/logic/lib.rs:1531
↓ 2 callersFunctionrecycle_sql_statement
(scope: &str, query: &str, statement: *mut rusqlite::ffi::sqlite3_stmt)
crates/celld/storage.rs:802
↓ 2 callersFunctionregister_actor_name
( scope: &mut v8::PinScope, actor_scope: &str, name: Option<&str>, )
crates/celld/js.rs:4135
↓ 2 callersFunctionregister_incoming_request
( tc: &mut v8::PinScope, request_id: RequestId, request: v8::Local<v8::Value>, )
crates/celld/js.rs:7664
↓ 2 callersMethodreleaseLock
()
crates/celld/js/streams.js:156
↓ 2 callersMethodreload_after_process_exit
(&mut self)
crates/celld/js.rs:2317
↓ 2 callersMethodrequest_authorized
(&mut self, request: RequestId, id: CellId, effects: &mut Vec<Effect>)
crates/logic/lib.rs:2567
↓ 2 callersMethodrequest_with_mode
( &self, cell: String, capacity_handoff: bool, )
crates/celld/main.rs:530
↓ 2 callersMethodresidents
(&self)
crates/logic/lib.rs:1198
↓ 2 callersFunctionresolved_promise
( tc: &mut v8::PinScope<'s, '_>, value: v8::Local<'s, v8::Value>, )
crates/celld/js.rs:1237
↓ 2 callersMethodresponse
( &self, encoded_path: &str, query: Option<&str>, host: Option<&str>,
crates/celld/assets.rs:180
↓ 2 callersFunctionrestart_process
(trigger: &'static str)
crates/celld/control_plane.rs:41
↓ 2 callersMethodrestore
( &self, cell: &str, spec: &celld_logic::RestoreSpec, )
crates/celld/runtime.rs:126
↓ 2 callersFunctionrestore_candidate_better
True if `next` is a strictly better restore candidate than `curr`: longer reach first (`MaxTXID`), then a smaller `MinTXID` (more coverage), then a hi
crates/ltx/src/replica.rs:665
↓ 2 callersMethodrestore_completed
( &mut self, op: OpId, result: Result<RestoreOutcome, Failure>, effects: &mut
crates/logic/lib.rs:3162
↓ 2 callersFunctionresume
(stream, state)
crates/celld/js/node_stream.js:3071
↓ 2 callersMethodresume_node_lease_after_failure
( &mut self, prior: HeldNodeLease, now_mono_ms: u64, effects: &mut Vec<Effect>
crates/logic/lib.rs:1866
↓ 2 callersFunctionretry_credential_handoff_ack
(path: PathBuf, config: CloudConfig)
crates/celld/control_plane.rs:2495
↓ 2 callersFunctionrollback
Rolls back the connection's current transaction, swallowing the "already rolled back" / "no transaction is active" errors (issue #934). Ported from `r
crates/ltx/src/db.rs:1248
↓ 2 callersFunctionrpc_data_ret
The inverse: `__dispatchRpc` answers in the flavor it was asked in.
crates/celld/js.rs:1640
↓ 2 callersFunctionrpc_data_value
An `RpcData` payload as the JS argument `__dispatchRpc` expects: a string for the JSON flavor, a `Uint8Array` for structured clone.
crates/celld/js.rs:1632
↓ 2 callersFunctionrun_bootstrap_script
(scope: &mut v8::PinScope, name: &'static str, src: &str)
crates/celld/js.rs:6575
↓ 2 callersFunctionrun_client_suite
Generic conformance suite every `ReplicaClient` backend must pass: empty state, write, listing order, seek filtering, full + partial reads, not-found,
crates/ltx/src/client/mod.rs:100
↓ 2 callersMethodruntime_started
( &mut self, op: OpId, result: Result<(), Failure>, effects: &mut Vec<Effect>,
crates/logic/lib.rs:3224
↓ 2 callersFunctionrustyriver_replicate
Drives rustyriver's write path over `workload()`: opens a managed `Db`, an app writer, applies each statement-group, then captures (`db.sync`) and upl
crates/ltx/tests/differential_xtool.rs:179
↓ 2 callersFunctions3_client_with_credentials
( bucket: &str, endpoint: Option<&str>, region: &str, managed: Option<&crate::control_plane::M
crates/celld/fleet.rs:34
↓ 2 callersMethodsalt
(&self)
crates/ltx/src/wal.rs:333
← previousnext →701–800 of 2,867, ranked by callers