Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 529 for JOIN (0.25 sec)

  1. istioctl/pkg/writer/envoy/configdump/route_test.go

    			if err := cw.Prime(cd); err != nil {
    				t.Errorf("failed to parse config dump: %s", err)
    			}
    			err := cw.PrintRouteSummary(RouteFilter{Verbose: true})
    			assert.NoError(t, err)
    
    			wantOutputFile := path.Join("testdata/routes", tt.name, "output.txt")
    			util.CompareContent(t, gotOut.Bytes(), wantOutputFile)
    		})
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  2. cni/pkg/cmd/root.go

    		monitoring.SetupMonitoring(cfg.InstallConfig.MonitoringPort, "/metrics", ctx.Done())
    
    		// Start UDS log server
    		udsLogger := udsLog.NewUDSLogger(log.GetOutputLevel())
    		if err = udsLogger.StartUDSLogServer(filepath.Join(cfg.InstallConfig.CNIAgentRunDir, constants.LogUDSSocketName), ctx.Done()); err != nil {
    			log.Errorf("Failed to start up UDS Log Server: %v", err)
    			return
    		}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. tests/tests_test.go

    		log.Println("testing tidb...")
    		if dbDSN == "" {
    			dbDSN = tidbDSN
    		}
    		db, err = gorm.Open(mysql.Open(dbDSN), cfg)
    	default:
    		log.Println("testing sqlite3...")
    		db, err = gorm.Open(sqlite.Open(filepath.Join(os.TempDir(), "gorm.db")), cfg)
    		if err == nil {
    			db.Exec("PRAGMA foreign_keys = ON")
    		}
    	}
    
    	if err != nil {
    		return
    	}
    
    	if debug := os.Getenv("DEBUG"); debug == "true" {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Sep 30 03:21:19 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/ztunnel/configdump/services.go

    		}
    		endpoints := fmt.Sprintf("%d/%d", healthyEndpoints, allEndpoints)
    
    		waypoint := serviceWaypointName(svc, zDump.Services)
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\n",
    			svc.Namespace, svc.Name, strings.Join(ips, ","), waypoint, endpoints)
    	}
    	return w.Flush()
    }
    
    // PrintServiceDump prints the relevant services in the config dump to the ConfigWriter stdout
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 24 09:07:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. cmd/endpoint-ellipses.go

    	if len(s.endpoints) != 0 {
    		return s.endpoints
    	}
    	for _, argPattern := range s.argPatterns {
    		for _, lbls := range argPattern.Expand() {
    			endpoints = append(endpoints, strings.Join(lbls, ""))
    		}
    	}
    	s.endpoints = endpoints
    	return endpoints
    }
    
    // Get returns the sets representation of the endpoints
    // this function also intelligently decides on what will
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          }
        }
      }
    
      /** Invokes {@code toJoin.}{@link Thread#join() join()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static void joinUninterruptibly(Thread toJoin) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
              toJoin.join();
              return;
            } catch (InterruptedException e) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  7. docs/sts/client_grants/__init__.py

                query_components = []
                for key in query:
                    if query[key] is not None:
                        query_components.append("%s=%s" % (key, query[key]))
    
                query_string = '&'.join(query_components)
                sts_ep_url = self.sts_ep
                if query_string:
                    sts_ep_url = self.sts_ep + '?' + query_string
    
                response = self._http.urlopen(
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  8. tests/sql_builder_test.go

    								},
    							},
    						},
    					},
    				},
    			},
    		},
    	)
    
    	newDB.Joins("inner join rgs on rgs.id = user.id")
    
    	stmt := newDB.First(&result).Statement
    	str := stmt.SQL.String()
    
    	if !strings.Contains(str, "rgs.id = user.id") {
    		t.Errorf("The second join condition is over written instead of combining")
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Jan 12 08:42:21 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
      public void testRemoveWaiter_polling() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/internal/impl/Graph.java

            }
    
            public List<String> getCycle() {
                return cycle;
            }
    
            @Override
            public String getMessage() {
                return super.getMessage() + " " + String.join(" --> ", cycle);
            }
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top