()
| 133 | } |
| 134 | |
| 135 | func (t *TokenRenewer) sendDisconnectSignal() { |
| 136 | // Needs to be non-blocking because tokenRenewer may be stopped. |
| 137 | select { |
| 138 | case t.disconnect <- struct{}{}: |
| 139 | default: |
| 140 | } |
| 141 | } |
| 142 | |
| 143 | // renewToken gets a new token from a kontrolClient, parses it and sets it as the token. |
| 144 | func (t *TokenRenewer) renewToken() error { |