(orgID string)
| 167 | sessions.SetRequestedVCPUsResolver(func(profile *WorkerProfile) (int, error) { |
| 168 | return requestedWorkerVCPUs(profile, tr.baseCfg.WorkerCPURequest) |
| 169 | }) |
| 170 | sessions.SetConnectionLimiter(NewRuntimeOrgConnectionLimiter( |
| 171 | tr.configStore, |
| 172 | tc.Name, |
| 173 | tr.baseCfg.CPInstanceID, |
| 174 | tr.globalCfg.WorkerQueueTimeout, |
| 175 | tr.admissionReclaimer, |
| 176 | )) |
| 177 | rebalancer.SetSessionLister(sessions) |
| 178 | |
| 179 | stack := &OrgStack{ |
| 180 | Config: tc, |
| 181 | Pool: pool, |
| 182 | Sessions: sessions, |
| 183 | Rebalancer: rebalancer, |
| 184 | cancel: cancel, |
| 185 | } |
no test coverage detected