postgres

Documentation

Overview

services/User/internal/adapters/postgres/user_repository.go

Index

• type UserRepository
  • func NewUserRepository(pool *pgxpool.Pool) *UserRepository
  • func (r *UserRepository) FindByEmail(ctx context.Context, email string) (*user.UserAggregate, error)
  • func (r *UserRepository) MarkVerified(ctx context.Context, userID uuid.UUID) error
  • func (r *UserRepository) Save(ctx context.Context, agg *user.UserAggregate) error
• type VerificationTokenRepository
  • func NewVerificationTokenRepository(pool *pgxpool.Pool) *VerificationTokenRepository
  • func (r *VerificationTokenRepository) CreateToken(ctx context.Context, userID uuid.UUID, token string, expires time.Time) error
  • func (r *VerificationTokenRepository) DeleteToken(ctx context.Context, token string) error
  • func (r *VerificationTokenRepository) GetUserIDByToken(ctx context.Context, token string) (uuid.UUID, error)

Types

type UserRepository

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

func NewUserRepository

func NewUserRepository(pool *pgxpool.Pool) *UserRepository

func (*UserRepository) FindByEmail

func (r *UserRepository) FindByEmail(ctx context.Context, email string) (*user.UserAggregate, error)

func (*UserRepository) MarkVerified

func (r *UserRepository) MarkVerified(ctx context.Context, userID uuid.UUID) error

func (*UserRepository) Save

func (r *UserRepository) Save(ctx context.Context, agg *user.UserAggregate) error

type VerificationTokenRepository

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

func NewVerificationTokenRepository

func NewVerificationTokenRepository(pool *pgxpool.Pool) *VerificationTokenRepository

func (*VerificationTokenRepository) CreateToken

func (r *VerificationTokenRepository) CreateToken(ctx context.Context, userID uuid.UUID, token string, expires time.Time) error

func (*VerificationTokenRepository) DeleteToken

func (r *VerificationTokenRepository) DeleteToken(ctx context.Context, token string) error

func (*VerificationTokenRepository) GetUserIDByToken

func (r *VerificationTokenRepository) GetUserIDByToken(ctx context.Context, token string) (uuid.UUID, error)