- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 453 for curr (0.04 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller_test.go
b.curr.Spec.Names.Plural = plural b.curr.Spec.Names.Singular = singular b.curr.Spec.Names.Kind = kind b.curr.Spec.Names.ListKind = listKind b.curr.Spec.Names.ShortNames = shortNames return b } func (b *crdBuilder) StatusNames(plural, singular, kind, listKind string, shortNames ...string) *crdBuilder { b.curr.Status.AcceptedNames.Plural = plural
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 03 16:49:27 UTC 2019 - 15.7K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
sma *SMA `json:"-"` } // Clone returns a copy of XferStats func (rx *XferStats) Clone() *XferStats { curr := rx.curr() peak := rx.Peak if curr > peak { peak = curr } return &XferStats{ Curr: curr, Avg: rx.Avg, Peak: peak, N: rx.N, measure: rx.measure, } } func newXferStats() *XferStats { return &XferStats{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/util.go
signerHumanName = "<self>" } usages := []string{} for _, curr := range certificate.ExtKeyUsage { if curr == x509.ExtKeyUsageClientAuth { usages = append(usages, "client") continue } if curr == x509.ExtKeyUsageServerAuth { usages = append(usages, "serving") continue } usages = append(usages, fmt.Sprintf("%d", curr)) } validServingNames := []string{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 21 07:29:30 UTC 2022 - 2.1K bytes - Viewed (0) -
cmd/bucket-stats.go
lpeak = math.Max(math.Max(v[Large].Peak, lpeak), v[Large].Curr) speak = math.Max(math.Max(v[Small].Peak, speak), v[Small].Curr) if lpeak > 0 || speak > 0 { count++ } } if count > 0 { lrg := XferStats{ Avg: lavg / float64(count), Curr: lcurr / float64(count), Peak: lpeak, } sml := XferStats{ Avg: savg / float64(count), Curr: scurr / float64(count),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
err = msgp.WrapError(err, "Curr") return } for zb0002 > 0 { zb0002-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err, "Curr") return } switch msgp.UnsafeString(field) { case "Count": z.Curr.Count, err = dc.ReadFloat64() if err != nil { err = msgp.WrapError(err, "Curr", "Count") return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 33.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/util.go
} return out } // returns a set of objects that are in `old` but not in `curr` // For example: // old = {a1, a2, a3} // curr = {a1, a2, a4, a5} // difference(old, curr) = {a3} func difference(old, curr map[types.NamespacedName]*config.Config) []types.NamespacedName { var out []types.NamespacedName for key := range old { if _, ok := curr[key]; !ok { out = append(out, key) } } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/union_content.go
func (c unionCAContent) Name() string { names := []string{} for _, curr := range c { names = append(names, curr.Name()) } return strings.Join(names, ",") } // CurrentCABundleContent provides ca bundle byte content func (c unionCAContent) CurrentCABundleContent() []byte { caBundles := [][]byte{} for _, curr := range c { if currCABytes := curr.CurrentCABundleContent(); len(currCABytes) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 3.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/config_compare_test.go
name string prev config.Config curr config.Config expected bool }{ { name: "different gvk", prev: config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.VirtualService, Name: "acme2-v1", Namespace: "not-default", }, Spec: &networking.VirtualService{}, }, curr: config.Config{ Meta: config.Meta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 03 16:47:35 UTC 2023 - 5.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/config_compare.go
// to be triggered. This is to avoid unnecessary pushes only when labels have changed // for example. func needsPush(prev config.Config, curr config.Config) bool { if prev.GroupVersionKind != curr.GroupVersionKind { // This should never happen. return true } // If the config is not Istio, let us just push. if !strings.HasSuffix(prev.GroupVersionKind.Group, "istio.io") {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 03 16:47:35 UTC 2023 - 2.1K bytes - Viewed (0) -
src/runtime/vdso_freebsd.go
for { if timekeepSharedPage.enabled == 0 { return zeroBintime } curr := atomic.Load(&timekeepSharedPage.current) // atomic_load_acq_32 th := &timehands[curr] gen := atomic.Load(&th.gen) // atomic_load_acq_32 bt = th.offset if tc, ok := th.getTimecounter(); !ok { return zeroBintime } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 2.4K bytes - Viewed (0)