- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for mgr2 (0.04 sec)
-
pkg/kubelet/token/token_manager_test.go
clock := testingclock.NewFakeClock(time.Time{}.Add(24 * time.Hour)) mgr := NewManager(nil) mgr.clock = clock mgr.set("key", &authenticationv1.TokenRequest{ Status: authenticationv1.TokenRequestStatus{ ExpirationTimestamp: metav1.Time{Time: mgr.clock.Now().Add(c.relativeExp)}, }, }) mgr.cleanup() if got, want := len(mgr.cache), c.expectedCacheSize; got != want {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 04 00:16:47 UTC 2022 - 16.2K bytes - Viewed (0) -
pilot/pkg/model/network.go
env.AppendNetworkGatewayHandler(mgr.reloadGateways) nameCache.AppendNetworkGatewayHandler(mgr.reloadGateways) mgr.reload() return mgr, nil } // reloadGateways reloads NetworkGateways and triggers a push if they change. func (mgr *NetworkManager) reloadGateways() { changed := mgr.reload() if changed && mgr.xdsUpdater != nil { log.Infof("gateways changed, triggering push")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 16.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager_test.go
sourcesReady: &sourcesReadyStub{}, } mgr.sourcesReady = &sourcesReadyStub{} mgr.allocatableCPUs = testCase.policy.GetAllocatableCPUs(mgr.state) pod := makePod("fakePod", "fakeContainer", "2", "2") container := &pod.Spec.Containers[0] _ = mgr.Allocate(pod, container) if !mgr.GetAllocatableCPUs().Equals(testCase.expAllocatableCPUs) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 42.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/service.go
//sys CreateService(mgr Handle, serviceName *uint16, displayName *uint16, access uint32, srvType uint32, startType uint32, errCtl uint32, pathName *uint16, loadOrderGroup *uint16, tagId *uint32, dependencies *uint16, serviceStartName *uint16, password *uint16) (handle Handle, err error) [failretval==0] = advapi32.CreateServiceW
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 10.3K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
func Add(mgr manager.Manager, options *Options) error { restConfig = mgr.GetConfig() kubeClient, err := kube.NewClient(kube.NewClientConfigForRestConfig(restConfig), "") if err != nil { return fmt.Errorf("create Kubernetes client: %v", err) } return add(mgr, &ReconcileIstioOperator{client: mgr.GetClient(), scheme: mgr.GetScheme(), kubeClient: kubeClient, options: options}, options) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
src/io/multi_test.go
r2 := strings.NewReader("45678") mr1 := MultiReader(r1, r2) mr2 := MultiReader(mr1) buf := make([]byte, 4) // Have mr2 use mr1's []Readers. // Consume r1 (and clear it for GC to handle) and consume part of r2. n, err := ReadFull(mr2, buf) if got := string(buf[:n]); got != "1234" || err != nil { t.Errorf(`ReadFull(mr2) = (%q, %v), want ("1234", nil)`, got, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 15:49:32 UTC 2022 - 10K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tf_saved_model_freeze_variables.cc
} // namespace LogicalResult FreezeVariables(ModuleOp module, tensorflow::Session* session) { if (failed(ValidateModule(module))) return failure(); const tensorflow::DeviceMgr* mgr = nullptr; auto status = session->LocalDeviceManager(&mgr); if (!status.ok()) { module->emitError( absl::StrCat("failed to fetch device manager: ", status.message())); return failure(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 09:56:53 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
nodeIndexer := informerFactory.Core().V1().Nodes().Informer().GetIndexer() mgr, _ := New(ctx, fakeClientSet, informerFactory.Core().V1().Pods(), informerFactory.Core().V1().Nodes(), "taint-eviction-controller") mgr.podListerSynced = alwaysReady mgr.nodeListerSynced = alwaysReady mgr.getPodsAssignedToNode = getPodsAssignedToNode(ctx, fakeClientSet) return mgr, podIndexer, nodeIndexer } type timestampedPod struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
src/internal/syscall/windows/zsyscall_windows.go
handle = syscall.Handle(r0) if handle == 0 { err = errnoErr(e1) } return } func OpenService(mgr syscall.Handle, serviceName *uint16, access uint32) (handle syscall.Handle, err error) { r0, _, e1 := syscall.Syscall(procOpenServiceW.Addr(), 3, uintptr(mgr), uintptr(unsafe.Pointer(serviceName)), uintptr(access)) handle = syscall.Handle(r0) if handle == 0 { err = errnoErr(e1) } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 11:49:46 UTC 2024 - 18.4K bytes - Viewed (0) -
src/mime/multipart/multipart_test.go
mr2 := NewReader(p, "e89a8ff1c1e83553e004be640610") p, err = mr2.NextPart() if err != nil { t.Fatalf("reading text/plain part: %v", err) } if b, err := io.ReadAll(p); string(b) != "*body*\r\n" || err != nil { t.Fatalf("reading text/plain part: got %q, %v", b, err) } p, err = mr2.NextPart() if err != nil { t.Fatalf("reading text/html part: %v", err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 17:36:47 UTC 2022 - 30.4K bytes - Viewed (0)