add estimated backlog size as measure of unconsumed messages (streamnative#860)

wnyffenegger · web-flow · commit c45743edd393 · 2022-10-19T11:38:50.000+08:00
diff --git a/pkg/pulsar/utils/data.go b/pkg/pulsar/utils/data.go
@@ -183,6 +183,7 @@ type NamespacesData struct {
 }
 
 type TopicStats struct {
+	BacklogSize         int64                        `json:"backlogSize"`
 	MsgCounterIn        int64                        `json:"msgInCounter"`
 	MsgCounterOut       int64                        `json:"msgOutCounter"`
 	MsgRateIn           float64                      `json:"msgRateIn"`

Original file line number	Diff line number	Diff line change
`@@ -183,6 +183,7 @@ type NamespacesData struct {`
`183`	`183`	`}`
`184`	`184`
`185`	`185`	`type TopicStats struct {`
	`186`	+ BacklogSize int64 `json:"backlogSize"`
`186`	`187`	MsgCounterIn int64 `json:"msgInCounter"`
`187`	`188`	MsgCounterOut int64 `json:"msgOutCounter"`
`188`	`189`	MsgRateIn float64 `json:"msgRateIn"`