dal

Documentation

Index

• Variables
• func GoCreateUser(ctx context.Context, db *sqlx.DB, n, chanBufSize int, wg *sync.WaitGroup)
• func GoGetUsers(ctx context.Context, db *sqlx.DB, n, chanBufSize int, wg *sync.WaitGroup)
• func MigrateDB(dsn string) (*sqlx.DB, error)
• type CreateUserQuery
  • func (q CreateUserQuery) Do()
• type GetUsersQuery
  • func (q GetUsersQuery) Do()

Variables

var CreateUserChan chan CreateUserQuery

var CreateUserTimeout = 20 * time.Second

var GetUsersChan chan GetUsersQuery

var GetUsersTimeout = 20 * time.Second

Functions

func GoCreateUser

func GoCreateUser(ctx context.Context, db *sqlx.DB, n, chanBufSize int, wg *sync.WaitGroup)

func GoGetUsers

func GoGetUsers(ctx context.Context, db *sqlx.DB, n, chanBufSize int, wg *sync.WaitGroup)

func MigrateDB

func MigrateDB(dsn string) (*sqlx.DB, error)

Types

type CreateUserQuery

type CreateUserQuery struct {
	Ctx    context.Context
	User   core.User
	Result chan verr.ValErr[core.User]
}

func (CreateUserQuery) Do

func (q CreateUserQuery) Do()

type GetUsersQuery

type GetUsersQuery struct {
	Ctx    context.Context
	Result chan verr.ValErr[core.User]
}

func (GetUsersQuery) Do

func (q GetUsersQuery) Do()