(logger log.Logger)
| 285 | } |
| 286 | |
| 287 | func createAndStartEventBus(logger log.Logger) (*types.EventBus, error) { |
| 288 | eventBus := types.NewEventBus() |
| 289 | eventBus.SetLogger(logger.With("module", "events")) |
| 290 | if err := eventBus.Start(); err != nil { |
| 291 | return nil, err |
| 292 | } |
| 293 | return eventBus, nil |
| 294 | } |
| 295 | |
| 296 | func createAndStartIndexerService( |
| 297 | config *cfg.Config, |
no test coverage detected