Why fastlane?

fastlane is a redis-based queueing service that outsmarts everyone else by using containers.

More seriously, though, fastlane allows you to easily implement new workers in the form of containers.

Instead of the tedious, repetitive work of yesteryear where you had to implement a worker in language X or Y, you just spin a new container with all the dependencies you require already previously installed, and instruct fastlane to run a command in that container. Bang! Instant Super-Powered Workers!

Features

• [x] Ad-Hoc execution of jobs (run job right now)
• [x] Scheduled execution of jobs (run job next sunday at 6am, or run in 10 minutes from now);
• [x] Crontab execution of jobs (run job at */10 * * * * - every ten minutes);
• [x] Allows job details to be updated;
• [x] API to retrieve tasks, /tasks;
• [x] API to retrieve task details, /tasks/my-task (<taskUrl>);
• [x] API to retrieve job details, <taskUrl>/jobs/<jobId> (<jobUrl>);
• [x] API to stop running job (<jobUrl>/stop);
• [x] API to retry job (<jobUrl>/retry);
• [x] API to get logs(<jobUrl>/logs), stdout (<jobUrl>/stdout) and stderr (<jobUrl>/stderr) for last execution in jobs;
• [x] Job log output streaming using WebSockets (ws://<jobUrl>/ws) and <jobUrl>/stream;
• [x] API to retrieve execution details, <jobUrl>/executions/<executionId> (<executionUrl>);
• [x] API to stop execution, <executionUrl>/stop;
• [x] API to get logs(<executionUrl>/stdout), stdout (<executionUrl>/stdout) and stderr (<executionUrl>/stderr) for execution;
• [x] Job execution log output streaming using WebSockets (ws://<executionUrl>/ws) and <executionUrl>/stream;
• [x] Additional Job Metadata (useful for webhooks);
• [x] Configurable retries per job;
• [x] Configurable exponential back-off for retries and failures in monitoring of jobs;
• [x] Configurable hard timeout for each execution;
• [x] E-mail subscription to tasks;
• [x] Healthcheck of the MongoDB and Redis Connections;
• [ ] Web hooks on job start;
• [x] Web hooks on job completion;
• [x] Redact any env that contains blacklisted keywords;
• [ ] Exponential back-off parameters per job;
• [x] Self-healing handling of interrupted jobs;
• [x] Workers should handle SIGTERM and exit gracefully;
• [x] Docker Container Runner (with docker host pool);
• [x] Docker Pool per task name (Regular Expressions);
• [x] Rename docker containers after processing their details;
• [x] Command to prune processed containers;
• [x] Routes to remove/put back docker host in job balancing;
• [ ] Docker SSL connections;
• [ ] Circuit breaking when docker host is unavailable;
• [x] Container Environment Variables per Job;
• [x] Configurable global limit for number of running jobs per task name (Regular Expressions);
• [ ] Limit of concurrent job executions per task;
• [ ] Kubernetes Container Runner;
• [x] MongoDB Task and Job Storage;
• [x] Structured Logging;
• [x] Monitoring of job completion;
• [x] Job Expiration;
• [x] Status Page with details on the farm status (executors, scheduled tasks and queue sizes);
• [x] Error handling mechanism (Sentry built-in, extensible)
• [ ] Per-job Error handling mechanism (Sentry built-in, extensible)
• [ ] Usage metrics (extensible);
• [x] Support Redis and Redis Sentinel;
• [ ] Support Redis Cluster;
• [ ] Comprehensive test coverage;
• [x] CORS headers in every API request (configurable);
• [x] Basic Auth support;
• [x] gzip all JSON responses for the API (for requests that accept gzip);
• [x] Store IP address of enqueued job for auditing (X-Real-IP, then X-Forwarded-For, then request.addr);
• [ ] Admin to inspect tasks and jobs.

Getting started

Do not leave!!! It takes only 5 minutes to get fastlane working.

License

fastlane is MIT licensed.

Contributions

Logo was created by Artur Sousa.