Documentation ¶
Index ¶
- func NewPostgresDB(ctx context.Context, cfg Config) (*pgxpool.Pool, error)
- type Config
- type Transaction
- func (T *Transaction) CommitTx(ctx context.Context) error
- func (T *Transaction) ExtractTx(ctx context.Context) (pgx.Tx, bool)
- func (T *Transaction) InjectTx(ctx context.Context) (context.Context, error)
- func (T *Transaction) RollbackTx(ctx context.Context) error
- func (T *Transaction) RollbackTxDefer(ctx context.Context)
- type UserDb
- func (u *UserDb) AddConverterPair(ctx context.Context, converterPair core.ConverterPair) (int, error)
- func (u *UserDb) AddConverterPairIfHasNot(ctx context.Context, converterPair core.ConverterPair) (int, error)
- func (u *UserDb) AddCurrency(ctx context.Context, currency core.FullCurrency) (int, error)
- func (u *UserDb) AddCurrencyIfHasNot(ctx context.Context, currency core.FullCurrency) (int, error)
- func (u *UserDb) AddUser(ctx context.Context, user core.AddUser) (int, error)
- func (u *UserDb) AddUserCurrency(ctx context.Context, userId int, currency core.FullCurrency) (int, error)
- func (u *UserDb) CheckConverterPair(ctx context.Context, converterPair core.ConverterPair) (int, error)
- func (u *UserDb) CheckCurrency(ctx context.Context, currency core.FullCurrency) (int, error)
- func (u *UserDb) DeleteUserCurrency(ctx context.Context, userId int, currency core.CurrencyCode) error
- func (u *UserDb) GetAvailableBanks(ctx context.Context, currency core.CurrencyCode) ([]..., error)
- func (u *UserDb) GetAvailableClassicCurrencies(ctx context.Context) ([]core.CurrencyCode, error)
- func (u *UserDb) GetAvailableCryptoCurrencies(ctx context.Context) ([]core.CurrencyCode, error)
- func (u *UserDb) GetConverterPairs(ctx context.Context) ([]core.ConverterPair, error)
- func (u *UserDb) GetCurrency(ctx context.Context, currencyId int) (*core.FullCurrency, error)
- func (u *UserDb) GetThresholdConvertPair(ctx context.Context, userId int) ([]core.ThresholdConvertPair, error)
- func (u *UserDb) GetUserConverterPairs(ctx context.Context, userId int) ([]core.ConverterPair, error)
- func (u *UserDb) GetUserCurrencies(ctx context.Context, userId int, currencyType *core.CurrencyType) ([]core.FullCurrency, error)
- func (u *UserDb) SetThresholdConvertPair(ctx context.Context, userId int, threshold core.ThresholdConvertPair) error
- func (u *UserDb) SetUserConverterPair(ctx context.Context, userId int, converterPair core.ConverterPair) (int, error)
- func (u *UserDb) ValidateUser(ctx context.Context, chatId int) (int, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Transaction ¶
type Transaction struct {
// contains filtered or unexported fields
}
func NewTransaction ¶
func NewTransaction(db db) *Transaction
func (*Transaction) RollbackTx ¶
func (T *Transaction) RollbackTx(ctx context.Context) error
func (*Transaction) RollbackTxDefer ¶
func (T *Transaction) RollbackTxDefer(ctx context.Context)
type UserDb ¶
type UserDb struct {
// contains filtered or unexported fields
}
func (*UserDb) AddConverterPair ¶
func (*UserDb) AddConverterPairIfHasNot ¶
func (*UserDb) AddCurrency ¶
func (*UserDb) AddCurrencyIfHasNot ¶
func (*UserDb) AddUserCurrency ¶
func (*UserDb) CheckConverterPair ¶
func (*UserDb) CheckCurrency ¶
func (*UserDb) DeleteUserCurrency ¶
func (*UserDb) GetAvailableBanks ¶
func (u *UserDb) GetAvailableBanks(ctx context.Context, currency core.CurrencyCode) ([]core. CurrencyBank, error)
func (*UserDb) GetAvailableClassicCurrencies ¶
func (*UserDb) GetAvailableCryptoCurrencies ¶
func (*UserDb) GetConverterPairs ¶
func (*UserDb) GetCurrency ¶
func (*UserDb) GetThresholdConvertPair ¶
func (*UserDb) GetUserConverterPairs ¶
func (*UserDb) GetUserCurrencies ¶
func (u *UserDb) GetUserCurrencies(ctx context.Context, userId int, currencyType *core.CurrencyType) ([]core.FullCurrency, error)
func (*UserDb) SetThresholdConvertPair ¶
func (*UserDb) SetUserConverterPair ¶
Click to show internal directories.
Click to hide internal directories.