Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Executor ¶
type Executor interface {
Exec(query string, args ...any) (sql.Result, error)
ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
Query(query string, args ...any) (*sql.Rows, error)
QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
QueryRow(query string, args ...any) *sql.Row
QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
Prepare(query string) (*sql.Stmt, error)
PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
}
type TextRepository ¶
type TextRepository struct {
// contains filtered or unexported fields
}
func NewTextRepository ¶
func NewTextRepository(transactor repoTransactor, errorExpected bool) *TextRepository
type Transactor ¶
type Transactor struct {
*oniontx.Transactor[*Wrapper, *TxWrapper]
}
Transactor manage a transaction for single [pgx.Conn] instance.
func NewTransactor ¶
func NewTransactor(db *sqlx.DB) *Transactor
NewTransactor returns new Transactor (sqlx implementation).
func (*Transactor) GetExecutor ¶
func (t *Transactor) GetExecutor(ctx context.Context) Executor
GetExecutor returns Executor implementation (*sqlx.DB or *sqlx.Tx default wrappers).
func (*Transactor) TryGetTx ¶
TryGetTx returns pointer of sqlx.Tx and "true" from context.Context or return `false`.
func (*Transactor) TxBeginner ¶
func (t *Transactor) TxBeginner() *sqlx.DB
TxBeginner returns pointer of sqlx.DB.
type TxWrapper ¶
TxWrapper wraps sqlx.Tx and implements oniontx.Tx
type UseCase ¶
type UseCase struct {
// contains filtered or unexported fields
}
func NewUseCase ¶
func NewUseCase(textRepoA repository, textRepoB repository, transactor transactor) *UseCase
type UseCases ¶
type UseCases struct {
// contains filtered or unexported fields
}
func NewUseCases ¶
func NewUseCases(useCaseA useCase, useCaseB useCase, transactor transactor) *UseCases
Click to show internal directories.
Click to hide internal directories.