QueueUpdate updates a queue's settings in the database. These settings override the settings in the client (if applied).
(ctx context.Context, name string, params *QueueUpdateParams)
| 2816 | // QueueUpdate updates a queue's settings in the database. These settings |
| 2817 | // override the settings in the client (if applied). |
| 2818 | func (c *Client[TTx]) QueueUpdate(ctx context.Context, name string, params *QueueUpdateParams) (*rivertype.Queue, error) { |
| 2819 | tx, err := c.driver.GetExecutor().Begin(ctx) |
| 2820 | if err != nil { |
| 2821 | return nil, err |
| 2822 | } |
| 2823 | defer dbutil.RollbackWithoutCancel(ctx, tx) |
| 2824 | |
| 2825 | queue, controlEvent, err := c.queueUpdate(ctx, tx, name, params) |
| 2826 | if err != nil { |
| 2827 | return nil, err |
| 2828 | } |
| 2829 | |
| 2830 | if err := tx.Commit(ctx); err != nil { |
| 2831 | return nil, err |
| 2832 | } |
| 2833 | |
| 2834 | c.notifyProducerWithoutListenerQueueControlEvent(name, controlEvent) |
| 2835 | |
| 2836 | return queue, nil |
| 2837 | } |
| 2838 | |
| 2839 | // QueueUpdateTx updates a queue's settings in the database. These settings |
| 2840 | // override the settings in the client (if applied). |
nothing calls this directly
no test coverage detected