(ctx context.Context, logger slog.Logger, resp *http.Response)
| 253 | } |
| 254 | |
| 255 | func (r *Runner) handleNonStreamingResponse(ctx context.Context, logger slog.Logger, resp *http.Response) error { |
| 256 | switch r.cfg.Provider { |
| 257 | case "messages": |
| 258 | return r.handleMessagesResponse(ctx, logger, resp) |
| 259 | case "responses": |
| 260 | return r.handleResponsesResponse(ctx, logger, resp) |
| 261 | case "completions": |
| 262 | return r.handleCompletionsResponse(ctx, logger, resp) |
| 263 | default: |
| 264 | return xerrors.Errorf("unsupported provider: %s", r.cfg.Provider) |
| 265 | } |
| 266 | } |
| 267 | |
| 268 | func (r *Runner) handleCompletionsResponse(ctx context.Context, logger slog.Logger, resp *http.Response) error { |
| 269 | var response struct { |
no test coverage detected