MCPcopy Create free account

hub / github.com/denoland/celld / functions

Functions2,867 in github.com/denoland/celld

⨍ Functions 2,867◇ Types & classes 485
↓ 2 callersFunctiondecompress_page
Decompresses one LZ4 frame holding exactly one page into `out`.
crates/ltx/src/ltx.rs:589
↓ 2 callersFunctiondecrement_regular_ws
(scope: &str)
crates/celld/js.rs:710
↓ 2 callersMethoddecrypt
(algorithm, key, data)
crates/celld/js/crypto.js:233
↓ 2 callersFunctiondelete_batch
Delete a batch of keys via `delete_stream`, surfacing per-key errors. When `ignore_missing` is set, `NotFound` is tolerated (delete is idempotent — t
crates/ltx/src/client/object_store.rs:815
↓ 2 callersFunctiondeserialize_storage_value
( scope: &mut v8::PinScope<'s, '_>, value: storage::StoredValue, )
crates/celld/js.rs:5959
↓ 2 callersMethoddigest
()
crates/celld/js/node_crypto.js:303
↓ 2 callersMethoddispatch_entrypoint_rpc
Invoke `method` on the named `WorkerEntrypoint`. The service-binding counterpart of `dispatch_rpc_data`: no actor scope, so no cell receiver and no SQ
crates/celld/js.rs:2511
↓ 2 callersMethoddispatch_rpc_data
Invoke one public method on a DO instance (Cloudflare native RPC), with arguments and result in either `RpcData` flavor.
crates/celld/js.rs:2454
↓ 2 callersFunctiondrain_arm_gates
Await the cell's pending wake-entry PUTs — the output-gate drain a response edge performs before releasing its reply. An error means an arm the respon
crates/celld/js.rs:222
↓ 2 callersMethoddrive
(&mut self, first: Event, in_flight: &mut FuturesUnordered<EffectFuture>)
crates/celld/main.rs:1299
↓ 2 callersMethoddurability_checked
( &mut self, op: OpId, result: Result<(), Failure>, effects: &mut Vec<Effect>,
crates/logic/lib.rs:3372
↓ 2 callersFunctiondurable_object_id_for_name
(namespace_key: &str, name: &str)
crates/celld/js.rs:4086
↓ 2 callersFunctiondurable_object_id_hex
(bytes: &[u8; 32])
crates/celld/js.rs:4102
↓ 2 callersFunctiondurable_object_id_hmac
(key: &[u8; 32], input: &[u8])
crates/celld/js.rs:4078
↓ 2 callersFunctiondurable_object_id_key
(namespace_key: &str)
crates/celld/js.rs:4066
↓ 2 callersMethoddurable_reached
A gated write's durability proof completed. Acknowledge the write only when the replica proved a position that *covers* it — a shorter proof (a laggin
crates/logic/lib.rs:3701
↓ 2 callersFunctioneager_module_global
Globals already installed by the src/js/harness for partially supported builtins. These cost every isolate, so new modules belong in `LAZY_MODULES` in
crates/celld/js.rs:7356
↓ 2 callersFunctionemitErrorNT
(self2, err)
crates/celld/js/node_stream.js:1729
↓ 2 callersMethodencrypt
(algorithm, key, data)
crates/celld/js/crypto.js:219
↓ 2 callersFunctionendpoint
()
crates/ltx/tests/integration_minio.rs:40
↓ 2 callersMethodensure_current
Populates `current` with the next item, or marks `done`. Ported from `ensureCurrent` (replica.go:1589-1603).
crates/ltx/src/replica.rs:647
↓ 2 callersMethodensure_wal_exists
Ensures the real WAL exists and has a header. Ported from `ensureWALExists` (db.go:1199-1209): exit early if the WAL header is present; otherwise for
crates/ltx/src/db.rs:380
↓ 2 callersMethodentries
()
crates/celld/js/url_search_params.js:227
↓ 2 callersFunctionenumKeys
(o)
crates/celld/js/node_assert.js:62
↓ 2 callersFunctionerrorBuffer
(state)
crates/celld/js/node_stream.js:3786
↓ 2 callersFunctionfail_
(actual, expected, message, operator, fn)
crates/celld/js/node_assert.js:50
↓ 2 callersMethodfail_initial_node_lease
(&mut self, spec: NodeLeaseSpec, effects: &mut Vec<Effect>)
crates/logic/lib.rs:1810
↓ 2 callersMethodfailure
Workerd's canonical message, matched by its conformance suite.
crates/celld/js.rs:4855
↓ 2 callersMethodfence_node
(&mut self, effects: &mut Vec<Effect>)
crates/logic/lib.rs:2495
↓ 2 callersFunctionfetch
(input, init)
crates/celld/js/harness.js:435
↓ 2 callersMethodfetch_cell
( &self, cell: String, name: Option<String>, request: RuntimeFetch, ca
crates/celld/runtime.rs:687
↓ 2 callersMethodfetch_worker
( &self, url: String, method: String, body: Vec<u8>, headers: Vec<(Str
crates/celld/main.rs:567
↓ 2 callersMethodfetch_worker_pool
Dispatch a cancellable top-level Worker request to the stateless pool.
crates/celld/runtime.rs:341
↓ 2 callersMethodfill
(&mut self, buf: &mut [u8])
crates/ltx/tests/fuzz_parsers.rs:94
↓ 2 callersFunctionfindLooseMatchingPrimitives
(prim)
crates/celld/js/node_util.js:3631
↓ 2 callersFunctionfinishImpl
(err, final)
crates/celld/js/node_stream.js:4945
↓ 2 callersFunctionfinish_alarm_handler
Finish an alarm handler. A successful handler consumes its original alarm; a failed handler reschedules it. Any alarm explicitly changed by the handle
crates/celld/storage.rs:2299
↓ 2 callersFunctionfinish_incoming_request
(tc: &mut v8::PinScope, request_id: RequestId)
crates/celld/js.rs:7684
↓ 2 callersFunctionfinish_open
(scope: &str, c: Connection)
crates/celld/storage.rs:357
↓ 2 callersFunctionflow
(stream)
crates/celld/js/node_stream.js:3099
↓ 2 callersFunctionformat
Formats a `SystemTime` as an RFC-3339 UTC string (`…Z`), trimming trailing zeros from the fractional-second field (Go `time.RFC3339Nano` behaviour). P
crates/ltx/src/leaser.rs:789
↓ 2 callersFunctionformat
(...args)
crates/celld/js/node_util.js:3010
↓ 2 callersFunctionformatBigInt
(fn, bigint, numericSeparator)
crates/celld/js/node_util.js:2483
↓ 2 callersFunctionformatMapIterInner
(ctx, recurseTimes, entries, state)
crates/celld/js/node_util.js:2712
↓ 2 callersFunctionformatSetIterInner
(ctx, recurseTimes, entries, state)
crates/celld/js/node_util.js:2691
↓ 2 callersFunctionformatWithOptionsInternal
(inspectOptions, args)
crates/celld/js/node_util.js:3023
↓ 2 callersFunctionformat_rfc3339_nano
Format `unix_millis` as an RFC3339Nano UTC string (`…Z`, fractional seconds trimmed of trailing zeros, matching Go's `time.RFC3339Nano`).
crates/ltx/src/client/object_store.rs:906
↓ 2 callersFunctionframe_data
Reconstructs the exact 4096-byte SQLite page from litestream_test.go:42. The page is mostly zeros; all 52 non-zero bytes are listed here. We use spar
crates/ltx/tests/litestream_helpers.rs:37
↓ 2 callersFunctiongetHkdf
(hash, key, salt, info, length)
crates/celld/js/node_crypto.js:844
↓ 2 callersFunctiongetMaxListeners_
(that)
crates/celld/js/node_events.js:110
↓ 2 callersFunctiongetOwnNonIndexProperties
( // deno-lint-ignore ban-types obj, filter)
crates/celld/js/node_util.js:196
↓ 2 callersFunctiongetPbkdf
(password, salt, iterations, keylen, digest)
crates/celld/js/node_crypto.js:789
↓ 2 callersFunctiongetStackString
(ctx, error)
crates/celld/js/node_util.js:2176
↓ 2 callersFunctiongetStringWidth
* Returns the number of columns required to display the given string.
crates/celld/js/node_util.js:3171
↓ 2 callersMethodgetWriter
()
crates/celld/js/writable_stream.js:530
↓ 2 callersFunctionget_many_stored
(scope: &str, keys: &[String])
crates/celld/storage.rs:1379
↓ 2 callersFunctionget_string
(bucket: &Bucket, key: &str)
crates/celld/fleet.rs:341
↓ 2 callersFunctionhandle_reentrant_job
( tc: &mut v8::PinScope, rx: &std::sync::mpsc::Receiver<CellJob>, job: CellJob, )
crates/celld/js.rs:1351
↓ 2 callersFunctionharness_env
(scope: &mut v8::PinScope<'s, '_>)
crates/celld/js.rs:6977
↓ 2 callersMethodhead_with_meta
Size plus one `x-amz-meta-*` value, or `None` when the key does not exist. A plain `head` cannot see user metadata; this one can.
crates/celld/bucket.rs:157
↓ 2 callersFunctionheader
(min_txid: TXID, max_txid: TXID, page_size: u32, timestamp: i64, commit: u32)
crates/ltx/tests/integration_minio.rs:223
↓ 2 callersMethodhealthy
(&self)
crates/celld/main.rs:716
↓ 2 callersMethodhighest_nonempty_epoch
Highest epoch under `cells/<cell>/ltx/` that holds any LTX — the newest durable copy to restore on takeover.
crates/celld/ltx_repl.rs:138
↓ 2 callersFunctionhkdfValidate
(hash, key, salt, info, length)
crates/celld/js/node_crypto.js:831
↓ 2 callersMethodhold_node_lease
( &mut self, spec: NodeLeaseSpec, record: NodeLeaseRecord, prior: Option<HeldN
crates/logic/lib.rs:1825
↓ 2 callersFunctionincrement_regular_ws
(scope: &str)
crates/celld/js.rs:703
↓ 2 callersFunctioninspect
(v, depth = 0)
crates/celld/js/node_events.js:65
↓ 2 callersFunctioninspect
(v, depth = 0)
crates/celld/js/node_assert.js:10
↓ 2 callersFunctioninstallation_storage_with_version
()
crates/celld/control_plane.rs:737
↓ 2 callersMethodinto_db
Consumes the replica and returns the attached database, if any. Lets a host perform a clean [`Db::close`] (which consumes the `Db`) after a final sync
crates/ltx/src/replica.rs:143
↓ 2 callersFunctioninvalidArgType
(name, expected, value)
crates/celld/js/node_path.js:21
↓ 2 callersFunctioninvalidArgTypeHelper
(input)
crates/celld/js/node_util.js:702
↓ 2 callersFunctioninvoke
(operation)
crates/celld/js/harness.js:2725
↓ 2 callersFunctionisAsyncFunction
(v)
crates/celld/js/node_stream.js:104
↓ 2 callersFunctionisDataView
(v)
crates/celld/js/node_crypto.js:223
↓ 2 callersFunctionisKeyObject
(obj)
crates/celld/js/node_crypto.js:565
↓ 2 callersFunctionisOutgoingMessage
(stream)
crates/celld/js/node_stream.js:860
↓ 2 callersFunctionisPrimeBig
(n, checks)
crates/celld/js/node_crypto.js:1050
↓ 2 callersFunctionisRequest
(stream)
crates/celld/js/node_stream.js:996
↓ 2 callersFunctionisUndetectableObject
(v)
crates/celld/js/node_util.js:940
↓ 2 callersFunctionisWritableFinished
(stream, strict)
crates/celld/js/node_stream.js:688
↓ 2 callersMethodis_eof
(&self)
crates/ltx/src/wal.rs:139
↓ 2 callersMethodis_expired
Returns `true` once the wall clock has passed `expires_at`. Ported from `Lease.IsExpired` (leaser.go:38-40): `time.Now().After(ExpiresAt)`. Note Go u
crates/ltx/src/leaser.rs:243
↓ 2 callersFunctionis_external
Scan a bundle for its external (`cloudflare:*` / `node:*`) imports and the named/default bindings pulled from each. V8 static-links these, so a stub m
crates/celld/js.rs:7066
↓ 2 callersFunctionis_local_endpoint
`true` for localhost / loopback / RFC1918 / `.local` endpoints. Ported from `IsLocalEndpoint` (replica_url.go:306-329).
crates/ltx/src/replica_url.rs:403
↓ 2 callersMethodis_public_ip
(&self)
crates/celld/startup.rs:59
↓ 2 callersFunctionis_reserved_sql_name
(name: &str)
crates/celld/storage.rs:160
↓ 2 callersMethodis_zero
(&self)
crates/ltx/src/ltx.rs:256
↓ 2 callersFunctionkeyMaterial
(key)
crates/celld/js/node_crypto.js:488
↓ 2 callersFunctionlift
(v)
crates/celld/js/harness.js:1816
↓ 2 callersFunctionlist_query
( scope: &str, begin: Option<&str>, end: Option<&str>, start_after: Option<&str>, prefix:
crates/celld/storage.rs:1591
↓ 2 callersFunctionlist_stored_with_options
( scope: &str, begin: Option<&str>, end: Option<&str>, start_after: Option<&str>, prefix:
crates/celld/storage.rs:1570
↓ 2 callersFunctionlitestream_bin
The real binary under test: `$LITESTREAM_BIN`, or `litestream` on PATH. The oracle is pinned to the v0.5 replica format (v0.5.11); a v0.3-era binary k
crates/ltx/tests/integration_file.rs:58
↓ 2 callersFunctionlitestream_bin
The real binary under test: `$LITESTREAM_BIN`, or `litestream` on PATH. The oracle is pinned to the v0.5 replica format (v0.5.11); a v0.3-era binary k
crates/ltx/tests/differential_xtool.rs:77
↓ 2 callersFunctionload
(bucket: &Bucket)
crates/celld/peer_auth.rs:287
↓ 2 callersFunctionloadFrom
(getCode)
crates/celld/js/harness.js:1357
↓ 2 callersFunctionload_worker_from_pointer
( bucket: &Bucket, pointer_key: &str, node: String, )
crates/celld/fleet.rs:364
↓ 2 callersFunctionlooseEq
(a, b)
crates/celld/js/node_assert.js:58
↓ 2 callersFunctionltx_dir
Returns the path to the LTX directory under a given root. Ported from `LTXDir` in litestream@v0.5.11 litestream.go:185: `return path.Join(root, "ltx"
crates/ltx/src/lib.rs:507
↓ 2 callersMethodltx_files
(&self, l: i32, s: TXID, m: bool)
crates/ltx/src/replica.rs:1193
← previousnext →601–700 of 2,867, ranked by callers