middlewares

Documentation

Index

• Constants
• type A2AMiddleware
  • func NewA2AMiddleware(registry providers.ProviderRegistry, a2aClient a2a.A2AClientInterface, ...) (A2AMiddleware, error)
• type A2AMiddlewareImpl
  • func (m *A2AMiddlewareImpl) Middleware() gin.HandlerFunc
• type A2AProviderModelResult
• type ErrorResponse
• type Logger
  • func NewLoggerMiddleware(logger *logger.Logger) (Logger, error)
• type LoggerImpl
  • func (l LoggerImpl) Middleware() gin.HandlerFunc
• type MCPMiddleware
  • func NewMCPMiddleware(registry providers.ProviderRegistry, inferenceGatewayClient providers.Client, ...) (MCPMiddleware, error)
• type MCPMiddlewareImpl
  • func (m *MCPMiddlewareImpl) Middleware() gin.HandlerFunc
• type MCPProviderModelResult
• type NoopA2AMiddlewareImpl
  • func (n *NoopA2AMiddlewareImpl) Middleware() gin.HandlerFunc
• type NoopMCPMiddlewareImpl
  • func (n *NoopMCPMiddlewareImpl) Middleware() gin.HandlerFunc
• type OIDCAuthenticator
  • func NewOIDCAuthenticatorMiddleware(logger logger.Logger, cfg config.Config) (OIDCAuthenticator, error)
• type OIDCAuthenticatorImpl
  • func (a *OIDCAuthenticatorImpl) Middleware() gin.HandlerFunc
• type OIDCAuthenticatorNoop
  • func (a *OIDCAuthenticatorNoop) Middleware() gin.HandlerFunc
• type Telemetry
  • func NewTelemetryMiddleware(cfg config.Config, telemetry otel.OpenTelemetry, logger logger.Logger) (Telemetry, error)
• type TelemetryImpl
  • func (t *TelemetryImpl) Middleware() gin.HandlerFunc

Constants

const (
	AuthTokenContextKey contextKey = "authToken"
	IDTokenContextKey   contextKey = "idToken"
)

const (
	// MCPBypassHeader marks internal MCP requests to prevent middleware loops
	MCPBypassHeader = "X-MCP-Bypass"

	// MaxMCPAgentIterations limits the number of agent loop iterations
	MaxMCPAgentIterations = 10
)

const (
	A2ABypassHeader = "X-A2A-Bypass"
)

const (
	// ChatCompletionsPath is the endpoint path for chat completions
	ChatCompletionsPath = "/v1/chat/completions"
)

Types

type A2AMiddleware

type A2AMiddleware interface {
	Middleware() gin.HandlerFunc
}

A2AMiddleware defines the interface for A2A middleware

func NewA2AMiddleware

func NewA2AMiddleware(registry providers.ProviderRegistry, a2aClient a2a.A2AClientInterface, a2aAgent a2a.Agent, log logger.Logger, inferenceGatewayClient providers.Client, cfg config.Config) (A2AMiddleware, error)

NewA2AMiddleware creates a new A2A middleware instance

type A2AMiddlewareImpl

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

A2AMiddlewareImpl implements the A2A middleware

func (*A2AMiddlewareImpl) Middleware

func (m *A2AMiddlewareImpl) Middleware() gin.HandlerFunc

Middleware returns the A2A middleware handler

type A2AProviderModelResult

type A2AProviderModelResult struct {
	Provider      providers.IProvider
	ProviderModel string
	ProviderID    *providers.Provider
}

A2AProviderModelResult contains the result of provider and model determination

type ErrorResponse

type ErrorResponse struct {
	Error string `json:"error"`
}

type Logger

type Logger interface {
	Middleware() gin.HandlerFunc
}

func NewLoggerMiddleware

func NewLoggerMiddleware(logger *logger.Logger) (Logger, error)

type LoggerImpl

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

func (LoggerImpl) Middleware

func (l LoggerImpl) Middleware() gin.HandlerFunc

type MCPMiddleware

type MCPMiddleware interface {
	Middleware() gin.HandlerFunc
}

MCPMiddleware defines the interface for MCP middleware

func NewMCPMiddleware

func NewMCPMiddleware(registry providers.ProviderRegistry, inferenceGatewayClient providers.Client, mcpClient mcp.MCPClientInterface, mcpAgent mcp.Agent, log logger.Logger, cfg config.Config) (MCPMiddleware, error)

NewMCPMiddleware creates a new MCP middleware instance

type MCPMiddlewareImpl

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

MCPMiddlewareImpl implements the MCP middleware

func (*MCPMiddlewareImpl) Middleware

func (m *MCPMiddlewareImpl) Middleware() gin.HandlerFunc

Middleware returns the MCP middleware handler

type MCPProviderModelResult

type MCPProviderModelResult struct {
	Provider      providers.IProvider
	ProviderModel string
	ProviderID    *providers.Provider
}

MCPProviderModelResult contains the result of provider and model determination

type NoopA2AMiddlewareImpl

type NoopA2AMiddlewareImpl struct{}

NoopA2AMiddlewareImpl is a no-operation implementation of A2AMiddleware

func (*NoopA2AMiddlewareImpl) Middleware

func (n *NoopA2AMiddlewareImpl) Middleware() gin.HandlerFunc

Middleware returns a no-op handler for the noop implementation

type NoopMCPMiddlewareImpl

type NoopMCPMiddlewareImpl struct{}

NoopMCPMiddlewareImpl is a no-op implementation of MCPMiddleware

func (*NoopMCPMiddlewareImpl) Middleware

func (n *NoopMCPMiddlewareImpl) Middleware() gin.HandlerFunc

Middleware returns the no-op middleware handler

type OIDCAuthenticator

type OIDCAuthenticator interface {
	Middleware() gin.HandlerFunc
}

func NewOIDCAuthenticatorMiddleware

func NewOIDCAuthenticatorMiddleware(logger logger.Logger, cfg config.Config) (OIDCAuthenticator, error)

NewOIDCAuthenticatorMiddleware creates a new OIDCAuthenticator instance

type OIDCAuthenticatorImpl

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

func (*OIDCAuthenticatorImpl) Middleware

func (a *OIDCAuthenticatorImpl) Middleware() gin.HandlerFunc

Middleware implementation of the OIDCAuthenticator interface

type OIDCAuthenticatorNoop

type OIDCAuthenticatorNoop struct{}

func (*OIDCAuthenticatorNoop) Middleware

func (a *OIDCAuthenticatorNoop) Middleware() gin.HandlerFunc

Noop implementation of the OIDCAuthenticator interface

type Telemetry

type Telemetry interface {
	Middleware() gin.HandlerFunc
}

func NewTelemetryMiddleware

func NewTelemetryMiddleware(cfg config.Config, telemetry otel.OpenTelemetry, logger logger.Logger) (Telemetry, error)

type TelemetryImpl

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

func (*TelemetryImpl) Middleware

func (t *TelemetryImpl) Middleware() gin.HandlerFunc