aibridge

package module

Go to main page

Versions in this module

v0

v0.3.0

Dec 5, 2025

Changes in this version

type AnthropicMessagesBlockingInterception

+ func (i *AnthropicMessagesBlockingInterception) TraceAttributes(r *http.Request) []attribute.KeyValue

type AnthropicMessagesStreamingInterception

+ func (s *AnthropicMessagesStreamingInterception) TraceAttributes(r *http.Request) []attribute.KeyValue

type Interceptor

+ TraceAttributes func(*http.Request) []attribute.KeyValue

type OpenAIBlockingChatInterception

+ func (s *OpenAIBlockingChatInterception) TraceAttributes(r *http.Request) []attribute.KeyValue

type OpenAIStreamingChatInterception

+ func (s *OpenAIStreamingChatInterception) TraceAttributes(r *http.Request) []attribute.KeyValue

v0.2.2

Dec 3, 2025

v0.2.1

Dec 3, 2025

v0.2.0

Nov 24, 2025

Changes in this version

+ const InterceptionCountStatusCompleted

+ const InterceptionCountStatusFailed

type AnthropicMessagesBlockingInterception

+ func (s *AnthropicMessagesBlockingInterception) Streaming() bool

type AnthropicMessagesStreamingInterception

+ func (s *AnthropicMessagesStreamingInterception) Streaming() bool

type AsyncRecorder

+ func (a *AsyncRecorder) WithInitiatorID(initiatorID string)

+ func (a *AsyncRecorder) WithMetrics(metrics *Metrics)

+ func (a *AsyncRecorder) WithModel(model string)

+ func (a *AsyncRecorder) WithProvider(provider string)

type Interceptor

+ Streaming func() bool

+ type Metrics struct

+ InjectedToolUseCount *prometheus.CounterVec

+ InterceptionCount *prometheus.CounterVec

+ InterceptionDuration *prometheus.HistogramVec

+ InterceptionsInflight *prometheus.GaugeVec

+ NonInjectedToolUseCount *prometheus.CounterVec

+ PassthroughCount *prometheus.CounterVec

+ PromptCount *prometheus.CounterVec

+ TokenUseCount *prometheus.CounterVec

+ func NewMetrics(reg prometheus.Registerer) *Metrics

type OpenAIBlockingChatInterception

+ func (s *OpenAIBlockingChatInterception) Streaming() bool

type OpenAIErrorResponse

+ ErrorObject *shared.ErrorObject

type OpenAIStreamingChatInterception

+ func (i *OpenAIStreamingChatInterception) Streaming() bool

type TokenUsageRecord

+ ExtraTokenTypes map[string]int64

v0.1.7

Nov 12, 2025

v0.1.6

Oct 28, 2025

Changes in this version

+ type AWSBedrockConfig struct

+ AccessKey string

+ AccessKeySecret string

+ EndpointOverride string

+ Model string

+ Region string

+ SmallFastModel string

+ type AnthropicConfig ProviderConfig

type Config

+ Bedrock AWSBedrockConfig

+ type OpenAIConfig ProviderConfig

v0.1.5

Oct 27, 2025

Changes in this version

type AsyncRecorder

+ func (a *AsyncRecorder) RecordInterceptionEnded(ctx context.Context, req *InterceptionRecordEnded) error

+ type InterceptionRecordEnded struct

+ EndedAt time.Time

+ ID string

type Recorder

+ RecordInterceptionEnded func(ctx context.Context, req *InterceptionRecordEnded) error

type RecorderWrapper

+ func (r *RecorderWrapper) RecordInterceptionEnded(ctx context.Context, req *InterceptionRecordEnded) error

v0.1.4

Oct 22, 2025

Changes in this version

+ const ProviderAnthropic

+ const ProviderOpenAI

+ const SSEEventTypeError

+ const SSEEventTypeMessage

+ const SSEEventTypePing

+ var ErrEventStreamClosed = errors.New("event stream closed")

+ var UnknownRoute = errors.New("unknown route")

+ func AsActor(ctx context.Context, actorID string, metadata Metadata) context.Context

+ type AnthropicErrorResponse struct

+ StatusCode int

+ func (a *AnthropicErrorResponse) Error() string

+ type AnthropicMessagesBlockingInterception struct

+ func NewAnthropicMessagesBlockingInterception(id uuid.UUID, req *MessageNewParamsWrapper, baseURL, key string) *AnthropicMessagesBlockingInterception

+ func (i *AnthropicMessagesBlockingInterception) ProcessRequest(w http.ResponseWriter, r *http.Request) error

+ func (s *AnthropicMessagesBlockingInterception) Setup(logger slog.Logger, recorder Recorder, mcpProxy mcp.ServerProxier)

+ type AnthropicMessagesInterceptionBase struct

+ func (i *AnthropicMessagesInterceptionBase) ID() uuid.UUID

+ func (i *AnthropicMessagesInterceptionBase) Model() string

+ func (i *AnthropicMessagesInterceptionBase) Setup(logger slog.Logger, recorder Recorder, mcpProxy mcp.ServerProxier)

+ type AnthropicMessagesStreamingInterception struct

+ func NewAnthropicMessagesStreamingInterception(id uuid.UUID, req *MessageNewParamsWrapper, baseURL, key string) *AnthropicMessagesStreamingInterception

+ func (i *AnthropicMessagesStreamingInterception) ProcessRequest(w http.ResponseWriter, r *http.Request) error

+ func (s *AnthropicMessagesStreamingInterception) Setup(logger slog.Logger, recorder Recorder, mcpProxy mcp.ServerProxier)

+ type AnthropicProvider struct

+ func NewAnthropicProvider(cfg ProviderConfig) *AnthropicProvider

+ func (p *AnthropicProvider) AuthHeader() string

+ func (p *AnthropicProvider) BaseURL() string

+ func (p *AnthropicProvider) BridgedRoutes() []string

+ func (p *AnthropicProvider) CreateInterceptor(w http.ResponseWriter, r *http.Request) (Interceptor, error)

+ func (p *AnthropicProvider) InjectAuthHeader(headers *http.Header)

+ func (p *AnthropicProvider) Name() string

+ func (p *AnthropicProvider) PassthroughRoutes() []string

+ type AsyncRecorder struct

+ func NewAsyncRecorder(logger slog.Logger, wrapped Recorder, timeout time.Duration) *AsyncRecorder

+ func (a *AsyncRecorder) RecordInterception(ctx context.Context, req *InterceptionRecord) error

+ func (a *AsyncRecorder) RecordPromptUsage(_ context.Context, req *PromptUsageRecord) error

+ func (a *AsyncRecorder) RecordTokenUsage(_ context.Context, req *TokenUsageRecord) error

+ func (a *AsyncRecorder) RecordToolUsage(_ context.Context, req *ToolUsageRecord) error

+ func (a *AsyncRecorder) Wait()

+ type ChatCompletionNewParamsWrapper struct

+ Stream bool

+ func (c *ChatCompletionNewParamsWrapper) LastUserPrompt() (*string, error)

+ func (c *ChatCompletionNewParamsWrapper) UnmarshalJSON(raw []byte) error

+ func (c ChatCompletionNewParamsWrapper) MarshalJSON() ([]byte, error)

+ type Config struct

+ Anthropic ProviderConfig

+ OpenAI ProviderConfig

+ type InterceptionRecord struct

+ ID string

+ InitiatorID string

+ Metadata Metadata

+ Model string

+ Provider string

+ StartedAt time.Time

+ type Interceptor interface

+ ID func() uuid.UUID

+ Model func() string

+ ProcessRequest func(w http.ResponseWriter, r *http.Request) error

+ Setup func(logger slog.Logger, recorder Recorder, mcpProxy mcp.ServerProxier)

+ type MessageNewParamsWrapper struct

+ Stream bool

+ func (b *MessageNewParamsWrapper) LastUserPrompt() (*string, error)

+ func (b *MessageNewParamsWrapper) UnmarshalJSON(raw []byte) error

+ func (b *MessageNewParamsWrapper) UseStreaming() bool

+ func (b MessageNewParamsWrapper) MarshalJSON() ([]byte, error)

+ type Metadata map[string]any

+ type OpenAIBlockingChatInterception struct

+ func NewOpenAIBlockingChatInterception(id uuid.UUID, req *ChatCompletionNewParamsWrapper, baseURL, key string) *OpenAIBlockingChatInterception

+ func (i *OpenAIBlockingChatInterception) ProcessRequest(w http.ResponseWriter, r *http.Request) error

+ func (s *OpenAIBlockingChatInterception) Setup(logger slog.Logger, recorder Recorder, mcpProxy mcp.ServerProxier)

+ type OpenAIChatInterceptionBase struct

+ func (i *OpenAIChatInterceptionBase) ID() uuid.UUID

+ func (i *OpenAIChatInterceptionBase) Model() string

+ func (i *OpenAIChatInterceptionBase) Setup(logger slog.Logger, recorder Recorder, mcpProxy mcp.ServerProxier)

+ type OpenAIErrorResponse struct

+ StatusCode int

+ func (a *OpenAIErrorResponse) Error() string

+ type OpenAIProvider struct

+ func NewOpenAIProvider(cfg ProviderConfig) *OpenAIProvider

+ func (p *OpenAIProvider) AuthHeader() string

+ func (p *OpenAIProvider) BaseURL() string

+ func (p *OpenAIProvider) BridgedRoutes() []string

+ func (p *OpenAIProvider) CreateInterceptor(w http.ResponseWriter, r *http.Request) (Interceptor, error)

+ func (p *OpenAIProvider) InjectAuthHeader(headers *http.Header)

+ func (p *OpenAIProvider) Name() string

+ func (p *OpenAIProvider) PassthroughRoutes() []string

+ type OpenAIStreamingChatInterception struct

+ func NewOpenAIStreamingChatInterception(id uuid.UUID, req *ChatCompletionNewParamsWrapper, baseURL, key string) *OpenAIStreamingChatInterception

+ func (i *OpenAIStreamingChatInterception) ProcessRequest(w http.ResponseWriter, r *http.Request) error

+ func (i *OpenAIStreamingChatInterception) Setup(logger slog.Logger, recorder Recorder, mcpProxy mcp.ServerProxier)

+ type PromptUsageRecord struct

+ CreatedAt time.Time

+ InterceptionID string

+ Metadata Metadata

+ MsgID string

+ Prompt string

+ type Provider interface

+ AuthHeader func() string

+ BaseURL func() string

+ BridgedRoutes func() []string

+ CreateInterceptor func(w http.ResponseWriter, r *http.Request) (Interceptor, error)

+ InjectAuthHeader func(*http.Header)

+ Name func() string

+ PassthroughRoutes func() []string

+ type ProviderConfig struct

+ BaseURL string

+ Key string

+ type Recorder interface

+ RecordInterception func(ctx context.Context, req *InterceptionRecord) error

+ RecordPromptUsage func(ctx context.Context, req *PromptUsageRecord) error

+ RecordTokenUsage func(ctx context.Context, req *TokenUsageRecord) error

+ RecordToolUsage func(ctx context.Context, req *ToolUsageRecord) error

+ type RecorderWrapper struct

+ func NewRecorder(logger slog.Logger, clientFn func() (Recorder, error)) *RecorderWrapper

+ func (r *RecorderWrapper) RecordInterception(ctx context.Context, req *InterceptionRecord) error

+ func (r *RecorderWrapper) RecordPromptUsage(ctx context.Context, req *PromptUsageRecord) error

+ func (r *RecorderWrapper) RecordTokenUsage(ctx context.Context, req *TokenUsageRecord) error

+ func (r *RecorderWrapper) RecordToolUsage(ctx context.Context, req *ToolUsageRecord) error

+ type RequestBridge struct

+ func NewRequestBridge(ctx context.Context, providers []Provider, logger slog.Logger, ...) (*RequestBridge, error)

+ func (b *RequestBridge) InflightRequests() int32

+ func (b *RequestBridge) ServeHTTP(rw http.ResponseWriter, r *http.Request)

+ func (b *RequestBridge) Shutdown(ctx context.Context) error

+ type SSEEvent struct

+ Data string

+ ID string

+ Retry int

+ Type string

+ type SSEParser struct

+ func NewSSEParser() *SSEParser

+ func (p *SSEParser) AllEvents() map[string][]SSEEvent

+ func (p *SSEParser) EventsByType(eventType string) []SSEEvent

+ func (p *SSEParser) MessageEvents() []SSEEvent

+ func (p *SSEParser) Parse(reader io.Reader) error

+ type TokenUsageRecord struct

+ CreatedAt time.Time

+ Input int64

+ InterceptionID string

+ Metadata Metadata

+ MsgID string

+ Output int64

+ type ToolArgs any

+ type ToolUsageRecord struct

+ Args ToolArgs

+ CreatedAt time.Time

+ Injected bool

+ InterceptionID string

+ InvocationError error

+ Metadata Metadata

+ MsgID string

+ ServerURL *string

+ Tool string

v0.1.3

Sep 30, 2025

v0.1.2

Sep 29, 2025

v0.1.0

Sep 25, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL