repository

Documentation

Index

• Constants
• type MongoAdapter
  • func (m MongoAdapter) Confirm(ctx context.Context, udb *models.UserDBModel) error
  • func (m MongoAdapter) Exists(ctx context.Context, udb *models.UserDBModel) (bool, error)
  • func (m MongoAdapter) FindAll(ctx context.Context, user *models.UserDBModel) ([]models.UserDBModel, error)
  • func (m MongoAdapter) FindOne(ctx context.Context, user *models.UserDBModel) (*models.UserDBModel, error)
  • func (m MongoAdapter) GetOrCreate(ctx context.Context, id int64) (*models.UserDBModel, error)
  • func (m MongoAdapter) Save(ctx context.Context, user *models.UserDBModel) error
  • func (m MongoAdapter) Update(ctx context.Context, user models.UserDBModel) error
  • func (m MongoAdapter) UpdateLastLogin(ctx context.Context, user *models.UserDBModel) error
• type RedisAdapter
  • func (r RedisAdapter) Confirm(ctx context.Context, udb *models.UserDBModel) error
  • func (r RedisAdapter) Exists(ctx context.Context, udb *models.UserDBModel) (bool, error)
  • func (r RedisAdapter) FindAll(ctx context.Context, user *models.UserDBModel) ([]models.UserDBModel, error)
  • func (r RedisAdapter) FindOne(ctx context.Context, user *models.UserDBModel) (*models.UserDBModel, error)
  • func (r RedisAdapter) GetOrCreate(ctx context.Context, id int64) (*models.UserDBModel, error)
  • func (r RedisAdapter) Save(ctx context.Context, user *models.UserDBModel) error
  • func (r RedisAdapter) Update(ctx context.Context, user models.UserDBModel) error
• type RedisRepository
• type UserAdapter
  • func (r *UserAdapter) ByLogin(ctx context.Context, user *models.SignInUserRequest) (*models.UserDBModel, error)
  • func (r *UserAdapter) Confirm(ctx context.Context, user *models.UserDBModel) error
  • func (r *UserAdapter) Exists(ctx context.Context, udb *models.UserDBModel) (bool, error)
  • func (r *UserAdapter) FindAll(ctx context.Context, user *models.UserDBModel) ([]models.UserDBModel, error)
  • func (r *UserAdapter) FindOne(ctx context.Context, user *models.UserDBModel) (*models.UserDBModel, error)
  • func (r *UserAdapter) FindUserById(uid int64) (*models.UserDBModel, error)
  • func (r *UserAdapter) GetConnection() *gorm.DB
  • func (r *UserAdapter) GetOrCreate(ctx context.Context, id int64) (*models.UserDBModel, error)
  • func (r *UserAdapter) Save(ctx context.Context, user *models.UserDBModel) error
  • func (r *UserAdapter) SignUp(ctx context.Context, user models.UserDBModel) error
  • func (r *UserAdapter) Update(ctx context.Context, user models.UserDBModel) error
  • func (r *UserAdapter) UpdateLastLogin(ctx context.Context, u *models.UserDBModel) error
• type UserRepository
  • func NewUserRepository(ctx context.Context, dbType string, params *config.Config) (UserRepository, error)

Constants

const (
	MySQL   string = "mysql"
	MongoDB string = "mongo"
	Redis   string = "redis"
)

Types

type MongoAdapter

type MongoAdapter struct {
	DB *mongo.Client
	// contains filtered or unexported fields
}

func (MongoAdapter) Confirm

func (m MongoAdapter) Confirm(ctx context.Context, udb *models.UserDBModel) error

func (MongoAdapter) Exists

func (m MongoAdapter) Exists(ctx context.Context, udb *models.UserDBModel) (bool, error)

func (MongoAdapter) FindAll

func (m MongoAdapter) FindAll(ctx context.Context, user *models.UserDBModel) ([]models.UserDBModel, error)

func (MongoAdapter) FindOne

func (m MongoAdapter) FindOne(ctx context.Context, user *models.UserDBModel) (*models.UserDBModel, error)

func (MongoAdapter) GetOrCreate

func (m MongoAdapter) GetOrCreate(ctx context.Context, id int64) (*models.UserDBModel, error)

func (MongoAdapter) Save

func (m MongoAdapter) Save(ctx context.Context, user *models.UserDBModel) error

func (MongoAdapter) Update

func (m MongoAdapter) Update(ctx context.Context, user models.UserDBModel) error

func (MongoAdapter) UpdateLastLogin

func (m MongoAdapter) UpdateLastLogin(ctx context.Context, user *models.UserDBModel) error

type RedisAdapter

type RedisAdapter struct {
	DB *redis.UniversalClient
}

func (RedisAdapter) Confirm

func (r RedisAdapter) Confirm(ctx context.Context, udb *models.UserDBModel) error

func (RedisAdapter) Exists

func (r RedisAdapter) Exists(ctx context.Context, udb *models.UserDBModel) (bool, error)

func (RedisAdapter) FindAll

func (r RedisAdapter) FindAll(ctx context.Context, user *models.UserDBModel) ([]models.UserDBModel, error)

func (RedisAdapter) FindOne

func (r RedisAdapter) FindOne(ctx context.Context, user *models.UserDBModel) (*models.UserDBModel, error)

func (RedisAdapter) GetOrCreate

func (r RedisAdapter) GetOrCreate(ctx context.Context, id int64) (*models.UserDBModel, error)

func (RedisAdapter) Save

func (r RedisAdapter) Save(ctx context.Context, user *models.UserDBModel) error

func (RedisAdapter) Update

func (r RedisAdapter) Update(ctx context.Context, user models.UserDBModel) error

type RedisRepository

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

type UserAdapter

type UserAdapter struct {
	DB *gorm.DB
}

func (*UserAdapter) ByLogin

func (r *UserAdapter) ByLogin(ctx context.Context, user *models.SignInUserRequest) (*models.UserDBModel, error)

func (*UserAdapter) Confirm

func (r *UserAdapter) Confirm(ctx context.Context, user *models.UserDBModel) error

func (*UserAdapter) Exists

func (r *UserAdapter) Exists(ctx context.Context, udb *models.UserDBModel) (bool, error)

func (*UserAdapter) FindAll

func (r *UserAdapter) FindAll(ctx context.Context, user *models.UserDBModel) ([]models.UserDBModel, error)

func (*UserAdapter) FindOne

func (r *UserAdapter) FindOne(ctx context.Context, user *models.UserDBModel) (*models.UserDBModel, error)

func (*UserAdapter) FindUserById

func (r *UserAdapter) FindUserById(uid int64) (*models.UserDBModel, error)

func (*UserAdapter) GetConnection

func (r *UserAdapter) GetConnection() *gorm.DB

func (*UserAdapter) GetOrCreate

func (r *UserAdapter) GetOrCreate(ctx context.Context, id int64) (*models.UserDBModel, error)

func (*UserAdapter) Save

func (r *UserAdapter) Save(ctx context.Context, user *models.UserDBModel) error

func (*UserAdapter) SignUp

func (r *UserAdapter) SignUp(ctx context.Context, user models.UserDBModel) error

func (*UserAdapter) Update

func (r *UserAdapter) Update(ctx context.Context, user models.UserDBModel) error

func (*UserAdapter) UpdateLastLogin

func (r *UserAdapter) UpdateLastLogin(ctx context.Context, u *models.UserDBModel) error

type UserRepository

type UserRepository interface {
	FindOne(ctx context.Context, user *models.UserDBModel) (*models.UserDBModel, error)
	FindAll(ctx context.Context, user *models.UserDBModel) ([]models.UserDBModel, error)
	Save(ctx context.Context, user *models.UserDBModel) error
	Update(ctx context.Context, user models.UserDBModel) error
	Confirm(ctx context.Context, udb *models.UserDBModel) error
	GetOrCreate(ctx context.Context, id int64) (*models.UserDBModel, error)
	Exists(ctx context.Context, udb *models.UserDBModel) (bool, error)
}

func NewUserRepository

func NewUserRepository(ctx context.Context, dbType string, params *config.Config) (UserRepository, error)