()
| 1084 | } |
| 1085 | |
| 1086 | func (t *QueueManager) client() WriteClient { |
| 1087 | t.clientMtx.RLock() |
| 1088 | defer t.clientMtx.RUnlock() |
| 1089 | return t.storeClient |
| 1090 | } |
| 1091 | |
| 1092 | // processExternalLabels merges externalLabels into b. If b contains |
| 1093 | // a label in externalLabels, the value in b wins. |
no outgoing calls