Documentation ¶
Index ¶
- type Order
- type OrderRepoWith2PC
- type PsqlRepository
- func (p *PsqlRepository) CommitInsertTransaction(ctx context.Context, txID uuid.UUID) error
- func (p *PsqlRepository) GetOrder(ctx context.Context, id uuid.UUID) (*Order, error)
- func (p *PsqlRepository) PrepareInsertOrder(ctx context.Context, order *Order, txID uuid.UUID) (err error)
- func (p *PsqlRepository) RollbackInsertTransaction(ctx context.Context, txID uuid.UUID) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OrderRepoWith2PC ¶
type OrderRepoWith2PC interface { PrepareInsertOrder(ctx context.Context, order *Order, txId uuid.UUID) error CommitInsertTransaction(ctx context.Context, txID uuid.UUID) error RollbackInsertTransaction(ctx context.Context, txID uuid.UUID) error GetOrder(ctx context.Context, id uuid.UUID) (*Order, error) }
type PsqlRepository ¶
type PsqlRepository struct {
// contains filtered or unexported fields
}
func NewPsqlRepository ¶
func NewPsqlRepository(db *sqlx.DB) *PsqlRepository
func (*PsqlRepository) CommitInsertTransaction ¶
func (*PsqlRepository) PrepareInsertOrder ¶
func (*PsqlRepository) RollbackInsertTransaction ¶
Click to show internal directories.
Click to hide internal directories.