Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 668 for countFn (0.15 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go

    )
    
    func newMutatingWorkEstimator(countFn watchCountGetterFunc, config *WorkEstimatorConfig, maxSeatsFn maxSeatsFunc) WorkEstimatorFunc {
    	estimator := &mutatingWorkEstimator{
    		config:     config,
    		countFn:    countFn,
    		maxSeatsFn: maxSeatsFn,
    	}
    	return estimator.estimate
    }
    
    type mutatingWorkEstimator struct {
    	config     *WorkEstimatorConfig
    	countFn    watchCountGetterFunc
    	maxSeatsFn maxSeatsFunc
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 19:26:52 UTC 2023
    - 6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go

    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	"k8s.io/klog/v2"
    )
    
    func newListWorkEstimator(countFn objectCountGetterFunc, config *WorkEstimatorConfig, maxSeatsFn maxSeatsFunc) WorkEstimatorFunc {
    	estimator := &listWorkEstimator{
    		config:        config,
    		countGetterFn: countFn,
    		maxSeatsFn:    maxSeatsFn,
    	}
    	return estimator.estimate
    }
    
    type listWorkEstimator struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 7K bytes
    - Viewed (0)
  3. src/runtime/stack_test.go

    func count13(n int) int { return 1 + count14(n-1) }
    func count14(n int) int { return 1 + count15(n-1) }
    func count15(n int) int { return 1 + count16(n-1) }
    func count16(n int) int { return 1 + count17(n-1) }
    func count17(n int) int { return 1 + count18(n-1) }
    func count18(n int) int { return 1 + count19(n-1) }
    func count19(n int) int { return 1 + count20(n-1) }
    func count20(n int) int { return 1 + count21(n-1) }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 23.1K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/telemetry/internal/counter/counter.go

    	return &Counter{name: name, file: &defaultFile}
    }
    
    // Inc adds 1 to the counter.
    func (c *Counter) Inc() {
    	c.Add(1)
    }
    
    // Add adds n to the counter. n cannot be negative, as counts cannot decrease.
    func (c *Counter) Add(n int64) {
    	debugPrintf("Add %q += %d", c.name, n)
    
    	if n < 0 {
    		panic("Counter.Add negative")
    	}
    	if n == 0 {
    		return
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  5. pkg/monitoring/counter.go

    	api "go.opentelemetry.io/otel/metric"
    
    	"istio.io/istio/pkg/log"
    )
    
    type counter struct {
    	baseMetric
    	c api.Float64Counter
    	// precomputedAddOption is just a precomputation to avoid allocations on each record call
    	precomputedAddOption []api.AddOption
    }
    
    var _ Metric = &counter{}
    
    func newCounter(o options) *counter {
    	c, err := meter().Float64Counter(o.name,
    		api.WithDescription(o.description),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  6. tests/count_test.go

    		t.Fatalf("Count should be 3, but got count: %v err %v", count10, err)
    	}
    
    	var count11 int64
    	sameUsers := make([]*User, 0)
    	for i := 0; i < 3; i++ {
    		sameUsers = append(sameUsers, GetUser("count-4", Config{}))
    	}
    	DB.Create(sameUsers)
    
    	if err := DB.Model(&User{}).Where("name = ?", "count-4").Group("name").Count(&count11).Error; err != nil || count11 != 1 {
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Mon Oct 30 09:15:49 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting.go

    	cond          sync.Cond
    	activeCounter counter.GoRoutineCounter // counter of active goroutines
    	waitingCount  int                      // number of goroutines idle due to this being unset
    	isSet         bool
    	value         interface{}
    }
    
    var _ promiseifc.WriteOnce = &countingPromise{}
    
    // NewCountingWriteOnce creates a WriteOnce that uses locking and counts goroutine activity.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 10 14:37:53 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  8. subprojects/core/src/integTest/groovy/org/gradle/api/services/BuildServiceIntegrationTest.groovy

            }
    
            when:
            run("count")
    
            then:
            output.count("service:") == 6
            output.count("service: created with value = 10") == 2
            output.count("service: value is 11") == 2
            output.count("service: closed with value 11")
    
            when:
            run("count")
    
            then:
            output.count("service:") == 3
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 19:15:46 UTC 2024
    - 61K bytes
    - Viewed (0)
  9. src/cmd/vendor/golang.org/x/telemetry/counter/counter.go

    // each time the corresponding event is observed.
    //
    // Although it is possible to use New to create
    // a Counter each time a particular event needs to be recorded,
    // that usage fails to amortize the construction cost over
    // multiple calls to Add, so it is more expensive and not recommended.
    type Counter = counter.Counter
    
    // A StackCounter is the in-memory knowledge about a stack counter.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 15 18:02:34 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. platforms/jvm/language-groovy/src/testFixtures/resources/org/gradle/groovy/compile/AbstractGroovyCompilerIntegrationSpec/gradle3235/src/main/groovy/com/example/Country.groovy

    package com.example
    
    import groovy.transform.Canonical
    import groovy.transform.CompileStatic
    
    @Canonical
    @CompileStatic
    class Country {
    
        String name
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Aug 28 11:40:18 UTC 2023
    - 155 bytes
    - Viewed (0)
Back to top