Skip to content

Commit 6caf269

Browse files
authored
fix: add miss fields to PersistentTopicInternalStats (streamnative#477)
Signed-off-by: Zixuan Liu <[email protected]> Signed-off-by: Zixuan Liu <[email protected]>
1 parent bfca5de commit 6caf269

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

pkg/pulsar/utils/data.go

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -265,6 +265,8 @@ type PersistentTopicInternalStats struct {
265265
State string `json:"state"`
266266
Ledgers []LedgerInfo `json:"ledgers"`
267267
Cursors map[string]CursorStats `json:"cursors"`
268+
SchemaLedgers []SchemaLedger `json:"schemaLedgers"`
269+
CompactedLedger CompactedLedger `json:"compactedLedger"`
268270
}
269271

270272
type LedgerInfo struct {
@@ -402,3 +404,19 @@ type PublishRateData struct {
402404
PublishThrottlingRateInMsg int64 `json:"publishThrottlingRateInMsg"`
403405
PublishThrottlingRateInByte int64 `json:"publishThrottlingRateInByte"`
404406
}
407+
408+
type SchemaLedger struct {
409+
LedgerID int64 `json:"ledgerId"`
410+
Entries int64 `json:"entries"`
411+
Size int64 `json:"size"`
412+
Timestamp int64 `json:"timestamp"`
413+
IsOffloaded bool `json:"isOffloaded"`
414+
}
415+
416+
type CompactedLedger struct {
417+
LedgerID int64 `json:"ledgerId"`
418+
Entries int64 `json:"entries"`
419+
Size int64 `json:"size"`
420+
Offloaded bool `json:"offloaded"`
421+
UnderReplicated bool `json:"underReplicated"`
422+
}

0 commit comments

Comments
 (0)