Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for StatusJSON (0.25 sec)

  1. pilot/pkg/xds/discovery.go

    		case <-ticker.C:
    			push := s.globalPushContext()
    			model.LastPushMutex.Lock()
    			if model.LastPushStatus != push {
    				model.LastPushStatus = push
    				push.UpdateMetrics()
    				out, _ := model.LastPushStatus.StatusJSON()
    				if string(out) != "{}" {
    					log.Infof("Push Status: %s", string(out))
    				}
    			}
    			model.LastPushMutex.Unlock()
    		case <-stopCh:
    			return
    		}
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 20:21:09 UTC 2024
    - 19K bytes
    - Viewed (0)
  2. pilot/pkg/xds/debug.go

    	model.LastPushMutex.Lock()
    	defer model.LastPushMutex.Unlock()
    	if model.LastPushStatus == nil {
    		return
    	}
    	out, err := model.LastPushStatus.StatusJSON()
    	if err != nil {
    		handleHTTPError(w, err)
    		return
    	}
    	w.Header().Add("Content-Type", "application/json")
    
    	_, _ = w.Write(out)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. pilot/pkg/model/push_context.go

    		}
    		ps.ServiceIndex.instancesByPort[svcKey][port] = append(ps.ServiceIndex.instancesByPort[svcKey][port], inst...)
    	}
    }
    
    // StatusJSON implements json.Marshaller, with a lock.
    func (ps *PushContext) StatusJSON() ([]byte, error) {
    	if ps == nil {
    		return []byte{'{', '}'}, nil
    	}
    	ps.proxyStatusMutex.RLock()
    	defer ps.proxyStatusMutex.RUnlock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
Back to top