feat(kinesis): add AWS Kinesis Stream resource and capabilities

[sam-goodwin]

Add AWS Kinesis Data Streams support with type-safe Lambda integration.

Stream Resource

import * as Kinesis from "alchemy-effect/aws/kinesis";
import * as S from "effect/Schema";

class EventStream extends Kinesis.Stream("EventStream", {
  schema: S.Struct({
    eventId: S.String,
    timestamp: S.Number,
  }),
  streamMode: "ON_DEMAND",
  retentionPeriod: 48,
}) {}

Consume Stream

import * as Lambda from "alchemy-effect/aws/lambda";

class Consumer extends Lambda.consumeStream("Consumer", {
  stream: EventStream,
  batchSize: 100,
  startingPosition: "LATEST",
  handle: Effect.fn(function* (event) {
    for (const record of event.Records) {
      console.log(record.kinesis.data.eventId);
    }
  }),
})({
  main: "./handler.ts",
  bindings: $(),
}) {}

Produce to Stream

class Producer extends Lambda.serve("Producer", {
  fetch: Effect.fn(function* () {
    yield* Kinesis.putRecord(
      EventStream,
      { eventId: "123", timestamp: Date.now() },
      { partitionKey: "user-1" },
    );
    return { statusCode: 200, body: "OK" };
  }),
})({
  main: "./handler.ts",
  bindings: $(Kinesis.PutRecord(EventStream)),
}) {}

🤖 Generated with Claude Code

[pkg-pr-new]

Open in StackBlitz

npm i https://pkg.pr.new/alchemy-run/alchemy-effect@30

commit: 6e90479