Bump version to 2.8.0-rc-202106151929 (streamnative/pulsarctl#372)

* Created by streamnative-ci * Fix the failure tests * Fix the tests * Fix the failure tests * Fix the failure tests * Fix the failure tests Co-authored-by: streamnativebot <streamnativebot@users.noreply.github.com> Co-authored-by: Yong Zhang <zhangyong1025.zy@gmail.com>
apache · Aug 16, 2023 · 93c0e45 · 93c0e45
1 parent d5b6ddf
commit 93c0e45
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/pulsaradmin/pkg/pulsar/utils/backlog_quota.go b/pulsaradmin/pkg/pulsar/utils/backlog_quota.go
@@ -20,14 +20,16 @@ package utils
 import "github.com/pkg/errors"
 
 type BacklogQuota struct {
-	Limit  int64           `json:"limit"`
-	Policy RetentionPolicy `json:"policy"`
+	LimitTime int64           `json:"limitTime"`
+	LimitSize int64           `json:"limitSize"`
+	Policy    RetentionPolicy `json:"policy"`
 }
 
-func NewBacklogQuota(limit int64, policy RetentionPolicy) BacklogQuota {
+func NewBacklogQuota(limitSize int64, limitTime int64, policy RetentionPolicy) BacklogQuota {
 	return BacklogQuota{
-		Limit:  limit,
-		Policy: policy,
+		LimitSize: limitSize,
+		LimitTime: limitTime,
+		Policy:    policy,
 	}
 }
 

diff --git a/pulsaradmin/pkg/pulsar/utils/data.go b/pulsaradmin/pkg/pulsar/utils/data.go
@@ -171,6 +171,7 @@ type NamespacesData struct {
 	ClusterIds                     string   `json:"clusterIds"`
 	RetentionTimeStr               string   `json:"retentionTimeStr"`
 	LimitStr                       string   `json:"limitStr"`
+	LimitTime                      int64    `json:"limitTime"`
 	PolicyStr                      string   `json:"policyStr"`
 	AntiAffinityGroup              string   `json:"antiAffinityGroup"`
 	Tenant                         string   `json:"tenant"`