This commit is contained in:
Derek Collison
2015-08-23 13:23:02 -07:00
parent 47994eaf2c
commit eed8b6cf94
2 changed files with 5 additions and 1 deletions

View File

@@ -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))

View File

@@ -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
}
}