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

Function createAndStartEventBus

node/node.go:260–267  ·  view source on GitHub ↗
(logger log.Logger)

Source from the content-addressed store, hash-verified

258}
259
260func 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
269func createAndStartIndexerService(
270 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