Merge pull request #982 from Kuromesi/streamcontext

add clusterid in grpc stream context
kmesh-net · Oct 25, 2024 · 865f832 · 865f832
2 parents a4ca182 + 8c72e4c
commit 865f832
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/controller/client.go b/pkg/controller/client.go
@@ -23,6 +23,7 @@ import (
 
 	discoveryv3 "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3"
 	"google.golang.org/grpc"
+	"google.golang.org/grpc/metadata"
 
 	bpfwl "kmesh.net/kmesh/pkg/bpf/workload"
 	"kmesh.net/kmesh/pkg/constants"
@@ -60,6 +61,7 @@ func NewXdsClient(mode string, bpfWorkload *bpfwl.BpfWorkload, enableAccesslog b
 	}
 
 	client.ctx, client.cancel = context.WithCancel(context.Background())
+	client.ctx = metadata.AppendToOutgoingContext(client.ctx, "ClusterID", client.xdsConfig.Metadata.ClusterID.String())
 	return client
 }