code: func (s *Service) reportPending(conn *websocket.Conn) error {
  	// Retrieve the pending count from the local blockchain
  	var pending int
  	if s.eth != nil {
  		pending, _ = s.eth.TxPool().Stats()
  	} else {
  		pending = s.les.TxPool().Stats()
  	}
  	// Assemble the transaction stats and send it to the server
  	log.Trace("Sending pending transactions to ethstats", "count", pending)
  
  	stats := map[string]interface{}{
  		"id": s.node,
  		"stats": &pendStats{
  			Pending: pending,
  		},
  	}
  	report := map[string][]interface{}{
  		"emit": {"pending", stats},
  	}
  	return websocket.JSON.Send(conn, report)
  }
docs: // reportPending retrieves the current number of pending transactions and reports
  // it to the stats server.