db

package
v0.0.0-...-343eb44 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2025 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateUserOutboxParams

type CreateUserOutboxParams struct {
	CreatedAt time.Time
	UpdatedAt time.Time
	Payload   *entity.User
	Status    UserOutboxStatus
	ID        uuid.UUID
	CreatedBy uuid.UUID
	UpdatedBy uuid.UUID
}

type CreateUserParams

type CreateUserParams struct {
	CreatedAt time.Time
	UpdatedAt time.Time
	Name      string
	ID        uuid.UUID
	CreatedBy uuid.UUID
	UpdatedBy uuid.UUID
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type GetAllUserOutboxesForUpdateByStatusParams

type GetAllUserOutboxesForUpdateByStatusParams struct {
	Status UserOutboxStatus
	Limit  int32
}

type NullUserOutboxStatus

type NullUserOutboxStatus struct {
	UserOutboxStatus UserOutboxStatus
	Valid            bool // Valid is true if UserOutboxStatus is not NULL
}

func (*NullUserOutboxStatus) Scan

func (ns *NullUserOutboxStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullUserOutboxStatus) Value

func (ns NullUserOutboxStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CreateUser

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) error

func (*Queries) CreateUserOutbox

func (q *Queries) CreateUserOutbox(ctx context.Context, arg CreateUserOutboxParams) error

func (*Queries) GetAllUserOutboxesForUpdateByStatus

func (q *Queries) GetAllUserOutboxesForUpdateByStatus(ctx context.Context, arg GetAllUserOutboxesForUpdateByStatusParams) ([]*UsersOutbox, error)

func (*Queries) GetAllUsers

func (q *Queries) GetAllUsers(ctx context.Context, limit int32) ([]*User, error)

func (*Queries) GetUserByID

func (q *Queries) GetUserByID(ctx context.Context, id uuid.UUID) (*User, error)

func (*Queries) HardDeleteUserByID

func (q *Queries) HardDeleteUserByID(ctx context.Context, id uuid.UUID) error

func (*Queries) UpdateUserOutboxID

func (q *Queries) UpdateUserOutboxID(ctx context.Context, arg UpdateUserOutboxIDParams) error

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type UpdateUserOutboxIDParams

type UpdateUserOutboxIDParams struct {
	Status UserOutboxStatus
	ID     uuid.UUID
}

type User

type User struct {
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt *time.Time
	DeletedBy *uuid.UUID
	Name      string
	ID        uuid.UUID
	CreatedBy uuid.UUID
	UpdatedBy uuid.UUID
}

type UserOutboxStatus

type UserOutboxStatus string
const (
	UserOutboxStatusREADY     UserOutboxStatus = "READY"
	UserOutboxStatusPROCESSED UserOutboxStatus = "PROCESSED"
	UserOutboxStatusDELIVERED UserOutboxStatus = "DELIVERED"
	UserOutboxStatusFAILED    UserOutboxStatus = "FAILED"
)

func (*UserOutboxStatus) Scan

func (e *UserOutboxStatus) Scan(src interface{}) error

type UsersOutbox

type UsersOutbox struct {
	CreatedAt time.Time
	UpdatedAt time.Time
	Payload   *entity.User
	DeletedAt *time.Time
	DeletedBy *uuid.UUID
	Status    UserOutboxStatus
	ID        uuid.UUID
	CreatedBy uuid.UUID
	UpdatedBy uuid.UUID
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL