Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSagaStore ¶
func NewSagaStore(svcName string, txProvider gbus.TxProvider) saga.Store
NewSagaStore creates a bew SagaStore
func NewTxProvider ¶
func NewTxProvider(connStr string) (gbus.TxProvider, error)
NewTxProvider returns a new PgProvider
Types ¶
type TxOutbox ¶
type TxOutbox struct { ID string // contains filtered or unexported fields }
TxOutbox is a mysql based transactional outbox
func NewOutbox ¶
func NewOutbox(svcName string, txProv gbus.TxProvider, purgeOnStartup bool) *TxOutbox
NewOutbox creates a new mysql transactional outbox
func (*TxOutbox) Save ¶
func (outbox *TxOutbox) Save(tx *sql.Tx, exchange, routingKey string, amqpMessage amqp.Publishing) error
Save stores a message in a DB to ensure delivery
Click to show internal directories.
Click to hide internal directories.