mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 11:48:43 -07:00
Properly set pending
This commit is contained in:
@@ -36,7 +36,7 @@ type ConnInfo struct {
|
||||
Cid uint64 `json:"cid"`
|
||||
IP string `json:"ip"`
|
||||
Port int `json:"port"`
|
||||
Pending int `json:"pending_size"`
|
||||
Pending int `json:"pending_bytes"`
|
||||
InMsgs int64 `json:"in_msgs"`
|
||||
OutMsgs int64 `json:"out_msgs"`
|
||||
InBytes int64 `json:"in_bytes"`
|
||||
@@ -117,6 +117,7 @@ func (s *Server) HandleConnz(w http.ResponseWriter, r *http.Request) {
|
||||
InBytes: client.inBytes,
|
||||
OutBytes: client.outBytes,
|
||||
NumSubs: client.subs.Count(),
|
||||
Pending: client.bw.Buffered(),
|
||||
Lang: client.opts.Lang,
|
||||
Version: client.opts.Version,
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user