Documentation
¶
Overview ¶
Package axmysql provides MySQL-backed implementations of various interfaces consumed by Ax.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var DelayedMessageRepository delayedmessage.Repository = mysqldelayedmessage.Repository{}
DelayedMessageRepository is an delayed message repository backed by a MySQL database.
var MessageStore messagestore.GloballyOrderedStore = mysqlmessagestore.Store{}
MessageStore is a message store backed by a MySQL database.
var OutboxRepository outbox.Repository = mysqloutbox.Repository{}
OutboxRepository is an outbox repository backed by a MySQL database.
var ProjectionOffsetStore projection.OffsetStore = mysqlprojection.OffsetStore{}
ProjectionOffsetStore is an offset store backed by a MySQL database.
var SagaCRUDRepository crud.Repository = saga.CRUDRepository{}
SagaCRUDRepository is a CRUD saga repository backed by a MySQL database.
var SagaKeySetRepository keyset.Repository = saga.KeySetRepository{}
SagaKeySetRepository is a key-set repository backed by a MySQL database.
var SagaSnapshotRepository eventsourcing.SnapshotRepository = saga.SnapshotRepository{}
SagaSnapshotRepository is a saga snapshot repository backed by a MySQL database.
Functions ¶
func GetDB ¶
GetDB returns the SQL database contained in ctx.
It panics if ctx does not contain a MySQL-specific SQL database.
func GetTx ¶
GetTx returns the SQL transaction contained in ctx.
It panics if ctx does not contain a MySQL-specific SQL transaction.
func NewDataStore ¶
func NewDataStore(db *sql.DB) persistence.DataStore
NewDataStore returns a new data store that is backed by a MySQL database.
func NewReadModelProjector ¶
func NewReadModelProjector(rm mysqlprojection.ReadModel) projection.Projector
NewReadModelProjector returns a new projector that builds a MySQL based read-model from a stream of events.
Types ¶
This section is empty.
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package delayedmessage provides MySQL-specific implementations of the interfaces in Ax's top-level "delayedmessage" package.
|
Package delayedmessage provides MySQL-specific implementations of the interfaces in Ax's top-level "delayedmessage" package. |
|
internal
|
|
|
envelopestore
Package envelopestore provides common implementation used by repositories that persist outbound envelopes.
|
Package envelopestore provides common implementation used by repositories that persist outbound envelopes. |
|
Package messagestore provides MySQL-specific implementations of the interfaces in Ax's top-level "messagestore" package.
|
Package messagestore provides MySQL-specific implementations of the interfaces in Ax's top-level "messagestore" package. |
|
Package outbox provides MySQL-specific implementations of the interfaces in Ax's top-level "outbox" package.
|
Package outbox provides MySQL-specific implementations of the interfaces in Ax's top-level "outbox" package. |
|
Package persistence provides MySQL-specific implementations of the interfaces in Ax's top-level "persistence" package.
|
Package persistence provides MySQL-specific implementations of the interfaces in Ax's top-level "persistence" package. |
|
Package saga provides MySQL-specific implementations of the interfaces in Ax's top-level "saga" package.
|
Package saga provides MySQL-specific implementations of the interfaces in Ax's top-level "saga" package. |