Method QueueList

client.go:2626–2640

QueueList returns a list of all queues that are currently active or were recently active. Limit and offset can be used to paginate the results. The provided context is used for the underlying Postgres query and can be used to cancel the operation or apply a timeout. params := river.NewQueueListPa

(ctx context.Context, params *QueueListParams)

//		// handle error
//	}
func (c *Client[TTx]) QueueList(ctx context.Context, params *QueueListParams) (*QueueListResult, error) {
	if params == nil {
		params = NewQueueListParams()
	}

	queues, err := c.driver.GetExecutor().QueueList(ctx, &riverdriver.QueueListParams{
		Max:    int(params.paginationCount),
		Schema: c.config.Schema,
	})
	if err != nil {
		return nil, err
	}

	return &QueueListResult{Queues: queues}, nil
}

// QueueListTx returns a list of all queues that are currently active or were
// recently active. Limit and offset can be used to paginate the results.