MCPcopy Create free account
hub / github.com/DeAI-Artist/Linkis / createAndStartEventBus

Function createAndStartEventBus

test/maverick/node/node.go:287–294  ·  view source on GitHub ↗
(logger log.Logger)

Source from the content-addressed store, hash-verified

285}
286
287func 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
296func createAndStartIndexerService(
297 config *cfg.Config,

Callers 1

NewNodeFunction · 0.70

Calls 4

SetLoggerMethod · 0.95
NewEventBusFunction · 0.92
WithMethod · 0.65
StartMethod · 0.65

Tested by

no test coverage detected