Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ObserveWatchCount (0.24 sec)

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

    		return WorkEstimate{
    			InitialSeats:      minSeats,
    			FinalSeats:        0,
    			AdditionalLatency: time.Duration(0),
    		}
    	}
    
    	watchCount := e.countFn(requestInfo)
    	metrics.ObserveWatchCount(r.Context(), priorityLevelName, flowSchemaName, watchCount)
    
    	// The cost of the request associated with the watchers of that event
    	// consists of three parts:
    	// - cost of going through the event change logic
    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/metrics/metrics.go

    		reqType = requestInfo.Verb
    	}
    	apiserverRequestExecutionSeconds.WithContext(ctx).WithLabelValues(priorityLevel, flowSchema, reqType).Observe(executionTime.Seconds())
    }
    
    // ObserveWatchCount notes a sampling of a watch count
    func ObserveWatchCount(ctx context.Context, priorityLevel, flowSchema string, count int) {
    	watchCountSamples.WithLabelValues(priorityLevel, flowSchema).Observe(float64(count))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 24 19:40:05 UTC 2023
    - 25.6K bytes
    - Viewed (0)
Back to top