Skip to content

Commit b3ed0e3

Browse files
committed
Intial implementation of openai resposes api
Signed-off-by: Sivanantham Chinnaiyan <[email protected]>
1 parent 9bdd87e commit b3ed0e3

File tree

12 files changed

+2457
-0
lines changed

12 files changed

+2457
-0
lines changed

cmd/extproc/mainlib/main.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -234,6 +234,7 @@ func Main(ctx context.Context, args []string, stderr io.Writer) (err error) {
234234
messagesMetrics := metrics.NewMessages(meter, metricsRequestHeaderAttributes)
235235
completionMetrics := metrics.NewCompletion(meter, metricsRequestHeaderAttributes)
236236
embeddingsMetrics := metrics.NewEmbeddings(meter, metricsRequestHeaderAttributes)
237+
responsesMetrics := metrics.NewResponses(meter, metricsRequestHeaderAttributes)
237238
mcpMetrics := metrics.NewMCP(meter, metricsRequestHeaderAttributes)
238239

239240
tracing, err := tracing.NewTracingFromEnv(ctx, os.Stdout, spanRequestHeaderAttributes)
@@ -248,6 +249,7 @@ func Main(ctx context.Context, args []string, stderr io.Writer) (err error) {
248249
server.Register(path.Join(flags.rootPrefix, "/v1/chat/completions"), extproc.ChatCompletionProcessorFactory(chatCompletionMetrics))
249250
server.Register(path.Join(flags.rootPrefix, "/v1/completions"), extproc.CompletionsProcessorFactory(completionMetrics))
250251
server.Register(path.Join(flags.rootPrefix, "/v1/embeddings"), extproc.EmbeddingsProcessorFactory(embeddingsMetrics))
252+
server.Register(path.Join(flags.rootPrefix, "/v1/responses"), extproc.ResponsesProcessorFactory(responsesMetrics))
251253
server.Register(path.Join(flags.rootPrefix, "/v1/models"), extproc.NewModelsProcessor)
252254
server.Register(path.Join(flags.rootPrefix, "/anthropic/v1/messages"), extproc.MessagesProcessorFactory(messagesMetrics))
253255

internal/apischema/openai/openai.go

Lines changed: 416 additions & 0 deletions
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)