}
func (m *registryImpl) RecordWorkerHeartbeats(nsID namespace.ID, nsName namespace.Name, principal *commonpb.Principal, workerHeartbeat []*workerpb.WorkerHeartbeat) {
registry_impl.go
m.upsertHeartbeats(nsID, nsName, principal, workerHeartbeat)
m.metricsEmitter.emit(nsID, nsName, workerHeartbeat)
}
func buildQueryPredicate(nsID namespace.ID, query string) (func(*workerpb.WorkerHeartbeat) bool, error) {