What is Turbine?

Turbine is a durable workflow engine for PocketBase. It runs entirely on SQLite — no external dependencies.

You define workflows as Go functions. Turbine handles persistence, retries, scheduling, and recovery.

Install

go get github.com/YakirOren/turbine

Use Cases

Background Jobs

Enqueue work to run asynchronously with concurrency control and rate limiting.

handle, err := turbine.Run(rt, SendEmail, recipient,
    turbine.WithQueue("emails"),
)

Multi-Step Pipelines

Each step checkpoints its result. If the process crashes, it resumes from the last completed step.

func OrderWorkflow(ctx turbine.Context, orderID string) (string, error) {
    charge, err := turbine.Do(ctx, ChargePayment, turbine.WithStepName("charge"))
    if err != nil {
        return "", err
    }

    _, err = turbine.Do(ctx, ShipOrder, turbine.WithStepName("ship"))
    if err != nil {
        return "", err
    }

    return fmt.Sprintf("order %s shipped (charge: %s)", orderID, charge), nil
}

Scheduled Tasks

Run workflows on a cron schedule using PocketBase's built-in scheduler.

turbine.Register(rt, DailyCleanup, turbine.WithSchedule("0 3 * * *"))

Human-in-the-Loop

Pause a workflow and wait for a human decision. Survives crashes and restarts.

result, err := turbine.WaitForApproval(ctx)
if !result.Approved {
    return "rejected: " + result.Comment, nil
}

Rate-Limited Queues

Control concurrency, enforce rate limits, and partition work across tenants.

rt.Queue("api-calls",
    turbine.WithWorkerConcurrency(5),
    turbine.WithRateLimiter(turbine.RateLimiter{Limit: 100, Period: time.Minute}),
    turbine.WithPartitionQueue(),
)

Features

Feature	Description
Durable Steps	Step results recorded in SQLite, replayed on recovery
Step Retries	Automatic retries with exponential backoff
Queues	Concurrency control, priority, rate limiting, partitioning
Scheduling	Cron expressions via PocketBase's built-in scheduler
Communication	Inter-workflow messaging and key-value events
Approvals	Human-in-the-loop approval gates
Products	File outputs from workflows
KV Store	Global persistent key-value storage
Webhooks	HTTP notifications on workflow completion
Dashboard	Built-in UI for monitoring workflows, queues, and schedules