package repository

import "github.com/go-arrower/arrower/contexts/auth/internal/interfaces/repository"

Index

Variables 

var ErrMissingConnection = errors.New("missing db connection")

Types

type MemoryRepository 

type MemoryRepository struct {
	*repository.MemoryRepository[domain.User, domain.ID]
	// contains filtered or unexported fields
}

func NewUserMemoryRepository 

func NewUserMemoryRepository() *MemoryRepository

func (*MemoryRepository) All 

func (repo *MemoryRepository) All(ctx context.Context, filter domain.Filter) ([]domain.User, error)

func (*MemoryRepository) CreateVerificationToken 

func (repo *MemoryRepository) CreateVerificationToken(
	_ context.Context,
	token domain.VerificationToken,
) error

func (*MemoryRepository) ExistsByLogin 

func (repo *MemoryRepository) ExistsByLogin(ctx context.Context, login domain.Login) (bool, error)

func (*MemoryRepository) FindByLogin 

func (repo *MemoryRepository) FindByLogin(ctx context.Context, login domain.Login) (domain.User, error)

func (*MemoryRepository) VerificationTokenByToken 

func (repo *MemoryRepository) VerificationTokenByToken(
	_ context.Context,
	tokenID uuid.UUID,
) (domain.VerificationToken, error)

type PostgresRepository 

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

func NewUserPostgresRepository 

func NewUserPostgresRepository(pg *pgxpool.Pool) (*PostgresRepository, error)

func (*PostgresRepository) All 

func (repo *PostgresRepository) All(ctx context.Context, filter domain.Filter) ([]domain.User, error)

func (*PostgresRepository) Count 

func (repo *PostgresRepository) Count(ctx context.Context) (int, error)

func (*PostgresRepository) CreateVerificationToken 

func (repo *PostgresRepository) CreateVerificationToken(
	ctx context.Context,
	token domain.VerificationToken,
) error

func (*PostgresRepository) Delete 

func (repo *PostgresRepository) Delete(ctx context.Context, usr domain.User) error

func (*PostgresRepository) DeleteAll 

func (repo *PostgresRepository) DeleteAll(ctx context.Context) error

func (*PostgresRepository) DeleteByID 

func (repo *PostgresRepository) DeleteByID(ctx context.Context, userID domain.ID) error

func (*PostgresRepository) DeleteByIDs 

func (repo *PostgresRepository) DeleteByIDs(ctx context.Context, ids []domain.ID) error

func (*PostgresRepository) ExistsByID 

func (repo *PostgresRepository) ExistsByID(ctx context.Context, id domain.ID) (bool, error)

func (*PostgresRepository) ExistsByLogin 

func (repo *PostgresRepository) ExistsByLogin(ctx context.Context, login domain.Login) (bool, error)

func (*PostgresRepository) FindByID 

func (repo *PostgresRepository) FindByID(ctx context.Context, id domain.ID) (domain.User, error)

func (*PostgresRepository) FindByLogin 

func (repo *PostgresRepository) FindByLogin(ctx context.Context, login domain.Login) (domain.User, error)

func (*PostgresRepository) Save 

func (repo *PostgresRepository) Save(ctx context.Context, usr domain.User) error

func (*PostgresRepository) SaveAll 

func (repo *PostgresRepository) SaveAll(ctx context.Context, users []domain.User) error

func (*PostgresRepository) VerificationTokenByToken 

func (repo *PostgresRepository) VerificationTokenByToken(
	ctx context.Context,
	tokenID uuid.UUID,
) (domain.VerificationToken, error)

Source Files

mapping.go user.inmemory.repository.go user.postgres.repository.go

Directories

PathSynopsis
contexts/auth/internal/interfaces/repository/models
Version
v0.0.0-20250311203644-ab26c1152cb4 (latest)
Published
Mar 11, 2025
Platform
linux/amd64
Imports
13 packages
Last checked
1 week ago –

Tools for package owners.