add test to check when logs synced success

Author: Revolyssup

pkg/dashboard/route.go

@@ -55,7 +55,21 @@ func (r *routeClient) Get(ctx context.Context, name string) (*v1.Route, error) {
 
 // List is only used in cache warming up. So here just pass through
 // to APISIX.
-func (r *routeClient) List(ctx context.Context, args ...interface{}) ([]*v1.Route, error) {
+func (r *routeClient) List(ctx context.Context, listOptions ...interface{}) ([]*v1.Route, error) {
+	var options ListOptions
+	if len(listOptions) > 0 {
+		options = listOptions[0].(ListOptions)
+	}
+	if options.From == ListFromCache {
+		log.Debugw("try to list routes in cache",
+			zap.String("cluster", r.cluster.name),
+			zap.String("url", r.url),
+		)
+		return r.cluster.cache.ListRoutes("label",
+			options.KindLabel.Kind,
+			options.KindLabel.Namespace,
+			options.KindLabel.Name)
+	}
 	log.Debugw("try to list routes in APISIX",
 		zap.String("cluster", r.cluster.name),
 		zap.String("url", r.url),

test/e2e/framework/ingress.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	_ "embed"
 	"text/template"
+	"time"
 
 	"github.com/Masterminds/sprig/v3"
 	"github.com/gruntwork-io/terratest/modules/k8s"
@@ -48,4 +49,5 @@ func (f *Framework) DeployIngress(opts IngressDeployOpts) {
 		LabelSelector: "control-plane=controller-manager",
 	})
 	f.GomegaT.Expect(err).ToNot(HaveOccurred(), "waiting for controller-manager pod ready")
+	f.WaitControllerManagerLog("All cache synced successfully", 0, time.Minute)
 }

test/e2e/framework/utils.go

@@ -290,6 +290,10 @@ func (f *Framework) WaitMTLSDPLog(keyword string, sinceSeconds int64, timeout ti
 	f.WaitPodsLog("app.kubernetes.io/name=apisix,cp-connection=mtls", keyword, sinceSeconds, timeout)
 }
 
+func (f *Framework) WaitControllerManagerLog(keyword string, sinceSeconds int64, timeout time.Duration) {
+	f.WaitPodsLog("control-plane=controller-manager", keyword, sinceSeconds, timeout)
+}
+
 func (f *Framework) WaitDPLog(keyword string, sinceSeconds int64, timeout time.Duration) {
 	f.WaitPodsLog("app.kubernetes.io/name=apisix", keyword, sinceSeconds, timeout)
 }