Method Invoke

internal/adapters/mock/mock.go:24–52

(ctx context.Context, req types.BackendRequest)

}

func (a *Adapter) Invoke(ctx context.Context, req types.BackendRequest) (types.BackendResponse, error) {
	start := time.Now()
	// Simulate small processing latency.
	delay := 20 * time.Millisecond
	select {
	case <-ctx.Done():
		return types.BackendResponse{}, ctx.Err()
	case <-time.After(delay):
	}

	text, _ := req.Input["text"].(string)
	if text == "" {
		text = "No text provided."
	}

	end := time.Now()
	latency := end.Sub(start).Milliseconds()
	return types.BackendResponse{
		Output: map[string]any{
			"text":    fmt.Sprintf("[%s] %s", a.cfg.Name, text),
			"backend": a.cfg.Name,
		},
		Timing: &types.BackendTiming{
			TTFTMs:              latency,
			CompletionLatencyMs: latency,
			Streamed:            false,
		},
	}, nil
}

func (a *Adapter) Health(_ context.Context) error {
	return nil