(logger log.Logger)
| 258 | } |
| 259 | |
| 260 | func createAndStartEventBus(logger log.Logger) (*types.EventBus, error) { |
| 261 | eventBus := types.NewEventBus() |
| 262 | eventBus.SetLogger(logger.With("module", "events")) |
| 263 | if err := eventBus.Start(); err != nil { |
| 264 | return nil, err |
| 265 | } |
| 266 | return eventBus, nil |
| 267 | } |
| 268 | |
| 269 | func createAndStartIndexerService( |
| 270 | config *cfg.Config, |
no test coverage detected