Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/denoland/celld
/ functions
Functions
2,867 in github.com/denoland/celld
⨍
Functions
2,867
◇
Types & classes
485
↓ 4 callers
Function
usv
(v)
crates/celld/js/url_pattern.js:14
↓ 4 callers
Function
validate_response
(headers: &axum::http::HeaderMap)
crates/celld/peer_auth.rs:308
↓ 4 callers
Function
wal_checksum
Computes a running SQLite WAL checksum over a byte slice. The slice length **must** be a multiple of 8 bytes (the function panics otherwise, matching
crates/ltx/src/lib.rs:327
↓ 4 callers
Method
websocket_closed
(&self, cell: String, websocket: u64)
crates/celld/main.rs:679
↓ 4 callers
Function
with_mut
(scope: &str, f: impl FnOnce(&mut Connection) -> T)
crates/celld/storage.rs:409
↓ 4 callers
Method
with_ttl
Overrides the lease TTL (default [`DEFAULT_LEASE_TTL`]).
crates/ltx/src/leaser.rs:318
↓ 4 callers
Function
without_sql_authorizer_mut
( connection: &mut Connection, callback: impl FnOnce(&mut Connection) -> T, )
crates/celld/storage.rs:334
↓ 4 callers
Method
write_ltx_file
(&self, l: i32, mn: TXID, mx: TXID, d: &[u8])
crates/ltx/src/replica.rs:1209
↓ 4 callers
Function
ws_emit
(id: u64, out: WsOut)
crates/celld/js.rs:805
↓ 4 callers
Function
ws_emit_batch
Flush frames the output gate held: send each to its socket's task. Called from the actor thread once the gating write is proved durable.
crates/celld/js.rs:816
↓ 3 callers
Function
ArrayIsArray
(self2)
crates/celld/js/node_stream.js:243
↓ 3 callers
Function
ObjectDefineProperties
(self2, props)
crates/celld/js/node_stream.js:281
↓ 3 callers
Function
ObjectKeys
(obj)
crates/celld/js/node_stream.js:290
↓ 3 callers
Function
__ctxError
(kind)
crates/celld/js/harness.js:1553
↓ 3 callers
Function
__ctxUnregister
(meta)
crates/celld/js/harness.js:1599
↓ 3 callers
Function
__decodeStr
(bytes, enc)
crates/celld/js/node_buffer.js:117
↓ 3 callers
Function
__newEntry
(target)
crates/celld/js/harness.js:1647
↓ 3 callers
Function
__raceCallerAbort
(dispatch, signal, abandon)
crates/celld/js/harness.js:1166
↓ 3 callers
Function
__rpcDesArgs
(bytes)
crates/celld/js/harness.js:2595
↓ 3 callers
Function
__rpcRun
(body, lift)
crates/celld/js/harness.js:2588
↓ 3 callers
Function
__swapErr
(bits)
crates/celld/js/node_buffer.js:500
↓ 3 callers
Function
__tagged
(tag, sc)
crates/celld/js/harness.js:1519
↓ 3 callers
Function
_checkValue
(value)
crates/celld/js/headers.js:12
↓ 3 callers
Method
_dealWithRejection
(e)
crates/celld/js/writable_stream.js:428
↓ 3 callers
Method
_doneChunk
()
crates/celld/js/identity_transform_stream.js:77
↓ 3 callers
Method
_errorRd
(e)
crates/celld/js/identity_transform_stream.js:194
↓ 3 callers
Function
_extra
(operation, input)
crates/celld/js/crypto.js:64
↓ 3 callers
Method
_finishErroring
()
crates/celld/js/writable_stream.js:379
↓ 3 callers
Method
_iterate
(pick)
crates/celld/js/harness.js:3868
↓ 3 callers
Function
_makeHeadersIter
(map, kind)
crates/celld/js/headers.js:147
↓ 3 callers
Method
_maybePull
()
crates/celld/js/streams.js:366
↓ 3 callers
Function
_operationError
(message)
crates/celld/js/crypto.js:43
↓ 3 callers
Function
_readResult
(value, done)
crates/celld/js/streams.js:9
↓ 3 callers
Method
_rejectClosed
(e)
crates/celld/js/streams.js:358
↓ 3 callers
Method
_rejectClosed
(e)
crates/celld/js/writable_stream.js:139
↓ 3 callers
Method
_rejectReady
(e)
crates/celld/js/writable_stream.js:122
↓ 3 callers
Method
_startErroring
(reason)
crates/celld/js/writable_stream.js:370
↓ 3 callers
Method
_view
(d)
crates/celld/js/identity_transform_stream.js:95
↓ 3 callers
Method
_write
(chunk)
crates/celld/js/writable_stream.js:291
↓ 3 callers
Function
abortError
(cause)
crates/celld/js/node_events.js:42
↓ 3 callers
Function
acknowledge_credential_handoff
( client: &reqwest::Client, config: &CloudConfig, handoff_id: &str, )
crates/celld/control_plane.rs:2537
↓ 3 callers
Function
aggregateTwoErrors
(inner, outer)
crates/celld/js/node_stream.js:210
↓ 3 callers
Method
alarm_covered
(&self, cell: &str, at_ms: Option<i64>)
crates/celld/runtime.rs:801
↓ 3 callers
Function
assert
(value, message = 'Assertion failed')
crates/celld/js/node_util.js:895
↓ 3 callers
Method
below
(&mut self, n: usize)
crates/ltx/tests/fuzz_parsers.rs:87
↓ 3 callers
Function
bindings
( manifest: &'a Manifest, kind: &'a str, )
crates/celld/fleet.rs:464
↓ 3 callers
Function
bitLength
(n)
crates/celld/js/node_crypto.js:1011
↓ 3 callers
Function
calc_restore_plan
Returns the ordered list of LTX files needed to restore the database at `txid` (`TXID(0)` = latest). Ported from `CalcRestorePlan` (replica.go:1419-1
crates/ltx/src/replica.rs:472
↓ 3 callers
Method
cancel
(reason)
crates/celld/js/streams.js:449
↓ 3 callers
Method
cancel
()
crates/celld/js/harness.js:144
↓ 3 callers
Function
clearBuffer
(stream, state)
crates/celld/js/node_stream.js:3813
↓ 3 callers
Method
client_for
A per-cell client over the shared store, keyed to the cell's epoch prefix. `cells/<cell>/ltx/e<epoch>` matches [`Self::db_path`]'s remote twin so the
crates/celld/ltx_repl.rs:125
↓ 3 callers
Function
clone
(input)
crates/celld/js/harness.js:4274
↓ 3 callers
Method
close
()
crates/celld/js/streams.js:72
↓ 3 callers
Function
close_sync_list_cursors
(scope: &str)
crates/celld/storage.rs:1718
↓ 3 callers
Function
complete_fetch_event
Publish a fetch response when the handler settles, then keep driving the event region so waitUntil work can complete without delaying headers or a str
crates/celld/js.rs:1250
↓ 3 callers
Method
complete_request
( &mut self, id: &str, request: RequestId, result: Result<Route, RequestError>
crates/logic/lib.rs:1507
↓ 3 callers
Method
concat
(n)
crates/celld/js/node_stream.js:2095
↓ 3 callers
Function
connect
(options: ConnectOptions, wait: bool)
crates/celld/control_plane.rs:2153
↓ 3 callers
Method
db
Returns a reference to the attached database, if any. Ported from `Replica.DB` (replica.go:89).
crates/ltx/src/replica.rs:135
↓ 3 callers
Function
db_equal
Runs `db_equal.sh <mode> <a> <b>`; returns Ok(()) on exit 0, else the captured stderr/stdout for the failure message. Requires `sqlite3` on PATH.
crates/ltx/tests/integration_file.rs:35
↓ 3 callers
Method
db_path
(&self, cell: &str, epoch: u64)
crates/celld/ltx_repl.rs:114
↓ 3 callers
Function
decode_database_image
Reconstructs the full SQLite database image from a **snapshot** LTX file (every page `1..=commit`, with the lock page zero-filled). Ported from `Deco
crates/ltx/src/ltx.rs:548
↓ 3 callers
Function
decode_path
(path: &str)
crates/celld/assets.rs:1195
↓ 3 callers
Function
deepEq
(a, b, strict, seen)
crates/celld/js/node_assert.js:90
↓ 3 callers
Method
delete
(name)
crates/celld/js/node_util.js:3916
↓ 3 callers
Method
delete_all
(&self)
crates/ltx/tests/faults_inject.rs:238
↓ 3 callers
Function
deserialize_stored
Decode one stored row for JS. A stub-tagged row comes back as `[sentinel, tree]` (plus `true`), which only the storage wrapper — holder of the closure
crates/celld/js.rs:6000
↓ 3 callers
Function
discard_cached_sql_statement
(scope: &str, query: &str)
crates/celld/storage.rs:787
↓ 3 callers
Function
dispatch_ws_closed
( app: &AppHandle, scope: &str, ws_id: u64, code: u16, reason: String, was_clean: bool
crates/celld/main.rs:3027
↓ 3 callers
Function
due_alarm_entry
Scheduled time and retry count for an alarm due at/before `now_ms`.
crates/celld/storage.rs:2228
↓ 3 callers
Method
emit
(&mut self, id: u64, out: WsOut)
crates/celld/js.rs:680
↓ 3 callers
Function
emitReadable
(stream)
crates/celld/js/node_stream.js:2791
↓ 3 callers
Method
encode
(self)
crates/celld/js.rs:561
↓ 3 callers
Function
encode_http_response
Encode a cell/service response for the JS side. A text body crosses as a JS string (cheap, lossless), binary as a byte array, and a streaming body by
crates/celld/js.rs:410
↓ 3 callers
Method
entries
()
crates/celld/js/headers.js:100
↓ 3 callers
Function
env
()
crates/celld/js/harness.js:3312
↓ 3 callers
Function
exercise_wal
Drives the WAL reader over one input and asserts no panic: construction, a bounded `read_frame` drain, the `page_map` aggregation, a `frame_salts_unti
crates/ltx/tests/fuzz_parsers.rs:185
↓ 3 callers
Function
fail
(method)
crates/celld/js/harness.js:455
↓ 3 callers
Method
fetch_and_reply_id
As `fetch_and_reply`, but the request's signal is registered under `request_id` so an HTTP or service-binding caller that disconnects reaches the targ
crates/celld/js.rs:2648
↓ 3 callers
Function
file_url
A `file://<abs-path>` URL for the real binary's `file:` backend. The path must be absolute (litestream rejects a relative `file://` host segment).
crates/ltx/tests/differential_xtool.rs:134
↓ 3 callers
Function
fillRandom
(view)
crates/celld/js/node_crypto.js:872
↓ 3 callers
Method
finish
(isError, error)
crates/celld/js/streams.js:597
↓ 3 callers
Function
finishMaybe
(stream, state, sync)
crates/celld/js/node_stream.js:3967
↓ 3 callers
Function
finish_alarm_handler_with_retry_policy
( scope: &str, succeeded: bool, now_ms: i64, retry_counts_against_limit: bool, )
crates/celld/storage.rs:2303
↓ 3 callers
Method
forEach
(cb, thisArg)
crates/celld/js/headers.js:104
↓ 3 callers
Function
formatNumber
(fn, number, numericSeparator)
crates/celld/js/node_util.js:2462
↓ 3 callers
Function
formatPrimitive
(fn, value, ctx)
crates/celld/js/node_util.js:2490
↓ 3 callers
Method
frame_salts_until
Returns the set of unique frame salt pairs in the WAL, scanning until the `until` salt pair is seen or end-of-file is reached. Unlike frame reading,
crates/ltx/src/wal.rs:552
↓ 3 callers
Function
full_surface_source
Full-surface module source for a builtin: run the (guarded) setup, probe the backing object's enumerable keys, and re-export each one. Serves both `im
crates/celld/js.rs:7519
↓ 3 callers
Method
gate_write
The output gate. The caller invokes this only for a request whose handler advanced the cell's committed position, so the response is held until the co
crates/celld/main.rs:608
↓ 3 callers
Function
getArrayBufferOrView
(buffer, name, encoding)
crates/celld/js/node_crypto.js:232
↓ 3 callers
Function
getDefaultHighWaterMark
(objectMode)
crates/celld/js/node_stream.js:2224
↓ 3 callers
Function
getHighWaterMark
(state, options, duplexKey, isDuplex)
crates/celld/js/node_stream.js:2227
↓ 3 callers
Function
getPrefix
(constructor, tag, fallback, size = '')
crates/celld/js/node_util.js:1594
↓ 3 callers
Method
getReader
(options)
crates/celld/js/streams.js:405
↓ 3 callers
Function
has_bin
True if `bin` resolves on PATH.
crates/ltx/tests/integration_file.rs:90
↓ 3 callers
Function
has_bin
True if `bin` resolves on PATH.
crates/ltx/tests/integration_resilience.rs:59
↓ 3 callers
Method
has_capacity
(&self)
crates/logic/lib.rs:1404
↓ 3 callers
Method
head
Size and etag, or `None` when the key does not exist.
crates/celld/bucket.rs:139
← previous
next →
301–400 of 2,867, ranked by callers