Documentation
¶
Index ¶
- Constants
- Variables
- type PostgresQuerier
- func (q *PostgresQuerier) CheckTransactionID(ctx context.Context, transactionId string) (bool, error)
- func (q *PostgresQuerier) Close()
- func (q *PostgresQuerier) InsertGameResult(ctx context.Context, txn sqlx.Tx, gameResult entity.GameResult) (int, error)
- func (q *PostgresQuerier) LockUserRow(ctx context.Context, txn sqlx.Tx, userId uuid.UUID) error
- func (q *PostgresQuerier) SelectGameResultsByUser(ctx context.Context, userId uuid.UUID, ...) ([]entity.GameResult, error)
- func (q *PostgresQuerier) SelectUser(ctx context.Context, userId uuid.UUID) (*entity.User, error)
- func (q *PostgresQuerier) SelectUsersByValidationStatus(ctx context.Context, validationStatus bool) ([]entity.User, error)
- func (q *PostgresQuerier) UpdateGameResult(ctx context.Context, txn sqlx.Tx, gameResultId int, ...) error
- func (q *PostgresQuerier) UpdateUserBalance(ctx context.Context, txn sqlx.Tx, userId uuid.UUID, balance float64, ...) error
- func (q *PostgresQuerier) WithTransaction(ctx context.Context, fn func(*sqlx.Tx) error) (err error)
- type Querier
Constants ¶
View Source
const ( CustomMigrationParam = "x-migrations-table" CustomMigrationValue = "schema_migrations" )
Variables ¶
View Source
var (
ErrorNilUUID = errors.New("UUID is nil")
)
Functions ¶
This section is empty.
Types ¶
type PostgresQuerier ¶
type PostgresQuerier struct {
// contains filtered or unexported fields
}
func NewPostgresQuerier ¶
func NewPostgresQuerier(ctx context.Context, url string) (*PostgresQuerier, error)
func (*PostgresQuerier) CheckTransactionID ¶
func (*PostgresQuerier) Close ¶
func (q *PostgresQuerier) Close()
func (*PostgresQuerier) InsertGameResult ¶
func (q *PostgresQuerier) InsertGameResult(ctx context.Context, txn sqlx.Tx, gameResult entity.GameResult) (int, error)
func (*PostgresQuerier) LockUserRow ¶
func (*PostgresQuerier) SelectGameResultsByUser ¶
func (q *PostgresQuerier) SelectGameResultsByUser(ctx context.Context, userId uuid.UUID, validationStatus entity.ValidationStatus) ([]entity.GameResult, error)
func (*PostgresQuerier) SelectUser ¶
func (*PostgresQuerier) SelectUsersByValidationStatus ¶
func (*PostgresQuerier) UpdateGameResult ¶
func (q *PostgresQuerier) UpdateGameResult(ctx context.Context, txn sqlx.Tx, gameResultId int, validationStatus entity.ValidationStatus) error
func (*PostgresQuerier) UpdateUserBalance ¶
func (*PostgresQuerier) WithTransaction ¶
WithTransaction creates a new transaction and handles rollback/commit based on the error object returned by the `TxFn`
type Querier ¶
type Querier interface {
Close()
WithTransaction(ctx context.Context, fn func(*sqlx.Tx) error) (err error)
InsertGameResult(ctx context.Context, txn sqlx.Tx, gameResult entity.GameResult) (int, error)
LockUserRow(ctx context.Context, txn sqlx.Tx, userId uuid.UUID) error
SelectUser(ctx context.Context, userId uuid.UUID) (*entity.User, error)
SelectUsersByValidationStatus(ctx context.Context, validationStatus bool) ([]entity.User, error)
CheckTransactionID(ctx context.Context, transactionId string) (bool, error)
SelectGameResultsByUser(ctx context.Context, userId uuid.UUID, validationStatus entity.ValidationStatus) ([]entity.GameResult, error)
UpdateUserBalance(ctx context.Context, txn sqlx.Tx, userId uuid.UUID, balance float64, validationStatus bool) error
UpdateGameResult(ctx context.Context, txn sqlx.Tx, gameResultId int, validationStatus entity.ValidationStatus) error
}
Source Files
Click to show internal directories.
Click to hide internal directories.