Upstash provider

export UPSTASH_EMAIL="your-email"
export UPSTASH_API_KEY="your-api-key"

import alchemy from "alchemy";
import { RedisDatabase } from "alchemy/upstash";
import { Worker } from "alchemy/cloudflare";

const app = await alchemy("upstash-app");

// Create an Upstash Redis database
const redis = await RedisDatabase("cache", {
  name: "my-cache",
  region: "us-east-1",
  tls: true,
  eviction: true,
  maxDataSize: 100, // MB
});

// Use with Cloudflare Worker
const worker = await Worker("api", {
  entrypoint: "./src/index.ts",
  bindings: {
    REDIS_URL: redis.endpoint,
    REDIS_TOKEN: redis.token,
  },
});

console.log(`Redis endpoint: ${redis.endpoint}`);

await app.finalize();

import { KafkaCluster, KafkaTopic } from "alchemy/upstash";

// Create a Kafka cluster
const kafka = await KafkaCluster("events", {
  name: "event-stream",
  region: "us-east-1",
  multizone: true,
});

// Create topics
const userEvents = await KafkaTopic("user-events", {
  cluster: kafka,
  name: "user.events",
  partitions: 3,
  retentionTime: 604800000, // 7 days in ms
  retentionSize: 1073741824, // 1GB
});

const orderEvents = await KafkaTopic("order-events", {
  cluster: kafka,
  name: "order.events",
  partitions: 6,
});

console.log(`Kafka endpoint: ${kafka.endpoint}`);
console.log(`Topic: ${userEvents.name}`);

// In your Worker
export default {
  async fetch(request: Request, env: Env) {
    // Use @upstash/redis
    const { Redis } = await import("@upstash/redis/cloudflare");
    
    const redis = new Redis({
      url: env.REDIS_URL,
      token: env.REDIS_TOKEN,
    });
    
    await redis.set("key", "value");
    const value = await redis.get("key");
    
    return Response.json({ value });
  },
};

const redis = await RedisDatabase("global-cache", {
  name: "global-cache",
  region: "us-east-1",
  primaryRegion: "us-east-1",
  readRegions: ["eu-west-1", "ap-southeast-1"],
  tls: true,
});