Method RegisterModelEventHandler

scheduler/pkg/coordinator/model.go:20–37

(
	name string,
	queueSize int,
	logger log.FieldLogger,
	handle func(event ModelEventMsg),
)

)

func (h *EventHub) RegisterModelEventHandler(
	name string,
	queueSize int,
	logger log.FieldLogger,
	handle func(event ModelEventMsg),
) {
	events := make(chan ModelEventMsg, queueSize)
	h.addModelEventHandlerChannel(events)

	go func() {
		for e := range events {
			handle(e)
		}
	}()

	handler := h.newModelEventHandler(logger, events)
	h.bus.RegisterHandler(name, handler)
}

func (h *EventHub) newModelEventHandler(
	logger log.FieldLogger,