- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 562 for Shardz (0.23 sec)
-
pkg/test/framework/config.go
func (c *configFactory) WaitForConfigOrFail(ctx resource.Context, t test.Failer, ns string, yamlText ...string) { err := c.WaitForConfig(ctx, ns, yamlText...) if err != nil { // TODO(https://github.com/istio/istio/issues/37148) fail hard in this case t.Log(err) } } func (c *configFactory) withFilePrefix(prefix string) config.Factory { return &configFactory{ ctx: c.ctx, prefix: prefix, clusters: c.clusters, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/kubelet/kubeletconfig/util/files/files.go
tmpPath = tmpFile.Name() // write data if _, err := tmpFile.Write(data); err != nil { return tmpPath, err } // sync file, to ensure it's written in case a hard reset happens return tmpPath, tmpFile.Sync() } // ReplaceFile replaces the contents of the file at `path` with `data` by writing to a tmp file in the same
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 01:02:46 UTC 2023 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/quota/v1/resources.go
func CalculateUsage(namespaceName string, scopes []corev1.ResourceQuotaScope, hardLimits corev1.ResourceList, registry Registry, scopeSelector *corev1.ScopeSelector) (corev1.ResourceList, error) { // find the intersection between the hard resources on the quota // and the resources this controller can track to know what we can // look to measure updated usage stats for hardResources := ResourceNames(hardLimits) potentialResources := []corev1.ResourceName{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 06 23:11:22 UTC 2021 - 8.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
shards, ok := endpoints.ShardsForService(string(s.Hostname), s.Attributes.Namespace) if !ok { return nil } var pn string for _, p := range s.Ports { if p.Port == port { pn = p.Name break } } if pn == "" && port != 0 { return nil } shards.RLock() defer shards.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// StartRequest begins the process of handling a request. If the // request gets queued and the number of queues is greater than 1 // then StartRequest uses the given hashValue as the source of // entropy as it shuffle-shards the request into a queue. The // descr1 and descr2 values play no role in the logic but appear // in log messages. This method always returns quickly (without // waiting for the request to be dequeued). If this method
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
tools/golangci-override.yaml
- "!**/operator/**" - "!**/istioctl/**" - "!**/tools/bug-report/**" # This should only really import operator API, but that is hard to express without a larger refactoring - "!**/pkg/kube/**" - "!**/pkg/url/**" - "!**/pkg/test/framework/**" - "!**/tests/fuzz/**" deny:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 2.9K bytes - Viewed (0) -
hack/golangci.yaml.in
path: _test.go$ {{- if .Base}} # TODO(oscr) Remove these excluded directories and fix findings. Due to large amount of findings in different components # with different owners it's hard to fix everything in a single pr. This will therefore be done in multiple prs. - path: (pkg/volume/*|test/*|azure/*|pkg/cmd/wait*|request/bearertoken/*|metrics/*|filters/*) linters: - gocritic {{- end}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 13 13:12:04 UTC 2024 - 8K bytes - Viewed (0) -
ci/official/containers/linux_arm64/devel.usertools/squash_testlogs.py
r._elem.remove(testsuite._elem) if len(r) > 0: # pylint: disable=g-explicit-length-test result += r # Insert the number of failures for each test to help identify flakes # need to clarify for shard for p in result._elem.xpath(".//error | .//failure"): key = re.sub(r"0x\w+", "", p.getparent().get("name", "")) + p.text p.text = runfiles_matcher.sub("[testroot]/", p.text)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Sep 18 19:00:37 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo.go
return fmt.Errorf("failed to exec 'git checkout %s': %s: %v", b.revision, output, err) } if output, err := b.execCommand("git", []string{"reset", "--hard"}, subdir); err != nil { return fmt.Errorf("failed to exec 'git reset --hard': %s: %v", output, err) } volume.SetVolumeOwnership(b, dir, mounterArgs.FsGroup, nil /*fsGroupChangePolicy*/, volumeutil.FSGroupCompleteHook(b.plugin, nil))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 8.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/loopclosure/doc.go
// go func() { // use(v) // incorrect, and a data race // }() // } // // A fix is the same as before. The checker also reports problems // in goroutines started by golang.org/x/sync/errgroup.Group. // A hard-to-spot variant of this form is common in parallel tests: // // func Test(t *testing.T) { // for _, test := range tests { // t.Run(test.name, func(t *testing.T) { // t.Parallel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 20 21:52:54 UTC 2023 - 2.6K bytes - Viewed (0)