Effect-TS powered task scheduling for
Cloudflare Durable Objects

      import { ReliableScheduler, SchedulerService } from 'ironalarm';
import { Effect } from 'effect';

export class MyDO {
  private scheduler: ReliableScheduler;

  constructor(state: DurableObjectState, env: any) {
    // Initialize with DO storage + concurrency limits
    this.scheduler = new ReliableScheduler(state.storage, {
      maxConcurrentTasks: 10
    });

    // Register Effect-powered task handler with dependency injection
    this.scheduler.register('my-task', (taskId, params) => {
      return Effect.gen(function* () {
        const svc = yield* SchedulerService;

        const started = yield* svc.getCheckpoint(taskId, 'started');
        if (!started) {
          yield* Effect.promise(() => doWork(params));
          yield* svc.checkpoint(taskId, 'started', true);
        }

        yield* svc.completeTask(taskId);
        yield* Effect.log('Task completed successfully');
      });
    });
  }

  async alarm() {
    // Process due tasks with structured concurrency
    await Effect.runPromise(this.scheduler.alarm());
  }
}