| 136 | } |
| 137 | |
| 138 | type basePoolManager struct { |
| 139 | ctx context.Context |
| 140 | consumerID string |
| 141 | entity params.ForgeEntity |
| 142 | ghcli common.GithubClient |
| 143 | scaleSetClient *scalesets.ScaleSetClient |
| 144 | controllerInfo params.ControllerInfo |
| 145 | instanceTokenGetter auth.InstanceTokenGetter |
| 146 | consumer dbCommon.Consumer |
| 147 | |
| 148 | store dbCommon.Store |
| 149 | jobs map[int64]params.Job |
| 150 | |
| 151 | providers map[string]common.Provider |
| 152 | tools []commonParams.RunnerApplicationDownload |
| 153 | quit chan struct{} |
| 154 | checkedJobs map[int64]time.Time |
| 155 | |
| 156 | managerIsRunning bool |
| 157 | managerErrorReason string |
| 158 | |
| 159 | mux sync.Mutex |
| 160 | wg *sync.WaitGroup |
| 161 | backoff locking.InstanceDeleteBackoff |
| 162 | } |
| 163 | |
| 164 | func (r *basePoolManager) getProviderBaseParams(pool params.Pool) common.ProviderBaseParams { |
| 165 | r.mux.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected