(isRunning bool, failureReason string)
| 1018 | } |
| 1019 | |
| 1020 | func (r *basePoolManager) SetPoolRunningState(isRunning bool, failureReason string) { |
| 1021 | r.mux.Lock() |
| 1022 | r.managerErrorReason = failureReason |
| 1023 | r.managerIsRunning = isRunning |
| 1024 | updateParams := params.PoolManagerStatus{ |
| 1025 | IsRunning: isRunning, |
| 1026 | FailureReason: failureReason, |
| 1027 | } |
| 1028 | if err := r.store.SetEntityPoolManagerStatus(r.ctx, r.entity, updateParams); err != nil { |
| 1029 | slog.ErrorContext(r.ctx, "failed to set pool manager status", "error", err) |
| 1030 | } |
| 1031 | r.mux.Unlock() |
| 1032 | } |
| 1033 | |
| 1034 | func (r *basePoolManager) getLabelsForInstance(pool params.Pool) []string { |
| 1035 | labels := []string{} |
no test coverage detected