Documentation
¶
Index ¶
- type Transaction
- func (t Transaction) Close()
- func (t Transaction) SagaSaveTx(ctx context.Context, input types.PayloadType) error
- func (t Transaction) SagaUpdateInfos(ctx context.Context, ID uuid.UUID, retry int, status string) error
- func (t Transaction) SaveTx(ctx context.Context, input types.PayloadType) error
- func (t Transaction) UpdateInfos(ctx context.Context, ID uuid.UUID, retry int, status string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Transaction ¶
type Transaction struct {
// contains filtered or unexported fields
}
func NewPgAdapter ¶
func NewPgAdapter(connStr string) (*Transaction, error)
func (Transaction) Close ¶
func (t Transaction) Close()
func (Transaction) SagaSaveTx ¶
func (t Transaction) SagaSaveTx(ctx context.Context, input types.PayloadType) error
func (Transaction) SagaUpdateInfos ¶
func (Transaction) SaveTx ¶
func (t Transaction) SaveTx(ctx context.Context, input types.PayloadType) error
func (Transaction) UpdateInfos ¶
Source Files
Click to show internal directories.
Click to hide internal directories.