- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 214 for pselect (0.13 sec)
-
pilot/cmd/pilot-discovery/app/cmd.go
c.PersistentFlags().StringVarP(&serverArgs.Namespace, "namespace", "n", bootstrap.PodNamespace, "Select a namespace where the controller resides. If not set, uses ${POD_NAMESPACE} environment variable") c.PersistentFlags().StringVar(&serverArgs.CniNamespace, "cniNamespace", bootstrap.PodNamespace, "Select a namespace where the istio-cni resides. If not set, uses ${POD_NAMESPACE} environment variable")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 8.5K bytes - Viewed (0) -
src/crypto/aes/cipher.go
return "crypto/aes: invalid key size " + strconv.Itoa(int(k)) } // NewCipher creates and returns a new [cipher.Block]. // The key argument should be the AES key, // either 16, 24, or 32 bytes to select // AES-128, AES-192, or AES-256. func NewCipher(key []byte) (cipher.Block, error) { k := len(key) switch k { default: return nil, KeySizeError(k) case 16, 24, 32: break } if boring.Enabled {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 14:58:19 UTC 2024 - 2K bytes - Viewed (0) -
cmd/signals.go
shutdownLogIf(context.Background(), srv.Shutdown()) } if globalEventNotifier != nil { globalEventNotifier.RemoveAllBucketTargets() } return true } for { select { case err := <-globalHTTPServerErrorCh: shutdownLogIf(context.Background(), err) exit(stopProcess()) case osSignal := <-globalOSSignalCh: logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String()))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 17:57:52 UTC 2024 - 2.8K bytes - Viewed (0) -
src/regexp/syntax/make_perl_groups.pl
# Send the output of gofmt to the given file open($gofmt, '|-', 'gofmt >'.$ARGV[0]) or die; } else { open($gofmt, '|-', 'gofmt') or die; } # Redirect STDOUT to gofmt input select $gofmt; print <<EOF; // Copyright 2013 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 13:59:01 UTC 2024 - 2.6K bytes - Viewed (0) -
src/cmd/go/testdata/script/mod_tidy_compat_incompatible.txt
cp go.mod go.mod.orig ! go mod tidy stderr '^go: example\.com/m imports\n\texample\.net/lazy imports\n\texample\.com/retract/incompatible loaded from example\.com/retract/incompatible@v1\.0\.0,\n\tbut go 1\.16 would select v2\.0\.0\+incompatible\n\n'
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 14:56:56 UTC 2024 - 5.5K bytes - Viewed (0) -
tools/build-base-images.sh
source "${ROOT}/prow/lib.sh" buildx-create HUBS="${HUBS:?specify a space separated list of hubs}" TAG="${TAG:?specify a tag}" defaultTargets="$(< "${ROOT}/tools/docker.yaml" toJson | toJson | jq '[.images[] | select(.base) | .name] | join(",")' -r)" DOCKER_TARGETS="${DOCKER_TARGETS:-${defaultTargets}}" # For multi architecture building:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 17:24:41 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/util/concurrent/debouncer.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 01 13:44:06 UTC 2024 - 2.4K bytes - Viewed (0) -
cmd/metrics-v2_test.go
defer ticker.Stop() for _, obs := range observations { // Send observations once every 1ms, to simulate delay between // observations. This is to test the channel based // synchronization used internally. select { case <-ticker.C: ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val) } } metrics := getHistogramMetrics(ttfbHist, getBucketTTFBDistributionMD(), false)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 04 18:05:56 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/proxy/kubemark/hollow_proxy.go
) type HollowProxy struct { ProxyServer *proxyapp.ProxyServer } type FakeProxier struct { proxyconfig.NoopNodeHandler } func (*FakeProxier) Sync() {} func (*FakeProxier) SyncLoop() { select {} } func (*FakeProxier) OnServiceAdd(service *v1.Service) {} func (*FakeProxier) OnServiceUpdate(oldService, service *v1.Service) {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/speedtest.go
result.Servers = len(globalNotificationSys.peerClients) + 1 result.Version = Version result.Concurrent = concurrency select { case ch <- result: case <-ctx.Done(): return } } for { select { case <-ctx.Done(): // If the client got disconnected stop the speedtest. return default: } sopts := speedTestOpts{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0)