user

Documentation

Index

• type DBTX
• type NullUserStatus
  • func (ns *NullUserStatus) Scan(value interface{}) error
  • func (ns NullUserStatus) Value() (driver.Value, error)
• type Querier
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) CreateSeller(ctx context.Context, email string, password string, fullName string, ...) (int64, error)
  • func (q *Queries) CreateUser(ctx context.Context, email string, password string, fullName string) (*User, error)
  • func (q *Queries) CreateUserWithPhone(ctx context.Context, email string, password string, fullName string, ...) (*User, error)
  • func (q *Queries) CreateUserWithStatus(ctx context.Context, email string, password string, fullName string, ...) (*User, error)
  • func (q *Queries) CreateUserWithStatusAndPhone(ctx context.Context, email string, password string, fullName string, ...) (*User, error)
  • func (q *Queries) GetUser(ctx context.Context, id int64) (*User, error)
  • func (q *Queries) GetUserByEmail(ctx context.Context, email string) (*User, error)
  • func (q *Queries) UpdateUserPassword(ctx context.Context, password string, iD int64) error
  • func (q *Queries) UpdateUserStatusByEmail(ctx context.Context, status UserStatus, email string) error
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type Repository
  • func NewRepository(pool *pgxpool.Pool) Repository
• type User
• type UserStatus
  • func (e *UserStatus) Scan(src interface{}) error

Types

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type NullUserStatus

type NullUserStatus struct {
	UserStatus UserStatus
	Valid      bool // Valid is true if UserStatus is not NULL
}

func (*NullUserStatus) Scan

func (ns *NullUserStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullUserStatus) Value

func (ns NullUserStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Querier

type Querier interface {
	CreateSeller(ctx context.Context, email string, password string, fullName string, status UserStatus) (int64, error)
	CreateUser(ctx context.Context, email string, password string, fullName string) (*User, error)
	CreateUserWithPhone(ctx context.Context, email string, password string, fullName string, phoneNumber *string) (*User, error)
	CreateUserWithStatus(ctx context.Context, email string, password string, fullName string, status UserStatus) (*User, error)
	CreateUserWithStatusAndPhone(ctx context.Context, email string, password string, fullName string, status UserStatus, phoneNumber *string) (*User, error)
	GetUser(ctx context.Context, id int64) (*User, error)
	GetUserByEmail(ctx context.Context, email string) (*User, error)
	UpdateUserPassword(ctx context.Context, password string, iD int64) error
	UpdateUserStatusByEmail(ctx context.Context, status UserStatus, email string) error
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CreateSeller

func (q *Queries) CreateSeller(ctx context.Context, email string, password string, fullName string, status UserStatus) (int64, error)

func (*Queries) CreateUser

func (q *Queries) CreateUser(ctx context.Context, email string, password string, fullName string) (*User, error)

func (*Queries) CreateUserWithPhone

func (q *Queries) CreateUserWithPhone(ctx context.Context, email string, password string, fullName string, phoneNumber *string) (*User, error)

func (*Queries) CreateUserWithStatus

func (q *Queries) CreateUserWithStatus(ctx context.Context, email string, password string, fullName string, status UserStatus) (*User, error)

func (*Queries) CreateUserWithStatusAndPhone

func (q *Queries) CreateUserWithStatusAndPhone(ctx context.Context, email string, password string, fullName string, status UserStatus, phoneNumber *string) (*User, error)

func (*Queries) GetUser

func (q *Queries) GetUser(ctx context.Context, id int64) (*User, error)

func (*Queries) GetUserByEmail

func (q *Queries) GetUserByEmail(ctx context.Context, email string) (*User, error)

func (*Queries) UpdateUserPassword

func (q *Queries) UpdateUserPassword(ctx context.Context, password string, iD int64) error

func (*Queries) UpdateUserStatusByEmail

func (q *Queries) UpdateUserStatusByEmail(ctx context.Context, status UserStatus, email string) error

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type Repository

type Repository interface {
	Querier
	ExecTx(ctx context.Context, fn func(tx pgx.Tx) error) error
	WithTx(tx pgx.Tx) *Queries
}

func NewRepository

func NewRepository(pool *pgxpool.Pool) Repository

type User

type User struct {
	ID          int64
	Email       string
	Password    string
	PhoneNumber *string
	FullName    string
	Status      UserStatus
	CreatedAt   pgtype.Timestamptz
	UpdatedAt   pgtype.Timestamptz
}

type UserStatus

type UserStatus string

const (
	UserStatusBlocked             UserStatus = "Blocked"
	UserStatusRegistrationPending UserStatus = "RegistrationPending"
	UserStatusActive              UserStatus = "Active"
)

func (*UserStatus) Scan

func (e *UserStatus) Scan(src interface{}) error