address review: put also the rest to cluster

easegress-io · Mar 16, 2022 · f5415a4 · f5415a4
1 parent 6792093
commit f5415a4
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pkg/object/statussynccontroller/statussynccontroller.go b/pkg/object/statussynccontroller/statussynccontroller.go
@@ -272,6 +272,13 @@ func (ssc *StatusSyncController) syncStatusToCluster(statuses map[string]string)
 			kvs = make(map[string]*string)
 		}
 	}
+	if len(kvs) > 0 {
+		err := ssc.superSpec.Super().Cluster().PutAndDeleteUnderLease(kvs)
+		if err != nil {
+			logger.Errorf("sync status failed. If the message size is too large, "+
+				"please increase the value of cluster.MaxCallSendMsgSize in configuration: %v", err)
+		}
+	}
 }
 
 func (ssc *StatusSyncController) addStatusesRecord(statusesRecord *StatusesRecord) {