(project, service, version string)
| 56 | } |
| 57 | |
| 58 | func (s *Scaler) removeIsActiveStream(project, service, version string) { |
| 59 | s.lock.Lock() |
| 60 | defer s.lock.Unlock() |
| 61 | |
| 62 | // Generate a key for the stream |
| 63 | key := generateKey(project, service, version) |
| 64 | |
| 65 | // Close the stream if it already existed |
| 66 | if stream, p := s.isActiveStreams[key]; p { |
| 67 | close(stream.ch) |
| 68 | } |
| 69 | |
| 70 | // Remove the stream from the map |
| 71 | delete(s.isActiveStreams, key) |
| 72 | } |
| 73 | |
| 74 | func generateKey(project, service, version string) string { |
| 75 | return fmt.Sprintf("%s---%s---%s", project, service, version) |
no test coverage detected