proxy

type CentianProxy ¶

type CentianProxy struct {
	Name       string
	ServerID   string // used to uniquely identify this specific object instance
	Config     *config.GlobalConfig
	Mux        *http.ServeMux
	Server     *http.Server
	Logger     *logging.Logger // Shared base logger (ONE file handle)
	Gateways   map[string]*MCPProxy
	APIKeys    *auth.APIKeyStore
	AuthHeader string
}

CentianProxy is the main server struct.

It holds 4 critical components: - mux - used to register URL paths - server - used to serve the mux - logger - main logger for all events in the proxied endpoints - gateways - holds all gateways and proxy endpoints for easy access

Additionally it has a reference to the global config which was loaded to initialize this server.

func NewCentianProxy(globalConfig *config.GlobalConfig) (*CentianProxy, error)

func (c *CentianProxy) Setup() error

type CentianProxySession ¶

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

CentianProxySession represents a session with one or more downstream connections. For single-server mode, the map has exactly one entry. For aggregated mode, the map has multiple entries.

func (s *CentianProxySession) GetConnectionByName(serverName string) (*DownstreamConnection, error)

type DownstreamConnection ¶

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

DownstreamConnection represents a connection to a downstream MCP server.

func NewDownstreamConnection(name string, cfg *config.MCPServerConfig) *DownstreamConnection

func (dc *DownstreamConnection) CallTool(ctx context.Context, toolName string, args map[string]any) (*mcp.CallToolResult, error)

func (dc *DownstreamConnection) Close() error

func (dc *DownstreamConnection) Connect(ctx context.Context, authHeaders map[string]string) error

func (dc *DownstreamConnection) IsConnected() bool

func (dc *DownstreamConnection) Tools() []*mcp.Tool

type EventProcessor ¶

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

EventProcessor is used to call the main processing loop for any MCP transport method.

func NewEventProcessor(logger *logging.Logger, processors *processor.Chain) *EventProcessor

func (ep *EventProcessor) Process(event common.McpEventInterface) error

type HeaderRoundTripper ¶

type HeaderRoundTripper struct {
	Base    http.RoundTripper
	Headers map[string]string
}

HeaderRoundTripper is used to store.

func (rt HeaderRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type MCPProxy ¶

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

MCPProxy is a unified proxy that handles both aggregated (multiple servers with namespaced tools) and single-server (pass-through) modes.

Mode is controlled by the namespaceTools flag:

• true: Aggregated mode - tools are prefixed with "serverName__"
• false: Single mode - tools pass through with original names

func NewAggregatedProxy(name, endpoint string, gatewayConfig *config.GatewayConfig) *MCPProxy

func NewSingleProxy(serverName, endpoint string, serverConfig *config.MCPServerConfig) *MCPProxy

func (p *MCPProxy) Close() error

func (p *MCPProxy) GetServerForRequest(r *http.Request) *mcp.Server

func (p *MCPProxy) NewMcpServer() *mcp.Server