Documentation
¶
Overview ¶
Package dispatcher owns the bounded in-memory queue that decouples pollers from MCP workers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Module = fx.Module( "dispatcher", fx.Provide( newPolledCommandQueue, newConfiguredChannelBindings, fx.Annotate(newHarpoonChannelBinding, fx.ResultTags(`group:"dispatcher_channel_bindings"`)), newProcessorChannelBindings, dispatcherinternal.NewProcessor, dispatcherinternal.NewQueueListener, ), fx.Invoke(startQueueListener), )
Module registers the dispatcher components with the Fx graph. It provides the bounded polled command queue sized according to ControlPlaneConfig, constructs the Processor that consumes commands from that queue and calls downstream MCP servers, and starts the listener goroutine that drains the queue when the app lifecycle begins.
Functions ¶
This section is empty.
Types ¶
type Params ¶
type Params struct {
fx.In
ControlPlane *config.ControlPlaneConfig
MeterProvider *sdkmetric.MeterProvider
}
Params captures the dependencies needed to size the dispatcher work queue.
type Result ¶
type Result struct {
fx.Out
PolledCommandQueue controlplane.PolledCommandQueue
}
Result exposes the bounded queue that downstream components consume.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.