@@ -66,31 +66,31 @@ type TopicStatistics struct {
6666 MsgThroughputIn float64 `json:"msgThroughputIn,omitempty"`
6767 MsgRateOut float64 `json:"msgRateOut,omitempty"`
6868 MsgThroughputOut float64 `json:"msgThroughputOut,omitempty"`
69- BytesInCounter uint64 `json:"bytesInCounter,omitempty"`
70- MsgInCounter uint64 `json:"msgInCounter,omitempty"`
71- BytesOutCounter uint64 `json:"bytesOutCounter,omitempty"`
72- MsgOutCounter uint64 `json:"msgOutCounter,omitempty"`
69+ BytesInCounter int64 `json:"bytesInCounter,omitempty"`
70+ MsgInCounter int64 `json:"msgInCounter,omitempty"`
71+ BytesOutCounter int64 `json:"bytesOutCounter,omitempty"`
72+ MsgOutCounter int64 `json:"msgOutCounter,omitempty"`
7373 AverageMsgSize float64 `json:"averageMsgSize,omitempty"`
7474 MsgChunkPublished bool `json:"msgChunkPublished,omitempty"`
75- StorageSize uint64 `json:"storageSize,omitempty"`
76- BacklogSize uint64 `json:"backlogSize,omitempty"`
77- PublishRateLimitedTimes uint64 `json:"publishRateLimitedTimes,omitempty"`
78- EarliestMsgPublishTimeInBacklogs uint64 `json:"earliestMsgPublishTimeInBacklogs,omitempty"`
79- OffloadedStorageSize uint64 `json:"offloadedStorageSize,omitempty"`
80- LastOffloadLedgerId uint64 `json:"lastOffloadLedgerId,omitempty"`
81- LastOffloadSuccessTimeStamp uint64 `json:"lastOffloadSuccessTimeStamp,omitempty"`
82- LastOffloadFailureTimeStamp uint64 `json:"lastOffloadFailureTimeStamp,omitempty"`
83- OngoingTxnCount uint64 `json:"ongoingTxnCount,omitempty"`
84- AbortedTxnCount uint64 `json:"abortedTxnCount,omitempty"`
85- CommittedTxnCount uint64 `json:"committedTxnCount,omitempty"`
75+ StorageSize int64 `json:"storageSize,omitempty"`
76+ BacklogSize int64 `json:"backlogSize,omitempty"`
77+ PublishRateLimitedTimes int64 `json:"publishRateLimitedTimes,omitempty"`
78+ EarliestMsgPublishTimeInBacklogs int64 `json:"earliestMsgPublishTimeInBacklogs,omitempty"`
79+ OffloadedStorageSize int64 `json:"offloadedStorageSize,omitempty"`
80+ LastOffloadLedgerId int64 `json:"lastOffloadLedgerId,omitempty"`
81+ LastOffloadSuccessTimeStamp int64 `json:"lastOffloadSuccessTimeStamp,omitempty"`
82+ LastOffloadFailureTimeStamp int64 `json:"lastOffloadFailureTimeStamp,omitempty"`
83+ OngoingTxnCount int64 `json:"ongoingTxnCount,omitempty"`
84+ AbortedTxnCount int64 `json:"abortedTxnCount,omitempty"`
85+ CommittedTxnCount int64 `json:"committedTxnCount,omitempty"`
8686 Publishers []Publisher `json:"publishers,omitempty"`
87- WaitingPublishers uint64 `json:"waitingPublishers,omitempty"`
87+ WaitingPublishers int64 `json:"waitingPublishers,omitempty"`
8888 Subscriptions map [string ]SubscriptionStats `json:"subscriptions,omitempty"`
8989 Replication map [string ]string `json:"replication,omitempty"`
9090 DeduplicationStatus string `json:"deduplicationStatus,omitempty"`
91- NonContiguousDeletedMessagesRanges uint64 `json:"nonContiguousDeletedMessagesRanges,omitempty"`
92- NonContiguousDeletedMessagesRangesSerializedSize uint64 `json:"nonContiguousDeletedMessagesRangesSerializedSize,omitempty"`
93- DelayedMessageIndexSizeInBytes uint64 `json:"delayedMessageIndexSizeInBytes,omitempty"`
91+ NonContiguousDeletedMessagesRanges int64 `json:"nonContiguousDeletedMessagesRanges,omitempty"`
92+ NonContiguousDeletedMessagesRangesSerializedSize int64 `json:"nonContiguousDeletedMessagesRangesSerializedSize,omitempty"`
93+ DelayedMessageIndexSizeInBytes int64 `json:"delayedMessageIndexSizeInBytes,omitempty"`
9494 Compaction Compaction `json:"compaction"`
9595 OwnerBroker string `json:"ownerBroker,omitempty"`
9696}
@@ -115,15 +115,15 @@ type CursorStats struct {
115115}
116116
117117type Compaction struct {
118- LastCompactionRemovedEventCount uint64 `json:"lastCompactionRemovedEventCount,omitempty"`
119- LastCompactionSucceedTimestamp uint64 `json:"lastCompactionSucceedTimestamp,omitempty"`
120- LastCompactionFailedTimestamp uint64 `json:"lastCompactionFailedTimestamp,omitempty"`
121- LastCompactionDurationTimeInMills uint64 `json:"lastCompactionDurationTimeInMills,omitempty"`
118+ LastCompactionRemovedEventCount int64 `json:"lastCompactionRemovedEventCount,omitempty"`
119+ LastCompactionSucceedTimestamp int64 `json:"lastCompactionSucceedTimestamp,omitempty"`
120+ LastCompactionFailedTimestamp int64 `json:"lastCompactionFailedTimestamp,omitempty"`
121+ LastCompactionDurationTimeInMills int64 `json:"lastCompactionDurationTimeInMills,omitempty"`
122122}
123123
124124type SubscriptionStats struct {
125- LastConsumedFlowTimestamp uint64 `json:"lastConsumedFlowTimestamp,omitempty"`
126- MsgBacklog int `json:"msgBacklog"`
125+ LastConsumedFlowTimestamp int64 `json:"lastConsumedFlowTimestamp,omitempty"`
126+ MsgBacklog int `json:"msgBacklog"`
127127}
128128
129129type Publisher struct {
0 commit comments