T
B
L
LAre there any plans for read replicas for DOs?Yes, once D1 read replication is Generally Available, we will open up replicas for DOs too (or around that time), since the underlying infrastructure is the same. D1 read replication uses DO read replicas.
B
J
1
Deletes are counted as rows written.
B
just finishing an internal audit before we releaseJJBJ
PL If there isn't an ETA, you cannot miss it.L
deleteAll() which effectively removes DO is treated the same or not.
GProxyReadTimeout is defined here: https://developers.cloudflare.com/api/resources/zones/subresources/settings/models/proxy_read_timeout/
MLML
N
LL
INI
1M
wrangler
AMMAAMAAMAMAMMAMI
AL
Deletes are counted as rows written.deleteAll()ProxyReadTimeoutimport { DurableObject } from 'cloudflare:workers';
export class Aggregator extends DurableObject { /* ... */ }
export default { async fetch() { /* ... */ } }// Export Durable Object
export { MyDurable } from './durables/MyDurable.js'; "durable_objects": {
"bindings": [
{
"name": "MY_DURABLE",
"class_name": "MyDurable"
}
]import { DurableObject } from 'cloudflare:workers';
let LOCK_TIMEOUT = 5000; // 5 seconds
let RATE_LIMIT_WINDOW = 200; // 200 milliseconds, now using stamina in cast system
// UserLock.js
export default class RateLimitkDurableObject extends DurableObject {
constructor(state, env) {
super(state, env);
this.state = state;
this.env = env;
}
async acquireLock() {
// Check if user is locked
const isLocked = await this.state.storage.get("isLocked");
if (isLocked) {
// check lastInteraction
const lastInteraction = (await this.state.storage.get("lastInteraction")) || 0;
if (Date.now() - lastInteraction < LOCK_TIMEOUT) {
throw new Error("User is currently locked");
}
}
// Check rate limit (e.g., 1 request per 15 seconds)
const lastInteraction = (await this.state.storage.get("lastInteraction")) || 0;
const now = Date.now();
const rateLimitWindow = RATE_LIMIT_WINDOW;
if (now - lastInteraction < rateLimitWindow) {
let timeLeft = Math.ceil((rateLimitWindow - (now - lastInteraction)) / 1000);
throw new Error(`Please try again in ${timeLeft} seconds.`);
}
// Acquire lock and update last interaction time
await this.state.storage.put("isLocked", true);
await this.state.storage.put("lastInteraction", now);
return { status: "Lock acquired" };
}
async releaseLock() {
// Release lock
console.log("Releasing lock for user");
await this.state.storage.put("isLocked", false);
return { status: "Lock released" };
}
}