storage

Documentation

Index

• type DBQuery
• type PostgresStorage
  • func NewPostgresStorage(dsn string) (*PostgresStorage, error)
  • func (p *PostgresStorage) Ping(ctx context.Context) error
• type SessionManager
  • func NewSessionStorage() SessionManager
• type SessionStorage
  • func (s *SessionStorage) Add(token string, expire time.Time)
  • func (s *SessionStorage) IsValid(token string) bool
• type Transaction
  • func NewTransaction(db DBQuery) (*Transaction, error)
  • func (t *Transaction) AddError(e error)
  • func (t *Transaction) Commit() error
  • func (t *Transaction) Error() []error
  • func (t *Transaction) QueryRowContext(ctx context.Context, query string, args ...any) (*sql.Row, error)
  • func (t *Transaction) Rollback() error
  • func (t *Transaction) Tx() *sql.Tx
• type TxDBQuery

Types

type DBQuery

type DBQuery interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	PingContext(ctx context.Context) error
	Begin() (*sql.Tx, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
	Prepare(query string) (*sql.Stmt, error)
}

type PostgresStorage

type PostgresStorage struct {
	DB    DBQuery
	RawDB *sql.DB
	// contains filtered or unexported fields
}

func NewPostgresStorage

func NewPostgresStorage(dsn string) (*PostgresStorage, error)

NewPostgresStorage PostgresStorage настройка подключения к БД

func (*PostgresStorage) Ping

func (p *PostgresStorage) Ping(ctx context.Context) error

type SessionManager

type SessionManager interface {
	Add(token string, expire time.Time)
	IsValid(token string) bool
}

func NewSessionStorage

func NewSessionStorage() SessionManager

type SessionStorage

type SessionStorage struct {
	// contains filtered or unexported fields
}

SessionStorage данные по авторизованным пользователям

func (*SessionStorage) Add

func (s *SessionStorage) Add(token string, expire time.Time)

func (*SessionStorage) IsValid

func (s *SessionStorage) IsValid(token string) bool

type Transaction

type Transaction struct {
	// contains filtered or unexported fields
}

func NewTransaction

func NewTransaction(db DBQuery) (*Transaction, error)

NewTransaction Открывает новую транзакцию

func (*Transaction) AddError

func (t *Transaction) AddError(e error)

func (*Transaction) Commit

func (t *Transaction) Commit() error

func (*Transaction) Error

func (t *Transaction) Error() []error

func (*Transaction) QueryRowContext

func (t *Transaction) QueryRowContext(ctx context.Context, query string, args ...any) (*sql.Row, error)

func (*Transaction) Rollback

func (t *Transaction) Rollback() error

func (*Transaction) Tx

func (t *Transaction) Tx() *sql.Tx

type TxDBQuery

type TxDBQuery interface {
	QueryRowContext(ctx context.Context, query string, args ...any) (*sql.Row, error)
	Rollback() error
	Commit() error
	Tx() *sql.Tx
	Error() []error
	AddError(e error)
}