postgres

Documentation

Index

• Variables
• func NewPool(dsn string) *pgxpool.Pool
• func NewRolesRepository(db *pgxpool.Pool) repository.RolesRepository
• func NewUsersRepository(db *pgxpool.Pool) repository.UsersRepository
• type RolesRepository
  • func (r *RolesRepository) RolesById(ctx context.Context, id string) ([]string, error)
  • func (r *RolesRepository) RolesPermissions(ctx context.Context, roles []string) ([]string, error)
• type UsersRepository
  • func (r *UsersRepository) AssignRoleById(ctx context.Context, id string, role string) error
  • func (r *UsersRepository) Delete(ctx context.Context, id string) error
  • func (r *UsersRepository) FindByEmail(ctx context.Context, email string) (*entities.User, error)
  • func (r *UsersRepository) FindById(ctx context.Context, id string) (*entities.User, error)
  • func (r *UsersRepository) RevokeRoleById(ctx context.Context, id string, role string) error
  • func (r *UsersRepository) Save(ctx context.Context, user *entities.User) error
  • func (r *UsersRepository) Update(ctx context.Context, user *entities.User) error

Variables

var (
	ErrNotFound        = errors.New("not found")
	ErrAlreadyExists   = errors.New("already exists")
	ErrInternalFailure = errors.New("internal failure") // FIXME пока-что не юзаю, а смысл?
)

Functions

func NewPool

func NewPool(dsn string) *pgxpool.Pool

func NewRolesRepository

func NewRolesRepository(db *pgxpool.Pool) repository.RolesRepository

func NewUsersRepository

func NewUsersRepository(db *pgxpool.Pool) repository.UsersRepository

Types

type RolesRepository

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

func (*RolesRepository) RolesById

func (r *RolesRepository) RolesById(ctx context.Context, id string) ([]string, error)

func (*RolesRepository) RolesPermissions

func (r *RolesRepository) RolesPermissions(ctx context.Context, roles []string) ([]string, error)

type UsersRepository

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

func (*UsersRepository) AssignRoleById

func (r *UsersRepository) AssignRoleById(ctx context.Context, id string, role string) error

func (*UsersRepository) Delete

func (r *UsersRepository) Delete(ctx context.Context, id string) error

SOFT-DELETION METHOD

func (*UsersRepository) FindByEmail

func (r *UsersRepository) FindByEmail(ctx context.Context, email string) (*entities.User, error)

func (*UsersRepository) FindById

func (r *UsersRepository) FindById(ctx context.Context, id string) (*entities.User, error)

func (*UsersRepository) RevokeRoleById

func (r *UsersRepository) RevokeRoleById(ctx context.Context, id string, role string) error

func (*UsersRepository) Save

func (r *UsersRepository) Save(ctx context.Context, user *entities.User) error

func (*UsersRepository) Update

func (r *UsersRepository) Update(ctx context.Context, user *entities.User) error