From 8978a4e0e0c21d57543bcfd4d601889f13f8666d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=BE=84=E6=BD=AD?= Date: Tue, 25 Mar 2025 11:20:20 +0800 Subject: [PATCH] fix invalid ai-proxy cluster (#1947) Co-authored-by: Kent Dong --- .../extensions/ai-proxy/provider/cluster.go | 17 ----------------- .../extensions/ai-proxy/provider/context.go | 8 ++++---- 2 files changed, 4 insertions(+), 21 deletions(-) delete mode 100644 plugins/wasm-go/extensions/ai-proxy/provider/cluster.go diff --git a/plugins/wasm-go/extensions/ai-proxy/provider/cluster.go b/plugins/wasm-go/extensions/ai-proxy/provider/cluster.go deleted file mode 100644 index 27e1f580d..000000000 --- a/plugins/wasm-go/extensions/ai-proxy/provider/cluster.go +++ /dev/null @@ -1,17 +0,0 @@ -package provider - -import "fmt" - -type plainCluster struct { - serviceName string - servicePort int64 - hostName string -} - -func (c plainCluster) ClusterName() string { - return fmt.Sprintf("outbound|%d||%s", c.servicePort, c.serviceName) -} - -func (c plainCluster) HostName() string { - return c.hostName -} diff --git a/plugins/wasm-go/extensions/ai-proxy/provider/context.go b/plugins/wasm-go/extensions/ai-proxy/provider/context.go index 84f8eaca2..45fc8568d 100644 --- a/plugins/wasm-go/extensions/ai-proxy/provider/context.go +++ b/plugins/wasm-go/extensions/ai-proxy/provider/context.go @@ -95,10 +95,10 @@ func createContextCache(providerConfig *ProviderConfig) *contextCache { return nil } fileUrlObj, _ := url.Parse(contextConfig.fileUrl) - cluster := plainCluster{ - serviceName: contextConfig.serviceName, - servicePort: contextConfig.servicePort, - hostName: fileUrlObj.Host, + cluster := wrapper.FQDNCluster{ + FQDN: contextConfig.serviceName, + Port: contextConfig.servicePort, + Host: fileUrlObj.Host, } return &contextCache{ client: wrapper.NewClusterClient(cluster),