Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 453 for curr (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top