proxy

Jun 7, 2026

Changes in this version

type AuthData

+ CredentialID string

+ Principal *auth.Principal

type CentianServer

+ Authorizer centauth.Authorizer

+ Principals centauth.PrincipalProvider

May 31, 2026

Changes in this version

type CentianProject

+ Logger *logging.Logger

type CentianServer

+ func NewCentianServerWithOptions(globalConfig *config.GlobalConfig, options CentianServerOptions) (*CentianServer, error)

+ type CentianServerOptions struct

+ LoggerFactory func(projectSlug string) (*logging.Logger, error)

+ type DefaultAnnotationHandler struct

+ func (h *DefaultAnnotationHandler) Apply(callCtx CallContext, output *processor.DataContext) error

+ func (h *DefaultAnnotationHandler) AttachPart(callCtx CallContext, input *processor.DataContext)

+ type TaskToolMetadata struct

+ Annotations []any

Apr 18, 2026

Changes in this version

type AuthData

+ Project string

Apr 5, 2026

Changes in this version

+ type CentianProject struct

+ Config *config.ProjectConfig

+ Endpoints []*CentianEndpoint

+ Gateways map[string]*CentianEndpoint

+ OAuth *centoauth.Manager

+ PersistenceStore *persistence.Store

+ Slug string

+ TaskVerification *taskverification.Service

type CentianServer

+ Projects map[string]*CentianProject

Mar 29, 2026

Changes in this version

type CentianServer

+ PersistenceStore *persistence.Store

+ TaskVerification *taskverification.Service

Mar 20, 2026

Changes in this version

type CallContext

+ GetMetaContext func() *common.MetaContext

+ SetMetaContext func(*common.MetaContext)

+ ToLogEntry func() *common.LogEntry

type CentianServer

+ func (c *CentianServer) Close() []error

type DownstreamSessionPool

+ func (p *DownstreamSessionPool) HasActiveConnectWorker(serverName string) bool

type ToolCallContext

+ func (c *ToolCallContext) GetMetaContext() *common.MetaContext

+ func (c *ToolCallContext) SetMetaContext(meta *common.MetaContext)

+ func (c *ToolCallContext) ToLogEntry() *common.LogEntry

Mar 18, 2026

Changes in this version

type CentianServer

+ Endpoints []*CentianEndpoint

+ OAuth *centoauth.Manager

type ConnectionStatus

+ const StatusAuthRequired

+ const StatusRefreshFailed

+ func (s ConnectionStatus) IsAuthRequired() bool

+ func (s ConnectionStatus) IsRefreshFailed() bool

type DownstreamConnectOptions

+ GatewayName string

+ IdentityKey string

Mar 16, 2026

Changes in this version

+ type AuthData struct

+ AuthHeaderName string

+ Gateway string

+ Headers http.Header

+ KeyEntry *auth.APIKeyEntry

+ func (a *AuthData) Clone() *AuthData

type CallContext

+ func CallContextFromContext(ctx context.Context) (CallContext, bool)

+ GetAuthData func() *AuthData

+ type CentianEndpoint struct

+ func NewAggregatedEndpoint(gatewayName, endpoint string, gatewayConfig *config.GatewayConfig) *CentianEndpoint

+ func NewSingleEndpoint(serverName, endpoint string, gatewayConfig *config.GatewayConfig) *CentianEndpoint

+ func (p *CentianEndpoint) Close() []error

+ func (p *CentianEndpoint) GetActiveMCPServerConfigs() map[string]*config.MCPServerConfig

+ func (p *CentianEndpoint) GetOrCreateServerForRequest(r *http.Request) *mcp.Server

+ func (p *CentianEndpoint) ProcessCall(callCtx CallContext, direction common.McpEventDirection, ...) error

+ type CentianServer struct

+ APIKeys *centauth.APIKeyStore

+ AuthHeader string

+ Config *config.GlobalConfig

+ Gateways map[string]*CentianEndpoint

+ Logger *logging.Logger

+ Mux *http.ServeMux

+ Name string

+ Server *http.Server

+ ServerID string

+ func NewCentianServer(globalConfig *config.GlobalConfig) (*CentianServer, error)

+ func (c *CentianServer) Setup() error

type ConnectionStatus

+ const StatusDisconnected

+ func (s ConnectionStatus) IsConnected() bool

+ func (s ConnectionStatus) IsConnecting() bool

+ func (s ConnectionStatus) IsDisconnected() bool

+ func (s ConnectionStatus) IsFailed() bool

+ func (s ConnectionStatus) IsPending() bool

+ type DefaultAuthHandler struct

+ func (h *DefaultAuthHandler) Apply(_ CallContext, _ *processor.DataContext) error

+ func (h *DefaultAuthHandler) AttachPart(callCtx CallContext, input *processor.DataContext)

+ type DownstreamClientState struct

+ CapabilitiesFingerprint string

+ ClientCapabilities *mcp.ClientCapabilities

+ ProtocolVersion string

+ Roots []*mcp.Root

+ RootsFingerprint string

+ type DownstreamConnectOptions struct

+ ClientState DownstreamClientState

+ ElicitationHandler DownstreamElicitationHandler

+ ForwardedHeaders map[string]string

+ LoggingHandler DownstreamLoggingHandler

+ ResourceListChangedHandler DownstreamResourceListChangedHandler

+ ResourceUpdatedHandler DownstreamResourceUpdatedHandler

+ SamplingHandler DownstreamSamplingHandler

type DownstreamConnection

+ func (dc *DownstreamConnection) Complete(ctx context.Context, req *mcp.CompleteRequest) (*mcp.CompleteResult, error)

+ func (dc *DownstreamConnection) DiscoverPrompts(ctx context.Context) error

+ func (dc *DownstreamConnection) DiscoverResourceTemplates(ctx context.Context) error

+ func (dc *DownstreamConnection) DiscoverResources(ctx context.Context) error

+ func (dc *DownstreamConnection) GetPrompt(ctx context.Context, name string, args map[string]string) (*mcp.GetPromptResult, error)

+ func (dc *DownstreamConnection) GetServerName() string

+ func (dc *DownstreamConnection) IsConnecting() bool

+ func (dc *DownstreamConnection) IsDisconnected() bool

+ func (dc *DownstreamConnection) IsFailed() bool

+ func (dc *DownstreamConnection) IsPending() bool

+ func (dc *DownstreamConnection) Prompts() []*mcp.Prompt

+ func (dc *DownstreamConnection) ReadResource(ctx context.Context, uri string) (*mcp.ReadResourceResult, error)

+ func (dc *DownstreamConnection) ResourceTemplates() []*mcp.ResourceTemplate

+ func (dc *DownstreamConnection) Resources() []*mcp.Resource

+ func (dc *DownstreamConnection) SetLoggingLevel(ctx context.Context, params *mcp.SetLoggingLevelParams) error

+ func (dc *DownstreamConnection) Subscribe(ctx context.Context, uri string) error

+ func (dc *DownstreamConnection) SyncClientState(ctx context.Context, clientState *DownstreamClientState) error

+ func (dc *DownstreamConnection) Unsubscribe(ctx context.Context, uri string) error

type DownstreamConnectionInterface

+ Complete func(ctx context.Context, req *mcp.CompleteRequest) (*mcp.CompleteResult, error)

+ DiscoverPrompts func(ctx context.Context) error

+ DiscoverResourceTemplates func(ctx context.Context) error

+ DiscoverResources func(ctx context.Context) error

+ GetPrompt func(ctx context.Context, name string, args map[string]string) (*mcp.GetPromptResult, error)

+ GetServerName func() string

+ IsConnecting func() bool

+ IsDisconnected func() bool

+ IsFailed func() bool

+ IsPending func() bool

+ Prompts func() []*mcp.Prompt

+ ReadResource func(ctx context.Context, uri string) (*mcp.ReadResourceResult, error)

+ ResourceTemplates func() []*mcp.ResourceTemplate

+ Resources func() []*mcp.Resource

+ SetLoggingLevel func(ctx context.Context, params *mcp.SetLoggingLevelParams) error

+ Subscribe func(ctx context.Context, uri string) error

+ SyncClientState func(context.Context, *DownstreamClientState) error

+ Unsubscribe func(ctx context.Context, uri string) error

+ type DownstreamElicitationHandler func(context.Context, *mcp.ElicitRequest) (*mcp.ElicitResult, error)

+ type DownstreamLoggingHandler func(context.Context, *mcp.LoggingMessageRequest)

+ type DownstreamResourceListChangedHandler func(context.Context, *mcp.ResourceListChangedRequest)

+ type DownstreamResourceUpdatedHandler func(context.Context, *mcp.ResourceUpdatedNotificationRequest)

+ type DownstreamSamplingHandler func(context.Context, *mcp.CreateMessageRequest) (*mcp.CreateMessageResult, error)

+ type DownstreamSessionPool struct

+ func (p *DownstreamSessionPool) GetConnectionByServerName(serverName string) (DownstreamConnectionInterface, error)

+ func (p *DownstreamSessionPool) IsConnecting(serverName string) (bool, error)

+ func (p *DownstreamSessionPool) SetConnection(serverName string, conn DownstreamConnectionInterface)

type ToolCallContext

+ func (c *ToolCallContext) GetAuthData() *AuthData

type UpstreamSession

+ func (s *UpstreamSession) GetAuthHeaders(excludedHeader string) map[string]string

+ func (s *UpstreamSession) GetConnectionByServerName(serverName string) (DownstreamConnectionInterface, error)

Mar 12, 2026

Changes in this version

+ type DownstreamConnectionPool struct

+ type UpstreamSession struct

+ func (s *UpstreamSession) GetConnectionByName(serverName string) (DownstreamConnectionInterface, error)

Feb 10, 2026

Changes in this version

+ func ApplyResult(processorConfig *config.ProcessorConfig, result *processor.DataContext, ...) error

+ func GetInput(processorConfig *config.ProcessorConfig, callCtx CallContext) *processor.DataContext

+ func RegisterEndpoint(endpoint string, proxy *MCPProxy, mux *http.ServeMux, ...)

+ func WithCallContext(ctx context.Context, cc CallContext) context.Context

+ type CallContext interface

+ GetDirection func() common.McpEventDirection

+ GetError func() string

+ GetEventInfo func() *common.MCPEvent

+ GetHandler func(part string) (CallContextHandler, bool)

+ GetLogHandler func() LogHandler

+ GetMessageType func() common.McpMessageType

+ GetOriginalRequest func() *mcp.CallToolRequest

+ GetOriginalResult func() *mcp.CallToolResult

+ GetOriginalServerName func() string

+ GetOriginalToolName func() string

+ GetRequest func() *mcp.CallToolRequest

+ GetRequestID func() string

+ GetResult func() *mcp.CallToolResult

+ GetRoutingContext func() *common.RoutingLog

+ GetServerName func() string

+ GetSessionID func() string

+ GetStatus func() int

+ GetToolName func() string

+ HasResult func() bool

+ SendRequest func(ctx context.Context) error

+ SetDirection func(common.McpEventDirection)

+ SetError func(string)

+ SetEventInfo func(*common.MCPEvent)

+ SetHandler func(part string, h CallContextHandler)

+ SetLogHandler func(l LogHandler)

+ SetMessageType func(common.McpMessageType)

+ SetResult func(*mcp.CallToolResult)

+ SetServerName func(string)

+ SetStatus func(int)

+ func NewToolCallContext(ctx context.Context, proxy *MCPProxy, session *CentianProxySession, ...) (CallContext, error)

+ type CallContextHandler interface

+ Apply func(callCtx CallContext, output *processor.DataContext) error

+ AttachPart func(callCtx CallContext, input *processor.DataContext)

+ type ConnectionStatus string

+ const StatusConnected

+ const StatusConnecting

+ const StatusFailed

+ const StatusPending

+ type DefaultLogHandler struct

+ func NewDefaultLogHandler(logger *logging.Logger) *DefaultLogHandler

+ func (h *DefaultLogHandler) Log(callCtx CallContext) error

+ func (h *DefaultLogHandler) ToLogEntry(callCtx CallContext) *common.MCPEvent

+ type DefaultMetaHandler struct

+ func (h *DefaultMetaHandler) Apply(callCtx CallContext, result *processor.DataContext) error

+ func (h *DefaultMetaHandler) AttachPart(callCtx CallContext, input *processor.DataContext)

+ type DefaultPayloadHandler struct

+ func (h *DefaultPayloadHandler) Apply(callCtx CallContext, result *processor.DataContext) error

+ func (h *DefaultPayloadHandler) AttachPart(callCtx CallContext, input *processor.DataContext)

+ type DefaultRoutingHandler struct

+ func (h *DefaultRoutingHandler) Apply(callCtx CallContext, result *processor.DataContext) error

+ func (h *DefaultRoutingHandler) AttachPart(callCtx CallContext, input *processor.DataContext)

type DownstreamConnection

+ func (dc *DownstreamConnection) ConnectedAt() time.Time

+ func (dc *DownstreamConnection) GetConfig() *config.MCPServerConfig

+ func (dc *DownstreamConnection) GetError() error

+ func (dc *DownstreamConnection) GetStatus() ConnectionStatus

+ func (dc *DownstreamConnection) ServerName() string

+ type DownstreamConnectionInterface interface

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

+ Close func() error

+ Connect func(context.Context, map[string]string) error

+ GetConfig func() *config.MCPServerConfig

+ GetError func() error

+ GetStatus func() ConnectionStatus

+ IsConnected func() bool

+ Tools func() []*mcp.Tool

+ type LogHandler interface

+ Log func(callCtx CallContext) error

+ ToLogEntry func(callCtx CallContext) *common.MCPEvent

type MCPProxy

+ func (p *MCPProxy) ProcessCall(callCtx CallContext, direction common.McpEventDirection, ...) error

+ type ProcessingController struct

+ func NewProcessingController(processorConfigs []*config.ProcessorConfig) (*ProcessingController, error)

+ func (ep *ProcessingController) Process(callCtx CallContext) error

+ type ProcessingControllerInterface interface

+ Process func(event CallContext) error

+ type ToolCallContext struct

+ func (c *ToolCallContext) GetDirection() common.McpEventDirection

+ func (c *ToolCallContext) GetError() string

+ func (c *ToolCallContext) GetEventInfo() *common.MCPEvent

+ func (c *ToolCallContext) GetHandler(part string) (CallContextHandler, bool)

+ func (c *ToolCallContext) GetLogHandler() LogHandler

+ func (c *ToolCallContext) GetMessageType() common.McpMessageType

+ func (c *ToolCallContext) GetOriginalRequest() *mcp.CallToolRequest

+ func (c *ToolCallContext) GetOriginalResult() *mcp.CallToolResult

+ func (c *ToolCallContext) GetOriginalServerName() string

+ func (c *ToolCallContext) GetOriginalToolName() string

+ func (c *ToolCallContext) GetRequest() *mcp.CallToolRequest

+ func (c *ToolCallContext) GetRequestID() string

+ func (c *ToolCallContext) GetResult() *mcp.CallToolResult

+ func (c *ToolCallContext) GetRoutingContext() *common.RoutingLog

+ func (c *ToolCallContext) GetServerName() string

+ func (c *ToolCallContext) GetSessionID() string

+ func (c *ToolCallContext) GetStatus() int

+ func (c *ToolCallContext) GetToolName() string

+ func (c *ToolCallContext) HasResult() bool

+ func (c *ToolCallContext) SendRequest(ctx context.Context) error

+ func (c *ToolCallContext) SetDirection(d common.McpEventDirection)

+ func (c *ToolCallContext) SetError(msg string)

+ func (c *ToolCallContext) SetEventInfo(event *common.MCPEvent)

+ func (c *ToolCallContext) SetHandler(part string, h CallContextHandler)

+ func (c *ToolCallContext) SetLogHandler(l LogHandler)

+ func (c *ToolCallContext) SetMessageType(t common.McpMessageType)

+ func (c *ToolCallContext) SetResult(result *mcp.CallToolResult)

+ func (c *ToolCallContext) SetServerName(name string)

+ func (c *ToolCallContext) SetStatus(status int)

Jan 31, 2026

Changes in this version

+ const NamespaceSeparator

+ func RegisterHandler(endpoint string, proxy *MCPProxy, mux *http.ServeMux, ...)

+ type CentianProxy struct

+ APIKeys *auth.APIKeyStore

+ AuthHeader string

+ Config *config.GlobalConfig

+ Gateways map[string]*MCPProxy

+ Logger *logging.Logger

+ Mux *http.ServeMux

+ Name string

+ Server *http.Server

+ ServerID string

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

+ func (c *CentianProxy) Setup() error

+ type CentianProxySession struct

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

+ type DownstreamConnection struct

+ 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 struct

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

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

+ type HeaderRoundTripper struct

+ Base http.RoundTripper

+ Headers map[string]string

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

+ type MCPProxy struct

+ 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