From 1051201e970a18e4fad5c2c2298a08bf728247e0 Mon Sep 17 00:00:00 2001
From: Jun <108045855+2456868764@users.noreply.github.com>
Date: Sat, 19 Aug 2023 10:40:34 +0800
Subject: [PATCH] add consul cluster (#494)

---
 .../wasm-go/pkg/wrapper/cluster_wrapper.go    | 20 +++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/plugins/wasm-go/pkg/wrapper/cluster_wrapper.go b/plugins/wasm-go/pkg/wrapper/cluster_wrapper.go
index 239ab60f5..cb7f55e9d 100644
--- a/plugins/wasm-go/pkg/wrapper/cluster_wrapper.go
+++ b/plugins/wasm-go/pkg/wrapper/cluster_wrapper.go
@@ -131,3 +131,23 @@ func (c DnsCluster) ClusterName() string {
 func (c DnsCluster) HostName() string {
 	return c.Domain
 }
+
+type ConsulCluster struct {
+	ServiceName string
+	Datacenter  string
+	Port        int64
+	Host        string
+}
+
+func (c ConsulCluster) ClusterName() string {
+	tail := "consul"
+	return fmt.Sprintf("outbound|%d||%s.%s.%s",
+		c.Port, c.ServiceName, c.Datacenter, tail)
+}
+
+func (c ConsulCluster) HostName() string {
+	if c.Host != "" {
+		return c.Host
+	}
+	return c.ServiceName
+}