(res *RegisterResponse)
| 81 | } |
| 82 | |
| 83 | func (m *NATSCredentialManager) store(res *RegisterResponse) { |
| 84 | m.mu.Lock() |
| 85 | defer m.mu.Unlock() |
| 86 | m.nodeID = res.ID |
| 87 | if res.NatsJWT != "" && res.NatsUserSeed != "" { |
| 88 | m.jwt, m.seed = res.NatsJWT, res.NatsUserSeed |
| 89 | } |
| 90 | } |
| 91 | |
| 92 | // Current returns the latest NATS credentials (both empty until acquired). |
| 93 | func (m *NATSCredentialManager) Current() (jwt, seed string) { |
no test coverage detected