# README

Outbox

Workaround for resolving *sql.Tx from Gorm *gorm.DB:

err := gorm.DB.Transaction(func(tx *gorm.DB) error {
    pool := tx.Statement.ConnPool

    store.SaveTx(ctx, pool.(*sql.Tx), &outbox.Event{...})
})

The package includes a test suite that you can run with the go test command:

go test ./...

Contributions to go-outbox are welcome. Please submit a pull request or create an issue to discuss the changes you want to make.

go-outbox is licensed under the MIT License. See the LICENSE file for more information.

No description provided by the author

No description provided by the author

NewWorker builds a new worker instance.

Event is an event that is stored in the event store.

EventStore is responsible for storing and retrieving events.

Worker is responsible for periodically retrieving pending events from an event store dispatching them.

DispatchFunc is a function that is called for each event that is retrieved from the event store that has not been dispatched yet.