(timeout time.Duration)
| 1508 | } |
| 1509 | |
| 1510 | func WithGracefulTimeout(timeout time.Duration) ControllerOpt { |
| 1511 | return func(c *Controller) { |
| 1512 | c.gracefulTimeout = timeout |
| 1513 | } |
| 1514 | } |
| 1515 | |
| 1516 | // manageGracefulTimeout allows the gracefulContext to last longer than the main context |
| 1517 | // to allow a graceful disconnect. |
no outgoing calls