pool

Aug 11, 2026

Changes in this version

type HealthChecker

+ func (hc *HealthChecker) SetMaxFailures(n int)

+ type ReconnectSettings struct

+ Disabled bool

+ MaxRestartAttempts int

+ RestartBackoff time.Duration

+ StableWindow time.Duration

type ServerState

+ const StateDisconnected

type StdioPool

+ func (p *StdioPool) SetReconnect(settings ReconnectSettings)

May 31, 2026

Changes in this version

type HTTPClientPool

+ func (p *HTTPClientPool) IsServerMCPInitialized(name string) bool

+ func (p *HTTPClientPool) MarkServerMCPInitialized(name string)

type SSEPool

+ func (p *SSEPool) IsServerMCPInitialized(name string) bool

+ func (p *SSEPool) MarkServerMCPInitialized(name string)

type ServerSource

+ IsServerMCPInitialized func(name string) bool

+ MarkServerMCPInitialized func(name string)

type StdioPool

+ func (p *StdioPool) IsServerMCPInitialized(name string) bool

+ func (p *StdioPool) MarkServerMCPInitialized(name string)

type StdioServerV2

+ func (s *StdioServerV2) IsMCPInitialized() bool

+ func (s *StdioServerV2) SetMCPInitialized()

type UnifiedPool

+ func (p *UnifiedPool) IsServerMCPInitialized(name string) bool

+ func (p *UnifiedPool) MarkServerMCPInitialized(name string)

May 6, 2026

Changes in this version

type ServerStats

+ LastError string

+ LastErrorAt time.Time

type StdioPool

+ func (p *StdioPool) GetOrStartServer(ctx context.Context, name string) (*StdioServerV2, error)

May 5, 2026

Changes in this version

type ServerState

+ const StateUnknown

type StdioServerConfig

+ MaxResponseSize int

May 4, 2026

Changes in this version

+ type HTTPClientPool struct

+ func NewHTTPClientPool(logger *slog.Logger) *HTTPClientPool

+ func (p *HTTPClientPool) Close() error

+ func (p *HTTPClientPool) GetServerState(name string) (ServerState, error)

+ func (p *HTTPClientPool) HasServer(name string) bool

+ func (p *HTTPClientPool) ListServers() []string

+ func (p *HTTPClientPool) RestartServer(ctx context.Context, name string) error

+ func (p *HTTPClientPool) SendRequest(ctx context.Context, serverName string, req *proxy.JSONRPCRequest, ...) (*proxy.JSONRPCResponse, error)

+ func (p *HTTPClientPool) SendRequestToServer(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *HTTPClientPool) SendRequestToServerWithID(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *HTTPClientPool) SendServerNotification(ctx context.Context, name string, method string, params map[string]interface{}) error

+ func (p *HTTPClientPool) ServerCount() int

+ func (p *HTTPClientPool) StartServer(ctx context.Context, config *migrate.ServerConfig) error

+ type HTTPClientServer struct

+ func NewHTTPClientServer(name string, config *migrate.ServerConfig, logger *slog.Logger) *HTTPClientServer

+ func (s *HTTPClientServer) CallTool(ctx context.Context, name string, args map[string]interface{}) (*mcp.CallToolResult, error)

+ func (s *HTTPClientServer) Close() error

+ func (s *HTTPClientServer) Initialize(ctx context.Context) error

+ func (s *HTTPClientServer) ListTools(ctx context.Context) ([]mcp.Tool, error)

+ type SSEPool struct

+ func NewSSEPool(logger *slog.Logger) *SSEPool

+ func (p *SSEPool) Close() error

+ func (p *SSEPool) GetServerState(name string) (ServerState, error)

+ func (p *SSEPool) HasServer(name string) bool

+ func (p *SSEPool) ListServers() []string

+ func (p *SSEPool) RestartServer(ctx context.Context, name string) error

+ func (p *SSEPool) SendRequest(ctx context.Context, serverName string, req *proxy.JSONRPCRequest, ...) (*proxy.JSONRPCResponse, error)

+ func (p *SSEPool) SendRequestToServer(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *SSEPool) SendRequestToServerWithID(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *SSEPool) SendServerNotification(ctx context.Context, name string, method string, params map[string]interface{}) error

+ func (p *SSEPool) ServerCount() int

+ func (p *SSEPool) StartServer(ctx context.Context, config *migrate.ServerConfig) error

+ type SSEServer struct

+ func NewSSEServer(name string, config *migrate.ServerConfig, logger *slog.Logger) *SSEServer

+ func (s *SSEServer) CallTool(ctx context.Context, name string, args map[string]interface{}) (*mcp.CallToolResult, error)

+ func (s *SSEServer) Close() error

+ func (s *SSEServer) Initialize(ctx context.Context) error

+ func (s *SSEServer) ListTools(ctx context.Context) ([]mcp.Tool, error)

+ type ServerSource interface

+ Close func() error

+ GetServerState func(name string) (ServerState, error)

+ ListServers func() []string

+ RestartServer func(ctx context.Context, name string) error

+ SendRequestToServer func(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ SendRequestToServerWithID func(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ SendServerNotification func(ctx context.Context, name string, method string, params map[string]interface{}) error

type StdioPool

+ func (p *StdioPool) HasServer(name string) bool

+ type UnifiedPool struct

+ func NewUnifiedPool(stdio *StdioPool, http *HTTPClientPool, sse *SSEPool, logger *slog.Logger) *UnifiedPool

+ func (p *UnifiedPool) Close() error

+ func (p *UnifiedPool) GetServerState(name string) (ServerState, error)

+ func (p *UnifiedPool) ListServers() []string

+ func (p *UnifiedPool) RestartServer(ctx context.Context, name string) error

+ func (p *UnifiedPool) SendRequest(ctx context.Context, serverName string, req *proxy.JSONRPCRequest, ...) (*proxy.JSONRPCResponse, error)

+ func (p *UnifiedPool) SendRequestToServer(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *UnifiedPool) SendRequestToServerWithID(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *UnifiedPool) SendServerNotification(ctx context.Context, name string, method string, params map[string]interface{}) error

May 3, 2026

Changes in this version

type Request

+ func (r Request) MarshalJSON() ([]byte, error)

type StdioPool

+ func (p *StdioPool) SendNotificationToServer(ctx context.Context, name string, method string, params json.RawMessage) error

+ func (p *StdioPool) SendRequestToServer(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *StdioPool) SendRequestToServerWithID(ctx context.Context, name string, method string, params json.RawMessage, ...) (*Response, error)

+ func (p *StdioPool) SendServerNotification(ctx context.Context, name string, method string, params map[string]interface{}) error

May 2, 2026

Changes in this version

+ const ErrCodeInternalError

+ const ErrCodeServerError

+ const ErrCodeTimeout

+ type HealthCheckResult struct

+ CheckedAt time.Time

+ Error string

+ LatencyMs float64

+ ServerName string

+ Status HealthStatus

+ type HealthChecker struct

+ func NewHealthChecker(pool *StdioPool, logger *slog.Logger) *HealthChecker

+ func (hc *HealthChecker) CheckServer(ctx context.Context, name string) HealthCheckResult

+ func (hc *HealthChecker) GetAllHealth() map[string]HealthCheckResult

+ func (hc *HealthChecker) GetServerHealth(name string) (HealthStatus, error)

+ func (hc *HealthChecker) RegisterServer(name string)

+ func (hc *HealthChecker) Start(ctx context.Context, interval time.Duration)

+ func (hc *HealthChecker) Stop()

+ func (hc *HealthChecker) UnregisterServer(name string)

+ type HealthStatus string

+ const HealthDegraded

+ const HealthError

+ const HealthHealthy

+ const HealthUnhealthy

+ const HealthUnknown

+ type JSONRPCError struct

+ Code int

+ Data json.RawMessage

+ Message string

+ func (e *JSONRPCError) Error() string

+ type PingRequest struct

+ ID interface{}

+ JSONRPC string

+ Method string

+ type PingResponse struct

+ Error *JSONRPCError

+ ID interface{}

+ JSONRPC string

+ Result json.RawMessage

+ type PoolQueueManager struct

+ func NewPoolQueueManager(logger *slog.Logger) *PoolQueueManager

+ func (qm *PoolQueueManager) GetOrCreateQueue(name string, maxConcurrent int, queueTimeout time.Duration) *ServerQueue

+ func (qm *PoolQueueManager) GetQueueStats(name string) (active int, pending int, atCapacity bool)

+ func (qm *PoolQueueManager) ListQueues() []string

+ func (qm *PoolQueueManager) RemoveQueue(name string)

+ type Request struct

+ ErrorCh chan error

+ ID interface{}

+ Method string

+ Params json.RawMessage

+ ResultCh chan *Response

+ Timeout time.Duration

+ type RequestQueue struct

+ func NewRequestQueue(maxSize int, timeout time.Duration, logger *slog.Logger) *RequestQueue

+ func (q *RequestQueue) Dequeue(ctx context.Context) (Request, bool)

+ func (q *RequestQueue) Enqueue(req Request) bool

+ func (q *RequestQueue) IsEmpty() bool

+ func (q *RequestQueue) IsFull() bool

+ func (q *RequestQueue) Size() int

+ type Response struct

+ Error *JSONRPCError

+ ID interface{}

+ Result json.RawMessage

+ type ServerHandle struct

+ Name string

+ State ServerState

+ Stats ServerStats

+ type ServerQueue struct

+ func NewServerQueue(name string, maxConcurrent int, queueTimeout time.Duration, ...) *ServerQueue

+ func (sq *ServerQueue) Acquire(timeout time.Duration) bool

+ func (sq *ServerQueue) Dequeue(ctx context.Context) (Request, bool)

+ func (sq *ServerQueue) Enqueue(req Request) bool

+ func (sq *ServerQueue) IsAtCapacity() bool

+ func (sq *ServerQueue) PendingCount() int

+ func (sq *ServerQueue) Release()

+ type ServerState string

+ const StateBusy

+ const StateError

+ const StateIdle

+ const StateRunning

+ const StateStarting

+ const StateStopped

+ const StateStopping

+ type ServerStats struct

+ AvgLatencyMs float64

+ CurrentBackoff time.Duration

+ ErrorCount int64

+ LastRequestAt time.Time

+ RequestCount int64

+ RestartCount int

+ type StdioPool struct

+ func NewStdioPool(maxPerServer int, idleTimeout time.Duration, logger *slog.Logger) *StdioPool

+ func (p *StdioPool) Close() error

+ func (p *StdioPool) GetServer(name string) (*StdioServerV2, error)

+ func (p *StdioPool) GetServerState(name string) (ServerState, error)

+ func (p *StdioPool) GetServerStats(name string) (ServerStats, error)

+ func (p *StdioPool) ListServers() []string

+ func (p *StdioPool) PutRequest(name string, req Request) error

+ func (p *StdioPool) RestartServer(ctx context.Context, name string) error

+ func (p *StdioPool) SendRequest(ctx context.Context, serverName string, req *proxy.JSONRPCRequest, ...) (*proxy.JSONRPCResponse, error)

+ func (p *StdioPool) ServerCount() int

+ func (p *StdioPool) StartAllServers(ctx context.Context, configs []*migrate.ServerConfig) error

+ func (p *StdioPool) StartServer(ctx context.Context, config *migrate.ServerConfig) error

+ func (p *StdioPool) StopServer(name string) error

+ type StdioServerConfig struct

+ Args []string

+ CWD string

+ Command string

+ Env []string

+ IdleTimeout time.Duration

+ MaxConcurrent int

+ Name string

+ RequestTimeout time.Duration

+ type StdioServerV2 struct