Method newMessageWithKey

aibridge/intercept/messages/blocking.go:356–362

newMessageWithKey performs a single upstream call.

(ctx context.Context, svc anthropic.MessageService, extraOpts ...option.RequestOption)

// newMessageWithKey performs a single upstream call.
func (i *BlockingInterception) newMessageWithKey(ctx context.Context, svc anthropic.MessageService, extraOpts ...option.RequestOption) (_ *anthropic.Message, outErr error) {
	_, span := i.tracer.Start(ctx, "Intercept.ProcessRequest.Upstream", trace.WithAttributes(tracing.InterceptionAttributesFromContext(ctx)...))
	defer tracing.EndSpanErr(span, &outErr)

	opts := append([]option.RequestOption{i.withBody()}, extraOpts...)
	return svc.New(ctx, anthropic.MessageNewParams{}, opts...)
}

// newMessageWithKeyFailover walks the centralized key pool,
// trying each key until one succeeds or the pool is exhausted.