db

Documentation

Index

• type DB
• type JsonDB
• type LHClient
  • func NewLHClient(ctx context.Context, dbURL string, debug bool) (*LHClient, error)
  • func (lh *LHClient) Close() error
  • func (lh *LHClient) CreateUser(user *model.User) error
  • func (lh *LHClient) DeleteUser(UserID int) error
  • func (lh *LHClient) GetUserByID(UserID int) (*model.User, error)
  • func (lh *LHClient) GetUsers() ([]*model.User, error)
  • func (lh *LHClient) UpdateUser(UserID int, user *model.User) error
• type MongoClient
  • func NewMongoClient(ctx context.Context, dbURL string, debug bool) (*MongoClient, error)
  • func (h *MongoClient) Close() error
  • func (h *MongoClient) DeleteUser(id primitive.ObjectID) (*mongo.DeleteResult, error)
  • func (h *MongoClient) FindUserByID(id primitive.ObjectID) (*model.UserBson, error)
  • func (h *MongoClient) InsertUser(user model.UserBson) (*mongo.InsertOneResult, error)
  • func (h *MongoClient) UpdateUser(id primitive.ObjectID, update bson.M) (*mongo.UpdateResult, error)
• type PGClient
  • func NewPGClient(ctx context.Context, dbURL string, debug bool) (*PGClient, error)
  • func (pg *PGClient) Close() error
  • func (pg *PGClient) CreateUser(user *model.User) error
  • func (pg *PGClient) DeleteUser(UserID int) error
  • func (pg *PGClient) GetUserByID(UserID int) (*model.User, error)
  • func (pg *PGClient) GetUsers() ([]*model.User, error)
  • func (pg *PGClient) UpdateUser(UserID int, user *model.User) error

Types

type DB

type DB interface {
	GetUsers() ([]*model.User, error)
	GetUserByID(UserID int) (*model.User, error)
	CreateUser(user *model.User) error
	UpdateUser(UserID int, user *model.User) error
	DeleteUser(UserID int) error
	Close() error
}

type JsonDB

type JsonDB interface {
	InsertUser(user model.UserBson) (*mongo.InsertOneResult, error)
	FindUserByID(id primitive.ObjectID) (*model.UserBson, error)
	UpdateUser(id primitive.ObjectID, update bson.M) (*mongo.UpdateResult, error)
	DeleteUser(id primitive.ObjectID) (*mongo.DeleteResult, error)
	Close() error
}

type LHClient

type LHClient struct {
	DB *sqlx.DB
}

func NewLHClient

func NewLHClient(ctx context.Context, dbURL string, debug bool) (*LHClient, error)

NewPGClient creates a new item database connection.

func (*LHClient) Close

func (lh *LHClient) Close() error

func (*LHClient) CreateUser

func (lh *LHClient) CreateUser(user *model.User) error

func (*LHClient) DeleteUser

func (lh *LHClient) DeleteUser(UserID int) error

func (*LHClient) GetUserByID

func (lh *LHClient) GetUserByID(UserID int) (*model.User, error)

func (*LHClient) GetUsers

func (lh *LHClient) GetUsers() ([]*model.User, error)

func (*LHClient) UpdateUser

func (lh *LHClient) UpdateUser(UserID int, user *model.User) error

type MongoClient

type MongoClient struct {
	DB *mongo.Database
}

func NewMongoClient

func NewMongoClient(ctx context.Context, dbURL string, debug bool) (*MongoClient, error)

NewPGClient creates a new item database connection.

func (*MongoClient) Close

func (h *MongoClient) Close() error

func (*MongoClient) DeleteUser

func (h *MongoClient) DeleteUser(id primitive.ObjectID) (*mongo.DeleteResult, error)

DeleteUser deletes a user from the users collection

func (*MongoClient) FindUserByID

func (h *MongoClient) FindUserByID(id primitive.ObjectID) (*model.UserBson, error)

FindUserByID finds a user by their ID in the users collection

func (*MongoClient) InsertUser

func (h *MongoClient) InsertUser(user model.UserBson) (*mongo.InsertOneResult, error)

InsertUser inserts a new user into the users collection

func (*MongoClient) UpdateUser

func (h *MongoClient) UpdateUser(id primitive.ObjectID, update bson.M) (*mongo.UpdateResult, error)

UpdateUser updates an existing user in the users collection

type PGClient

type PGClient struct {
	DB *sqlx.DB
}

func NewPGClient

func NewPGClient(ctx context.Context, dbURL string, debug bool) (*PGClient, error)

NewPGClient creates a new item database connection.

func (*PGClient) Close

func (pg *PGClient) Close() error

func (*PGClient) CreateUser

func (pg *PGClient) CreateUser(user *model.User) error

func (*PGClient) DeleteUser

func (pg *PGClient) DeleteUser(UserID int) error

func (*PGClient) GetUserByID

func (pg *PGClient) GetUserByID(UserID int) (*model.User, error)

func (*PGClient) GetUsers

func (pg *PGClient) GetUsers() ([]*model.User, error)

func (*PGClient) UpdateUser

func (pg *PGClient) UpdateUser(UserID int, user *model.User) error