​

KV Storage

​

Use Cases

• Store small lookup tables.
• Track recently seen identifiers.
• Keep compact feed state.
• Share simple values across executions.

​

Filter Access

const kv = require("@atria/kv");

async function main(stream) {
  const bucket = kv.bucket("seen-transfers");
  await bucket.add(stream.metadata.blockNumber, true);
  return null;
}

​

Bucket Operations

​

Add Values

await bucket.add("key", { value: 1 });
await bucket.addMany([
  { key: "a", value: { value: 1 } },
  { key: "b", value: { value: 2 } }
]);

• add(key, value): stores one value by key.
• addMany(items): stores multiple key-value items in one call.

​

Read Values

const item = await bucket.get("key");
const items = await bucket.getMany(["a", "b"]);

• get(key): returns one value, or null when no value exists.
• getMany(keys): returns multiple values for the provided keys.

​

Remove Values

await bucket.remove("key");
await bucket.removeMany(["a", "b"]);

• remove(key): removes one key.
• removeMany(keys): removes multiple keys.

​

List Values

const page = await bucket.list({
  limit: 100,
  cursor: ""
});

• list({ limit, cursor }): returns a page of bucket values.
• limit controls the maximum number of values returned.
• cursor is used to continue from a previous page.

​

Use Carefully