Chore v20 (#871)

* remove envoy mod

* feature: Add xds metrics

Author: mfordjody

.asf.yaml

@@ -20,7 +20,7 @@ notifications:
     jira_options: link label
 
 github:
-  homepage: "https://dubbo-kubernetes.github.io/dsm-docs/"
+  homepage: "https://dubbo-kubernetes.github.io/"
   description: "Dubbo Service Mesh for Kubernetes."
   features:
     # Enable wiki for documentation

dubbod/discovery/pkg/model/push_context.go

@@ -18,6 +18,7 @@ package model
 
 import (
 	"cmp"
+	"encoding/json"
 	"sort"
 	"strings"
 	"sync"
@@ -1153,14 +1154,11 @@ func firstDestinationRule(csr *consolidatedSubRules, hostname host.Name) *networ
 	return nil
 }
 
-func ConfigNamesOfKind(configs sets.Set[ConfigKey], k kind.Kind) sets.String {
-	ret := sets.New[string]()
-
-	for conf := range configs {
-		if conf.Kind == k {
-			ret.Insert(conf.Name)
-		}
+func (ps *PushContext) StatusJSON() ([]byte, error) {
+	if ps == nil {
+		return []byte{'{', '}'}, nil
 	}
-
-	return ret
+	ps.proxyStatusMutex.RLock()
+	defer ps.proxyStatusMutex.RUnlock()
+	return json.MarshalIndent(ps.ProxyStatus, "", "    ")
 }

dubbod/discovery/pkg/xds/discovery.go

@@ -36,6 +36,8 @@ import (
 	"google.golang.org/grpc"
 )
 
+var periodicRefreshMetrics = 10 * time.Second
+
 var processStartTime = time.Now()
 
 type DiscoveryServer struct {
@@ -104,6 +106,7 @@ func (s *DiscoveryServer) Register(rpcs *grpc.Server) {
 func (s *DiscoveryServer) Start(stopCh <-chan struct{}) {
 	go s.handleUpdates(stopCh)
 	go s.sendPushes(stopCh)
+	go s.periodicRefreshMetrics(stopCh)
 	go s.Cache.Run(stopCh)
 }
 
@@ -306,6 +309,29 @@ func doSendPushes(stopCh <-chan struct{}, semaphore chan struct{}, queue *PushQu
 	}
 }
 
+func (s *DiscoveryServer) periodicRefreshMetrics(stopCh <-chan struct{}) {
+	ticker := time.NewTicker(periodicRefreshMetrics)
+	defer ticker.Stop()
+	for {
+		select {
+		case <-ticker.C:
+			push := s.globalPushContext()
+			model.LastPushMutex.Lock()
+			if model.LastPushStatus != push {
+				model.LastPushStatus = push
+				push.UpdateMetrics()
+				out, _ := model.LastPushStatus.StatusJSON()
+				if string(out) != "{}" {
+					log.Infof("Push Status: %s", string(out))
+				}
+			}
+			model.LastPushMutex.Unlock()
+		case <-stopCh:
+			return
+		}
+	}
+}
+
 func (s *DiscoveryServer) dropCacheForRequest(req *model.PushRequest) {
 	// If we don't know what updated, cannot safely cache. Clear the whole cache
 	if req.Forced {