synchro/queue: change HasInitialEvent to HasInitialEvents

Signed-off-by: Iceber Gu <[email protected]>

Author: Iceber

pkg/synchromanager/clustersynchro/default_resource_synchro.go

@@ -315,7 +315,7 @@ func (synchro *resourceSynchro) Start(stopCh <-chan struct{}) {
 		i := informer.NewResourceVersionInformer(synchro.cluster, config)
 		go func() {
 			synchro.initialListPhase.Store(true)
-			if !cache.WaitForCacheSync(informerStopCh, i.HasSynced, func() bool { return !synchro.queue.HasInitialEvent() }) {
+			if !cache.WaitForCacheSync(informerStopCh, i.HasSynced, func() bool { return !synchro.queue.HasInitialEvents() }) {
 				synchro.initialListPhase.Store(false)
 				return
 			}

pkg/synchromanager/resourcesynchro/queue/pressurequeue.go

@@ -123,7 +123,7 @@ func (q *pressurequeue) Done(event *Event) error {
 	return nil
 }
 
-func (q *pressurequeue) HasInitialEvent() bool {
+func (q *pressurequeue) HasInitialEvents() bool {
 	q.lock.Lock()
 	defer q.lock.Unlock()
 	return q.initialCount > 0

pkg/synchromanager/resourcesynchro/queue/queue.go

@@ -14,7 +14,7 @@ type EventQueue interface {
 
 	Len() int
 	DiscardAndRetain(retain int) bool
-	HasInitialEvent() bool
+	HasInitialEvents() bool
 
 	Close()
 }