diff --git a/server/monitor.go b/server/monitor.go index e7d3eee1..0cb32b01 100644 --- a/server/monitor.go +++ b/server/monitor.go @@ -245,6 +245,7 @@ func (s *Server) HandleSubsz(w http.ResponseWriter, r *http.Request) { type Varz struct { *Info *Options + MaxPayload int `json:"max_payload"` Start time.Time `json:"start"` Now time.Time `json:"now"` Uptime string `json:"uptime"` @@ -306,7 +307,7 @@ func (s *Server) HandleRoot(w http.ResponseWriter, r *http.Request) { // HandleVarz will process HTTP requests for server information. func (s *Server) HandleVarz(w http.ResponseWriter, r *http.Request) { - v := &Varz{Info: &s.info, Options: s.opts, Start: s.start} + v := &Varz{Info: &s.info, Options: s.opts, MaxPayload: s.opts.MaxPayload, Start: s.start} v.Now = time.Now() v.Uptime = myUptime(time.Since(s.start)) diff --git a/server/opts.go b/server/opts.go index ceab9ed5..aabf1965 100644 --- a/server/opts.go +++ b/server/opts.go @@ -363,4 +363,7 @@ func processOptions(opts *Options) { if opts.MaxPayload == 0 { opts.MaxPayload = MAX_PAYLOAD_SIZE } + if opts.MaxPending == 0 { + opts.MaxPending = MAX_PENDING_SIZE + } }