- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for mgr2 (0.04 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/managedfields/extract_test.go
objType: parser.Type("io.k8s.api.apps.v1.Deployment"), managedFields: []metav1.ManagedFieldsEntry{ applyFieldsEntry("mgr1", `{ "f:spec": { "f:replicas": {}}}`, ""), applyFieldsEntry("mgr2", `{ "f:spec": { "f:paused": {}}}`, ""), }, fieldManager: "mgr2", expectedOut: map[string]interface{}{"spec": map[string]interface{}{"paused": true}}, }, { name: "subresource",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 22 22:32:45 UTC 2021 - 8.3K bytes - Viewed (0) -
test/typeparam/mdempsky/13.go
} return m } type Abs2 interface { Abs() MyInt } func main() { mm := MyMer(3) ms := struct{ Mer }{Mer: mm } // Testing F with an interface type arg: Mer and Mer2 F[Mer](mm) F[Mer2](mm) F[struct{ Mer }](ms) F[*struct{ Mer }](&ms) ms2 := struct { MyMer }{MyMer: mm} ms3 := struct { *MyMer }{MyMer: &mm} // Testing F with a concrete type arg F[MyMer](mm) F[*MyMer](&mm)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 14 17:55:47 UTC 2022 - 1.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/mark_initialized_variables.cc
llvm::StringRef device_name, const tensorflow::DeviceMgr* mgr, tensorflow::Session* session) { auto* var_ptr = GetVariableFromSession(var_handle_op, device_name, mgr); if (!var_ptr) return false; auto* tensor = var_ptr->tensor(); bool is_initialized = tensor && tensor->IsInitialized(); var_ptr->Unref();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 13 19:14:56 UTC 2023 - 4.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/initsystem/initsystem_windows.go
func (sysd WindowsInitSystem) ServiceIsEnabled(service string) bool { m, err := mgr.Connect() if err != nil { return false } defer m.Disconnect() s, err := m.OpenService(service) if err != nil { return false } defer s.Close() c, err := s.Config() if err != nil { return false } return c.StartType != mgr.StartDisabled }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 08:56:16 UTC 2022 - 6.4K bytes - Viewed (0) -
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) -
pkg/kubelet/cm/memorymanager/memory_manager_test.go
mgr.state.SetMachineState(testCase.machineState) mgr.removeStaleState() if !areContainerMemoryAssignmentsEqual(t, mgr.state.GetMemoryAssignments(), testCase.expectedAssignments) { t.Errorf("Memory Manager removeStaleState() error, expected assignments %v, but got: %v", testCase.expectedAssignments, mgr.state.GetMemoryAssignments()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0) -
src/main/assemblies/files/fess-service-mgr.exe
Matsutani Kenji <******@****.***> 1477575947 +0900
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Oct 27 13:45:47 UTC 2016 - 102K bytes - Viewed (0) -
pilot/pkg/status/resourcelock_test.go
} var runCount int32 x := make(chan struct{}) y := make(chan struct{}) mgr := NewManager(nil) fakefunc := func(status *v1alpha1.IstioStatus, context any) *v1alpha1.IstioStatus { x <- struct{}{} atomic.AddInt32(&runCount, 1) y <- struct{}{} return nil } c1 := mgr.CreateIstioStatusController(fakefunc) c2 := mgr.CreateIstioStatusController(fakefunc) workers := NewWorkerPool(func(_ *config.Config, _ any) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 2.1K bytes - Viewed (0)