Method QueueGetTx

client.go:2601–2606

QueueGetTx returns the queue with the given name. If the queue has not recently been active or does not exist, returns ErrNotFound. The provided context is used for the underlying Postgres query and can be used to cancel the operation or apply a timeout.

(ctx context.Context, tx TTx, name string)

// The provided context is used for the underlying Postgres query and can be
// used to cancel the operation or apply a timeout.
func (c *Client[TTx]) QueueGetTx(ctx context.Context, tx TTx, name string) (*rivertype.Queue, error) {
	return c.driver.UnwrapExecutor(tx).QueueGet(ctx, &riverdriver.QueueGetParams{
		Name:   name,
		Schema: c.config.Schema,
	})
}

// QueueListResult is the result of a job list operation. It contains a list of
// jobs and leaves room for future cursor functionality.