L
P
V
LCurrently, DO to DO RPC requires at least 2 requests per RPC callWhat do you mean 2 requests per RPC call? There should only be one round trip for a normal RPC call.
1
B
happening in my Durable Objects "Live" logs. I'm seeing requests for an unrelated worker, that is a worker in a different project? It's a project that gets a lot of traffic compared to others, so I'm note sure if it is showing the traffic for all my workers or not. But there is a problem!
A
L
getCurrentBookmark() and getBookmarkForTime() return a Promise<string>, but the example right below it shows it being used without a promise:
GL
HLConfigures the Durable Object so that the next time it restarts, it should restore its storage to exactly match what the storage contained at the given bookmark. After calling this, the application should typically invoke ctx.abort() to restart the Durable Object, thus completing the point-in-time recovery.
onNextSessionRestoreBookmark works on the next restart, so you need to kill the DO for the restore to happen.await
Actx.waitUntil(doSomething())doSomething() as a result of the alarmLL
EActx.storage.get() returns a Promise.
I1
ctx.storage.kv.get() is the sync API (in SQLite DOs)1ctx.storage.get() is the old async APIA
.kv
S
L
environment and keep the script_name with the correct worker name does it work? The error says there isn't any worker with the name apiapi-staging.E
L
CEI
Nthis
B
promise!LE
JEGE
S
S
GLG
BGGG
getCurrentBookmark()getBookmarkForTime()Promise<string>onNextSessionRestoreBookmarkctx.waitUntil(doSomething())doSomething()ctx.storage.get()ctx.storage.get()ctx.storage.kv.get().kvenvironmentscript_nameapi-staginglet now = new Date();
// restore to 2 days ago
let bookmark = ctx.storage.getBookmarkForTime(now - 2);
ctx.storage.onNextSessionRestoreBookmark(bookmark);let bookmark = await getCurrentBookmark();
// stuff may happen here while it is awaiting
this.sql.exec(/* omitted */);let bookmark = await getCurrentBookmark();
// stuff may happen here while it is awaiting
this.sql.exec(/* omitted */);// Get a bookmark for the current state of the database. Note that since this is async, the
// bookmark will include any writes in the current atomic batch, including writes that are
// performed after this call begins. It could also include concurrent writes that haven't happened
// yet, unless blockConcurrencyWhile() is used to prevent them.
kj::Promise<kj::String> getCurrentBookmark();