users

Documentation

Index

• Variables
• func NewPostgresStore(pqdriver *pgxpool.Pool, tablename string) *pgstore
• type User
  • func (us *User) Sanitize()
  • func (us *User) ValidateForCreate() error
• type Users
  • func NewService(store store) *Users
  • func (us *Users) AsyncCreateUsers(ctx context.Context, users []User) error
  • func (us *Users) CreateUser(ctx context.Context, user *User) (*User, error)
  • func (us *Users) ReadByEmail(ctx context.Context, email string) (*User, error)

Variables

var (
	ErrUserEmailNotFound      = errors.New("user with the email not found")
	ErrUserEmailAlreadyExists = errors.New("user with the email already exists")
)

Functions

func NewPostgresStore

func NewPostgresStore(pqdriver *pgxpool.Pool, tablename string) *pgstore

Types

type User

type User struct {
	ID             string
	FullName       string
	Email          string
	Phone          string
	ContactAddress string
}

func (*User) Sanitize

func (us *User) Sanitize()

func (*User) ValidateForCreate

func (us *User) ValidateForCreate() error

ValidateForCreate runs the validation required for when a user is being created. i.e. ID is not available

type Users

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

func NewService

func NewService(store store) *Users

func (*Users) AsyncCreateUsers

func (us *Users) AsyncCreateUsers(ctx context.Context, users []User) error

func (*Users) CreateUser

func (us *Users) CreateUser(ctx context.Context, user *User) (*User, error)

func (*Users) ReadByEmail

func (us *Users) ReadByEmail(ctx context.Context, email string) (*User, error)