function

package

v0.0.0-...-64f415b Latest Latest Go to latest Published: Dec 29, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Batcher interface {
	Queue(query string, arguments ...any) *pgx.QueuedQuery
}

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

func NewQuerier(ctx context.Context, conn genericConn) (*DBQuerier, error)

NewQuerier creates a DBQuerier

func (q *DBQuerier) OutParams(ctx context.Context) ([]OutParamsRow, error)

OutParams implements Querier.OutParams.

func (q *DBQuerier) QueueOutParams(batch Batcher) *QueuedOutParams

QueueOutParams implements Querier.QueueOutParams.

type ListItem struct {
	Name  *string `json:"name"`
	Color *string `json:"color"`
}

ListItem represents the Postgres composite type "list_item".

type ListStats struct {
	Val1 *string  `json:"val1"`
	Val2 []*int32 `json:"val2"`
}

ListStats represents the Postgres composite type "list_stats".

type OutParamsRow struct {
	Items []ListItem `json:"_items"`
	Stats ListStats  `json:"_stats"`
}

type Querier interface {
	OutParams(ctx context.Context) ([]OutParamsRow, error)

	QueueOutParams(batch Batcher) *QueuedOutParams
}

Querier is a typesafe Go interface backed by SQL queries.

type QueryName struct{}

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

func (q *QueuedOutParams) OnResult(onResult func([]OutParamsRow) error)

func (q *QueuedOutParams) WrapError(wrapError func(err error) error)