A Microservice Toolkit from The New York Times

An improved drop-in replacement for SQS

Vanus is a Serverless, event streaming system with processing capabilities. It easily connects SaaS, Cloud Services, and Databases to help users build next-gen Event-driven Applications.

Golang asynchronous task/job queue with Redis, SQS, IronMQ, and in-memory backends

Community driven, reusable components for distributed apps

Kubernetes autoscaler for the workers. Resource is called WPA. Queues Supported: SQS, Beanstalkd.

A Publish & Subscribe library, with pluggable providers and middleware for Golang

Go Wrapper for using localstack

Inspect messages in an AWS SQS queue in a simple and deliberate manner

Unlimited job queue for go, using a pool of concurrent workers processing the job queue entries

MQTT Proxy allows MQTT clients to send messages to other messaging systems

SQS Consumer Server for Go

Rin is a Redshift data Importer by SQS messaging.

BinWatch is a tool to subscribe to a MySQL binlog and track changes that occur in database tables. These changes are processed and sent to supported connectors in real-time.

A simple, lightweight Prometheus metrics exporter for AWS's Simple Queue Service, written in Go.

A SQS client library built with aws/aws-sdk-go-v2

☁️ Run AWS services locally — open-source alternative to LocalStack . S3, DynamoDB, Lambda, SQS, API Gateway and 12 more services in one command.

Web hooks for message queues

📤 In-memory implementation of SQS ideal for unit testing.