Function addPIndexStats

ns_server.go:603–614

(pindex *cbgt.PIndex, nsIndexStat map[string]interface{})

}

func addPIndexStats(pindex *cbgt.PIndex, nsIndexStat map[string]interface{}) error {
	if destForwarder, ok := pindex.Dest.(*cbgt.DestForwarder); ok {
		if bp, ok := destForwarder.DestProvider.(*BleveDest); ok {
			bpsm, err := bp.StatsMap()
			if err != nil {
				return err
			}
			return extractStats(bpsm, nsIndexStat)
		}
	}
	return nil
}

func updateStat(name string, val float64, nsIndexStat map[string]interface{}) {
	oldValue, ok := nsIndexStat[name]