- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 106 for rResources (0.18 sec)
-
cmd/local-locker_test.go
t.Fatal("did not get write lock") } rResources[i] = arg.Resources[0] } if len(l.lockMap) != len(rResources)+len(wResources) { t.Fatalf("lockmap len, got %d, want %d + %d", len(l.lockMap), len(rResources), len(wResources)) } if len(l.lockUID) != len(rResources)+len(wResources) { t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), len(rResources), len(wResources)) } // Expire an hour from now, should keep all
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 11.8K bytes - Viewed (0) -
cmd/metrics-resource.go
lastDriveStatsRefresh time.Time ) // PeerResourceMetrics represents the resource metrics // retrieved from a peer, along with errors if any type PeerResourceMetrics struct { Metrics map[MetricSubsystem]ResourceMetrics Errors []string } // ResourceMetrics is a map of unique key identifying // a resource metric (e.g. reads_per_sec_{node}_{drive}) // to its data type ResourceMetrics map[string]ResourceMetric
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
// Gather the statuses before printing so they may be sorted mappedResp := map[string]string{} for id, dr := range drs { for _, resource := range dr.Resources { if s.InternalDebugAllIstiod { mappedResp[id] = string(resource.Value) + "\n" } else { _, _ = s.Writer.Write(resource.Value) _, _ = s.Writer.Write([]byte("\n")) } } } if len(mappedResp) > 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
// Combine all the shards as one, even if that means losing information about // the control plane version from each shard. retval.ControlPlane = response.ControlPlane retval.Resources = append(retval.Resources, response.Resources...) } return &retval, nil } func makeSan(istioNamespace, revision string) string { if revision == "" { return fmt.Sprintf("istiod.%s.svc", istioNamespace) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
cmd := &cobra.Command{ Use: "check-inject [<type>/]<name>[.<namespace>]", Short: "Check the injection status or inject-ability of a given resource, explains why it is (or will be) injected or not", Long: ` Checks associated resources of the given resource, and running webhooks to examine whether the pod can be or will be injected or not.`, Example: ` # Check the injection status of a pod
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/dsync/dsync_test.go
t.Errorf("expected at least %v time have passed, however %v passed", expect, elapsed) } t.Logf("expected at least %v time have passed, %v passed", expect, elapsed) } // Test two locks for different resources, both succeed func TestTwoSimultaneousLocksForDifferentResources(t *testing.T) { dm1 := NewDRWMutex(ds, "aap") dm2 := NewDRWMutex(ds, "noot") dm1.Lock(id, source) dm2.Lock(id, source)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
type manifestDiffArgs struct { // compareDir indicates comparison between directory. compareDir bool // verbose generates verbose output. verbose bool // selectResources constrains the list of resources to compare to only the ones in this list, ignoring all others. // The format of each list item is :: and the items are comma separated. The * character represents wildcard selection. // e.g.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
} // fakeApplyExtraResources applies any extra resources for the given test name. func fakeApplyExtraResources(inFile string) error { reconciler, err := helmreconciler.NewHelmReconciler(testClient, nil, nil, nil) if err != nil { return err } if rs, err := readFile(filepath.Join(testDataDir, "input-extra-resources", inFile+".yaml")); err == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cmd/namespace-lock.go
resource := pathJoin(volume, path) n.lockMapMutex.Lock() defer n.lockMapMutex.Unlock() if _, found := n.lockMap[resource]; !found { return } if readLock { n.lockMap[resource].RUnlock() } else { n.lockMap[resource].Unlock() } n.lockMap[resource].ref-- if n.lockMap[resource].ref < 0 { logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0"))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
t.Fatalf("Test %d: %s: Unable to marshal response body %s", i+1, instanceType, rec.Body.String()) } if errorResponse.Resource != testCase.errorResponse.Resource { t.Errorf("Test %d: %s: Expected the error resource to be `%s`, but instead found `%s`", i+1, instanceType, testCase.errorResponse.Resource, errorResponse.Resource) } if errorResponse.Message != testCase.errorResponse.Message {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 13 20:52:33 GMT 2023 - 11.2K bytes - Viewed (0)