mcppool

package
v0.19.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 20, 2026 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HTTPPool added in v0.8.96 

type HTTPPool struct {
	// contains filtered or unexported fields
}

HTTPPool manages a pool of HTTP MCP servers

func NewHTTPPool added in v0.8.96 

func NewHTTPPool(ctx context.Context) *HTTPPool

NewHTTPPool creates a new HTTP server pool

func (*HTTPPool) GetRunningCount added in v0.8.96 

func (p *HTTPPool) GetRunningCount() int

GetRunningCount returns the number of running HTTP servers

func (*HTTPPool) GetServer added in v0.8.96 

func (p *HTTPPool) GetServer(name string) *HTTPServer

GetServer returns the HTTP server by name

func (*HTTPPool) GetURL added in v0.8.96 

func (p *HTTPPool) GetURL(name string) string

GetURL returns the URL for an HTTP server

func (*HTTPPool) IsRunning added in v0.8.96 

func (p *HTTPPool) IsRunning(name string) bool

IsRunning checks if an HTTP server is running

func (*HTTPPool) ListServers added in v0.8.96 

func (p *HTTPPool) ListServers() []HTTPServerInfo

ListServers returns info about all HTTP servers

func (*HTTPPool) RegisterExternal added in v0.8.96 

func (p *HTTPPool) RegisterExternal(name, url string) error

RegisterExternal registers an external HTTP server (already running)

func (*HTTPPool) Shutdown added in v0.8.96 

func (p *HTTPPool) Shutdown() error

Shutdown stops all HTTP servers

func (*HTTPPool) Start added in v0.8.96 

func (p *HTTPPool) Start(name, url, healthCheckURL, command string, args []string, env map[string]string, startupTimeout time.Duration) error

Start starts an HTTP server for the given MCP

func (*HTTPPool) StartHealthMonitor added in v0.8.96 

func (p *HTTPPool) StartHealthMonitor()

StartHealthMonitor launches a background goroutine that checks for failed HTTP servers and restarts them automatically

func (*HTTPPool) Stop added in v0.8.96 

func (p *HTTPPool) Stop(name string) error

Stop stops an HTTP server

func (*HTTPPool) StopIfStartedByUs added in v0.8.96 

func (p *HTTPPool) StopIfStartedByUs(name string) error

StopIfStartedByUs stops a server only if we started it (not external)

type HTTPServer added in v0.8.96 

type HTTPServer struct {
	// contains filtered or unexported fields
}

HTTPServer manages an HTTP MCP server process

func NewHTTPServer added in v0.8.96 

func NewHTTPServer(ctx context.Context, name, url, healthCheckURL, command string, args []string, env map[string]string, startupTimeout time.Duration) *HTTPServer

NewHTTPServer creates a new HTTP server manager

func (*HTTPServer) GetLastError added in v0.8.96 

func (s *HTTPServer) GetLastError() error

GetLastError returns the last error encountered

func (*HTTPServer) GetName added in v0.8.96 

func (s *HTTPServer) GetName() string

GetName returns the server name

func (*HTTPServer) GetStatus added in v0.8.96 

func (s *HTTPServer) GetStatus() ServerStatus

GetStatus safely reads the server status

func (*HTTPServer) GetURL added in v0.8.96 

func (s *HTTPServer) GetURL() string

GetURL returns the HTTP endpoint URL

func (*HTTPServer) HealthCheck added in v0.8.96 

func (s *HTTPServer) HealthCheck() error

HealthCheck checks if the server is responding

func (*HTTPServer) IsRunning added in v0.8.96 

func (s *HTTPServer) IsRunning() bool

IsRunning returns true if the server is running

func (*HTTPServer) Restart added in v0.8.96 

func (s *HTTPServer) Restart() error

Restart stops and restarts the server

func (*HTTPServer) SetStatus added in v0.8.96 

func (s *HTTPServer) SetStatus(status ServerStatus)

SetStatus safely updates the server status

func (*HTTPServer) Start added in v0.8.96 

func (s *HTTPServer) Start() error

Start starts the HTTP server process If the URL is already reachable, marks as external and skips process creation

func (*HTTPServer) StartedByUs added in v0.8.96 

func (s *HTTPServer) StartedByUs() bool

StartedByUs returns true if we started this server (vs. external discovery)

func (*HTTPServer) Stop added in v0.8.96 

func (s *HTTPServer) Stop() error

Stop stops the HTTP server process

type HTTPServerInfo added in v0.8.96 

type HTTPServerInfo struct {
	Name        string
	URL         string
	Status      string
	StartedByUs bool
}

HTTPServerInfo provides info about an HTTP server

type JSONRPCRequest 

type JSONRPCRequest struct {
	JSONRPC string      `json:"jsonrpc"`
	Method  string      `json:"method"`
	Params  interface{} `json:"params,omitempty"`
	ID      interface{} `json:"id,omitempty"`
}

type JSONRPCResponse 

type JSONRPCResponse struct {
	JSONRPC string      `json:"jsonrpc"`
	Result  interface{} `json:"result,omitempty"`
	Error   interface{} `json:"error,omitempty"`
	ID      interface{} `json:"id,omitempty"`
}

type Pool 

type Pool struct {
	// contains filtered or unexported fields
}

func NewPool 

func NewPool(ctx context.Context, config *PoolConfig) (*Pool, error)

func (*Pool) DiscoverExistingSockets added in v0.8.1 

func (p *Pool) DiscoverExistingSockets() int

DiscoverExistingSockets scans for existing pool sockets owned by another agent-deck instance and registers them so this instance can use them too. Returns count of discovered sockets.

func (*Pool) FallbackEnabled added in v0.8.1 

func (p *Pool) FallbackEnabled() bool

FallbackEnabled returns whether stdio fallback is allowed when pool isn't working

func (*Pool) GetRunningCount added in v0.8.70 

func (p *Pool) GetRunningCount() int

GetRunningCount returns the number of running MCP proxies

func (*Pool) GetSocketPath 

func (p *Pool) GetSocketPath(name string) string

func (*Pool) GetURL 

func (p *Pool) GetURL(name string) string

func (*Pool) IsRunning 

func (p *Pool) IsRunning(name string) bool

func (*Pool) ListServers 

func (p *Pool) ListServers() []ProxyInfo

func (*Pool) RegisterExternalSocket added in v0.8.1 

func (p *Pool) RegisterExternalSocket(name, socketPath string) error

RegisterExternalSocket registers an external socket owned by another agent-deck instance. This creates a proxy entry that points to the existing socket without starting a new process.

func (*Pool) RestartProxy added in v0.8.1 

func (p *Pool) RestartProxy(name string) error

RestartProxy stops and restarts a proxy that has died

func (*Pool) RestartProxyWithRateLimit added in v0.8.5 

func (p *Pool) RestartProxyWithRateLimit(name string) error

RestartProxyWithRateLimit restarts a proxy with rate limiting to prevent loops

func (*Pool) ShouldPool 

func (p *Pool) ShouldPool(mcpName string) bool

func (*Pool) Shutdown 

func (p *Pool) Shutdown() error

func (*Pool) Start 

func (p *Pool) Start(name, command string, args []string, env map[string]string) error

func (*Pool) StartHealthMonitor added in v0.8.5 

func (p *Pool) StartHealthMonitor()

StartHealthMonitor launches a background goroutine that checks for failed proxies every 3 seconds and restarts them automatically.

type PoolConfig 

type PoolConfig struct {
	Enabled       bool
	PoolAll       bool
	ExcludeMCPs   []string
	PoolMCPs      []string
	FallbackStdio bool
}

type ProxyInfo 

type ProxyInfo struct {
	Name       string
	SocketPath string
	Status     string
	Clients    int
}

type ServerStatus 

type ServerStatus int

ServerStatus represents MCP server state 

const (
	StatusStopped ServerStatus = iota
	StatusStarting
	StatusRunning
	StatusFailed
	StatusPermanentlyFailed
)

func (ServerStatus) String 

func (s ServerStatus) String() string

type SocketProxy 

type SocketProxy struct {
	Status ServerStatus
	// contains filtered or unexported fields
}

SocketProxy wraps a stdio MCP process with a Unix socket

func NewSocketProxy 

func NewSocketProxy(ctx context.Context, name, command string, args []string, env map[string]string) (*SocketProxy, error)

func (*SocketProxy) GetClientCount 

func (p *SocketProxy) GetClientCount() int

func (*SocketProxy) GetSocketPath 

func (p *SocketProxy) GetSocketPath() string

func (*SocketProxy) GetStatus added in v0.8.5 

func (p *SocketProxy) GetStatus() ServerStatus

GetStatus safely reads the proxy status

func (*SocketProxy) HealthCheck 

func (p *SocketProxy) HealthCheck() error

func (*SocketProxy) SetStatus added in v0.8.5 

func (p *SocketProxy) SetStatus(s ServerStatus)

SetStatus safely updates the proxy status

func (*SocketProxy) Start 

func (p *SocketProxy) Start() error

func (*SocketProxy) Stop 

func (p *SocketProxy) Stop() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.