MCPX MCP Gateway

//go:build pro

package handlers

import (
	"lunar/async-service/config"
	protocol_async "lunar/toolkit-core/network/protocols/async"

	"github.com/rs/zerolog/log"
)

type Dispatcher struct {
	workers *WorkerPool
}

func NewDispatcher(protocolHandler *protocol_async.Protocol) *Dispatcher {
	return &Dispatcher{
		workers: NewWorkerPool(config.GetAsyncServiceWorkers(), protocolHandler),
	}
}

func (d *Dispatcher) Start() {
	log.Debug().Msgf("Dispatcher started with %d workers", config.GetAsyncServiceWorkers())
	d.workers.Start()
}

func (d *Dispatcher) Stop() {
	log.Debug().Msgf("Dispatcher stopped")
	d.workers.Stop()
}