(ctx context.Context, refreshFreq time.Duration)
| 155 | } |
| 156 | |
| 157 | func (fs *featureSelector) refreshLoop(ctx context.Context, refreshFreq time.Duration) { |
| 158 | ticker := time.NewTicker(refreshFreq) |
| 159 | for { |
| 160 | select { |
| 161 | case <-ctx.Done(): |
| 162 | return |
| 163 | case <-ticker.C: |
| 164 | err := fs.refresh(ctx) |
| 165 | if err != nil { |
| 166 | fs.logger.Err(err).Msg("Failed to refresh feature selector") |
| 167 | } |
| 168 | } |
| 169 | } |
| 170 | } |
| 171 | |
| 172 | // resolver represents an object that can look up featuresRecord |
| 173 | type resolver interface { |
no test coverage detected