(db common.Store)
| 305 | } |
| 306 | |
| 307 | func maybeInitController(db common.Store) error { |
| 308 | if _, err := db.ControllerInfo(); err == nil { |
| 309 | return nil |
| 310 | } |
| 311 | |
| 312 | if _, err := db.InitController(); err != nil { |
| 313 | return fmt.Errorf("error initializing controller: %w", err) |
| 314 | } |
| 315 | |
| 316 | return nil |
| 317 | } |
| 318 | |
| 319 | func (s *WatcherTestSuite) TestWithEntityPoolFilterRepository() { |
| 320 | producer, err := watcher.RegisterProducer(s.ctx, "test-producer") |
no test coverage detected