outboxer

Documentation

Overview

Package outboxer implements a worker for the transactional outbox pattern: it reads events from a PostgreSQL table and publishes them to Google Pub/Sub or AWS SQS.

Index

• func Run(ctx context.Context, args []string) error

Functions

func Run

func Run(ctx context.Context, args []string) error

Run loads configuration, connects to the database and the enabled queue backends, and processes the outbox until the context is cancelled. It returns an error for any fatal startup or configuration problem.