Documentation
¶
Index ¶
- type CreateUserOutboxParams
- type CreateUserParams
- type DBTX
- type GetAllUserOutboxesForUpdateByStatusParams
- type NullUserOutboxStatus
- type Queries
- func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) error
- func (q *Queries) CreateUserOutbox(ctx context.Context, arg CreateUserOutboxParams) error
- func (q *Queries) GetAllUserOutboxesForUpdateByStatus(ctx context.Context, arg GetAllUserOutboxesForUpdateByStatusParams) ([]*UsersOutbox, error)
- func (q *Queries) GetAllUsers(ctx context.Context, limit int32) ([]*User, error)
- func (q *Queries) GetUserByID(ctx context.Context, id uuid.UUID) (*User, error)
- func (q *Queries) HardDeleteUserByID(ctx context.Context, id uuid.UUID) error
- func (q *Queries) UpdateUserOutboxID(ctx context.Context, arg UpdateUserOutboxIDParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type UpdateUserOutboxIDParams
- type User
- type UserOutboxStatus
- type UsersOutbox
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreateUserOutboxParams ¶
type CreateUserParams ¶
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.
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
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 (*Queries) GetUserByID ¶
func (*Queries) HardDeleteUserByID ¶
func (*Queries) UpdateUserOutboxID ¶
func (q *Queries) UpdateUserOutboxID(ctx context.Context, arg UpdateUserOutboxIDParams) error
type UpdateUserOutboxIDParams ¶
type UpdateUserOutboxIDParams struct {
Status UserOutboxStatus
ID 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
Click to show internal directories.
Click to hide internal directories.