- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 117 for reflect1 (0.3 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// In most of the cases, leader is reelected within few cycles. reflector.MaxInternalErrorRetryDuration = time.Second * 30 // since the watch-list is provided by the watch cache instruct // the reflector to issue a regular LIST against the store reflector.UseWatchList = ptr.To(false) cacher.watchCache = watchCache cacher.reflector = reflector go cacher.dispatchEvents() go progressRequester.Run(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
src/runtime/map.go
} h.flags &^= sameSizeGrow } } // Reflect stubs. Called from ../reflect/asm_*.s // reflect_makemap is for package reflect, // but widely used packages access it using linkname. // Notable members of the hall of shame include: // - gitee.com/quant1x/gox // - github.com/modern-go/reflect2 // - github.com/goccy/go-json // - github.com/RomiChan/protobuf
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 57.6K bytes - Viewed (0) -
src/reflect/type.go
panic("reflect: NumIn of non-func type " + t.String()) } tt := (*abi.FuncType)(unsafe.Pointer(t)) return tt.NumIn() } func (t *rtype) NumOut() int { if t.Kind() != Func { panic("reflect: NumOut of non-func type " + t.String()) } tt := (*abi.FuncType)(unsafe.Pointer(t)) return tt.NumOut() } func (t *rtype) Out(i int) Type { if t.Kind() != Func { panic("reflect: Out of non-func type " + t.String())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 85.5K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} if e, a := []syncPodRecord{{name: "pod1", updateType: kubetypes.SyncPodUpdate}}, processed[types.UID("2-static")]; !reflect.DeepEqual(e, a) { t.Fatalf("unexpected sync pod calls: %s", cmp.Diff(e, a)) } if e, a := map[string]types.UID{"pod1_test1": "2-static"}, podWorkers.startedStaticPodsByFullname; !reflect.DeepEqual(e, a) { t.Fatalf("unexpected started static pods: %s", cmp.Diff(e, a)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/apis/core/v1/defaults_test.go
if strings.HasPrefix(visit.path, ".ObjectMeta.ManagedFields[") { break } // if we don't already have a value, and contain structs, add an empty item so we can recurse item := reflect.New(visit.value.Type().Elem()).Elem() visit.value.Set(reflect.Append(visit.value, item)) toVisit = append(toVisit, testPath{path: visit.path + "[0]", value: visit.value.Index(0)})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/instantiation/generator/AbstractClassGenerator.java
import org.gradle.internal.logging.text.TreeFormatter; import org.gradle.internal.reflect.ClassDetails; import org.gradle.internal.reflect.ClassInspector; import org.gradle.internal.reflect.JavaPropertyReflectionUtil; import org.gradle.internal.reflect.MethodSet; import org.gradle.internal.reflect.PropertyAccessorType; import org.gradle.internal.reflect.PropertyDetails; import org.gradle.internal.service.ServiceLookup;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 06 21:54:37 UTC 2024 - 63K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
case "NextProtos": f.Set(reflect.ValueOf([]string{"a", "b"})) case "ServerName": f.Set(reflect.ValueOf("b")) case "ClientAuth": f.Set(reflect.ValueOf(VerifyClientCertIfGiven)) case "InsecureSkipVerify", "SessionTicketsDisabled", "DynamicRecordSizingDisabled", "PreferServerCipherSuites": f.Set(reflect.ValueOf(true)) case "MinVersion", "MaxVersion": f.Set(reflect.ValueOf(uint16(VersionTLS12)))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
// Mounter.SetUp() err = csiMounter.SetUp(volume.MounterArgs{}) if tc.setupShouldFail { if err != nil { if tc.exitError != nil && reflect.TypeOf(tc.exitError) != reflect.TypeOf(err) { t.Fatalf("expected exitError type: %v got: %v (%v)", reflect.TypeOf(tc.exitError), reflect.TypeOf(err), err) } t.Log(err) return } else { t.Error("test should fail, but no error occurred") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
// - part 3: other plugins (excluded by part 1 & 2) in regular extension point. newPlugins := reflect.New(reflect.TypeOf(e.slicePtr).Elem()).Elem() // part 1 for _, name := range slice.CopyStrings(enabledSet.list) { if overridePlugins.has(name) { newPlugins = reflect.Append(newPlugins, reflect.ValueOf(f.pluginsMap[name])) enabledSet.delete(name) } } // part 2
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
if !reflect.DeepEqual(newStatus.InitContainerStatuses[0].State, expectUnknownState) { t.Errorf("terminated container state not defaulted: %s", cmp.Diff(newStatus.InitContainerStatuses[0].State, expectUnknownState)) } if !reflect.DeepEqual(newStatus.InitContainerStatuses[1].State, firstStatus.InitContainerStatuses[1].State) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0)