Method QueueGet

client.go:2589–2594

QueueGet 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, 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]) QueueGet(ctx context.Context, name string) (*rivertype.Queue, error) {
	return c.driver.GetExecutor().QueueGet(ctx, &riverdriver.QueueGetParams{
		Name:   name,
		Schema: c.config.Schema,
	})
}

// QueueGetTx returns the queue with the given name. If the queue has not recently
// been active or does not exist, returns ErrNotFound.