- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for pubnames (0.13 sec)
-
pkg/controller/disruption/disruption_test.go
pdb, pdbName := newMinAvailablePodDisruptionBudget(t, intstr.FromInt32(3)) pdb.Spec.Selector = &metav1.LabelSelector{} pod, _ := newPod(t, "yo-yo-yo") add(t, dc.pdbStore, pdb) dc.sync(ctx, pdbName) ps.VerifyPdbStatus(t, pdbName, 0, 0, 3, 0, map[string]metav1.Time{}) add(t, dc.podStore, pod) dc.sync(ctx, pdbName) ps.VerifyPdbStatus(t, pdbName, 0, 1, 3, 1, map[string]metav1.Time{}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
callbacks/query.go
selectColumns, _ := db.Statement.SelectAndOmitColumns(false, false) clauseSelect.Columns = make([]clause.Column, 0, len(db.Statement.Schema.DBNames)) for _, dbName := range db.Statement.Schema.DBNames { if v, ok := selectColumns[dbName]; (ok && v) || !ok { clauseSelect.Columns = append(clauseSelect.Columns, clause.Column{Table: db.Statement.Table, Name: dbName}) } }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 09:51:44 UTC 2024 - 10.1K bytes - Viewed (0) -
src/go/types/resolver_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
return err } if labelSelector != "" { if podNames, podNamespace, err = getPodNameBySelector(ctx, kubeClient, labelSelector); err != nil { return err } } else { if podNames, podNamespace, err = getPodNames(ctx, args[0], ctx.Namespace()); err != nil { return err } } for _, pod := range podNames { loggerName, err = setupEnvoyLogConfig(kubeClient, "", pod, podNamespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 48K bytes - Viewed (0) -
schema/schema.go
if _, ok := schema.FieldsByDBName[field.DBName]; !ok { schema.DBNames = append(schema.DBNames, field.DBName) } schema.FieldsByDBName[field.DBName] = field schema.FieldsByName[field.Name] = field schema.FieldsByBindName[bindName] = field if v != nil && v.PrimaryKey {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:52:33 UTC 2024 - 13.7K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
if !ztunnelPod { return fmt.Errorf("workloads command is only supported by Ztunnel proxies: %v", podName) } podNames = []string{podName} podNamespace = ns } else { var err error podNames, podNamespace, err = ctx.InferPodsFromTypedResource("daemonset/ztunnel", ctx.IstioNamespace()) if err != nil { return err } } destLoggerLevels := map[string]Level{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
return fmt.Errorf("no network system notify") } podNames := sets.New[string]("pod1", "pod2") svcNames := sets.New[string]("svc1") addresses := c.ambientIndex.All() for _, addr := range addresses { wl := addr.GetWorkload() if wl != nil { if !podNames.Contains(wl.Name) { continue } if addr.GetWorkload().Network != network {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
src/net/net_windows_test.go
// for the same MAC address. If that is the case here, // and we can match at least one of those names, // let's ignore the other names. if dupNames, ok := dups[wantAddr]; ok && len(dupNames) > 1 { for _, dupName := range dupNames { if haveAddr, ok := have[dupName]; ok && haveAddr == wantAddr { continue nextWant } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/model/schemas_test.go
// required: // - name // - value // properties: // name: // type: string // nested: // type: object // properties: // subname: // type: string // flags: // type: object // additionalProperties: // type: boolean // dates: // type: array // items:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 20:13:14 UTC 2024 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
if err != nil { klog.ErrorS(err, "Unable to derive new concurrency limits", "plNames", plNames, "items", items) allocs = make([]float64, len(items)) for idx, plName := range plNames { plState := plStates[plName] allocs[idx] = float64(plState.currentCL) } } for idx, plName := range plNames { plState := plStates[plName] if setCompleters {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0)