- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for resources (0.16 sec)
-
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) -
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) -
operator/cmd/mesh/manifest-generate_test.go
} } } func TestManifestGenerateGateways(t *testing.T) { g := NewWithT(t) flags := "-s components.ingressGateways.[0].k8s.resources.requests.memory=999Mi " + "-s components.ingressGateways.[name:user-ingressgateway].k8s.resources.requests.cpu=555m" objss, err := runManifestCommands("gateways", flags, liveCharts, nil) if err != nil { t.Fatal(err) } for _, objs := range objss {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
} return nil } func ObjectToInstance(c controllers.Object) *resource.Instance { return &resource.Instance{ Origin: &legacykube.Origin{ Type: kubetypes.GvkFromObject(c), FullName: resource.FullName{ Namespace: resource.Namespace(c.GetNamespace()), Name: resource.LocalName(c.GetName()), }, ResourceVersion: resource.Version(c.GetResourceVersion()), Ref: nil,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.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) -
internal/hash/reader.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
cmd/local-locker.go
if len(args.Resources) > maxDeleteList { return false, fmt.Errorf("internal error: localLocker.Lock called with more than %d resources", maxDeleteList) } l.mutex.Lock() defer l.mutex.Unlock() if !l.canTakeLock(args.Resources...) { // Not all locks can be taken on resources, // reject it completely. return false, nil } // No locks held on the all resources, so claim write
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/local-locker_test.go
if len(l.lockMap) != len(rResources)+len(wResources)*m { t.Fatalf("lockmap len, got %d, want %d + %d", len(l.lockMap), len(rResources), len(wResources)*m) } // A UID is added for every resource. // We removed len(rResources) read sources. if len(l.lockUID) != len(rResources)+len(wResources)*m { t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), len(rResources), len(wResources)*m) } // RUnlock again, different uids
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/storage-rest-server.go
// Every 10 seconds a space character is sent. // keepHTTPReqResponseAlive will wait for the returned body to be read before starting the ticker. // The returned function should always be called to release resources. // An optional error can be sent which will be picked as text only error, // without its original type by the receiver. // waitForHTTPResponse should be used to the receiving side.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/object-api-errors.go
type InsufficientReadQuorum struct { Bucket string Object string Err error Type RQErrType } func (e InsufficientReadQuorum) Error() string { return "Storage resources are insufficient for the read operation " + e.Bucket + "/" + e.Object } // Unwrap the error. func (e InsufficientReadQuorum) Unwrap() error { return errErasureReadQuorum }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0)