repository

Documentation

Index

• type Order
• type OrderRepoWith2PC
• type PsqlRepository
  • func NewPsqlRepository(db *sqlx.DB) *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

Types

type Order

type Order struct {
	ID        uuid.UUID `db:"id"`
	UserID    uuid.UUID `db:"user_id"`
	Label     string    `db:"label"`
	CreatedAt time.Time `db:"created_at"`
}

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 (p *PsqlRepository) CommitInsertTransaction(ctx context.Context, txID uuid.UUID) error

func (*PsqlRepository) GetOrder

func (p *PsqlRepository) GetOrder(ctx context.Context, id uuid.UUID) (*Order, error)

func (*PsqlRepository) PrepareInsertOrder

func (p *PsqlRepository) PrepareInsertOrder(ctx context.Context, order *Order, txID uuid.UUID) (err error)

func (*PsqlRepository) RollbackInsertTransaction

func (p *PsqlRepository) RollbackInsertTransaction(ctx context.Context, txID uuid.UUID) error