- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,939 for dilation (0.14 sec)
-
pkg/controller/tainteviction/taint_eviction_test.go
// verify pod is not queued for deletion if controller.taintEvictionQueue.GetWorkerUnsafe(podNamespacedName.String()) != nil { t.Fatalf("pod queued for deletion with no taints") } // no taint -> infinitely tolerated taint nodeIndexer.Update(singleTaintedNode) controller.handleNodeUpdate(ctx, nodeUpdateItem{"node1"}) // verify pod is not queued for deletion
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/integrator.go
} // AvgAndStdDev returns the average and standard devation func (igr Moments) AvgAndStdDev() (float64, float64) { if igr.ElapsedSeconds <= 0 { return math.NaN(), math.NaN() } avg := igr.IntegralX / igr.ElapsedSeconds // standard deviation is sqrt( average( (x - xbar)^2 ) ) // = sqrt( Integral( x^2 + xbar^2 -2*x*xbar dt ) / Duration ) // = sqrt( ( Integral( x^2 dt ) + Duration * xbar^2 - 2*xbar*Integral(x dt) ) / Duration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 17:37:20 UTC 2022 - 5K bytes - Viewed (0) -
pkg/controller/job/backoff_utils.go
if p.DeletionTimestamp != nil { finishTime := p.DeletionTimestamp.Time.Add(-time.Duration(ptr.Deref(p.DeletionGracePeriodSeconds, 0)) * time.Second) return &finishTime } return nil } func (backoff backoffRecord) getRemainingTime(clock clock.WithTicker, defaultBackoff time.Duration, maxBackoff time.Duration) time.Duration {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_generated_ops.td
Arg<TF_I32OrI64Tensor, [{the padding to apply at the start and end of each input dimensions}]>:$padding, Arg<TF_I32OrI64Tensor, [{dilation to apply between input elements}]>:$lhs_dilation, Arg<TF_I32OrI64Tensor, [{dilation to apply between kernel elements}]>:$rhs_dilation, Arg<TF_I32OrI64Tensor, [{number of feature groups for grouped convolution.}]>:$feature_group_count,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 23:24:08 UTC 2024 - 793K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
// if the node is marked for deletion by autoscaler. // 4. get proxy health by verifying that the delay between QueuedUpdate() // calls and Updated() calls exceeded healthTimeout or not. type ProxierHealthServer struct { listener listener httpFactory httpServerFactory clock clock.Clock addr string healthTimeout time.Duration lock sync.RWMutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/cache/types.go
// e.g: plugin with name foo registers at foo.com/foo-1.9.7 later a plugin with name foo // registers at foo.com/foo-1.9.9 // // DeRegistration: When ReRegistration happens only the deletion of the new socket will trigger a DeRegister call type PluginHandler interface { // Validate returns an error if the information provided by // the potential plugin is erroneous (unsupported version, ...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/proxy/config/config.go
OnServiceAdd(service *v1.Service) // OnServiceUpdate is called whenever modification of an existing // service object is observed. OnServiceUpdate(oldService, service *v1.Service) // OnServiceDelete is called whenever deletion of an existing service // object is observed. OnServiceDelete(service *v1.Service) // OnServiceSynced is called once all the initial event handlers were // called and the state is fully propagated to local cache.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils.go
dnsName, caFilePath string, approveCsr, appendCaCert bool, requestedLifetime time.Duration, ) ([]byte, []byte, error) { // 1. Submit the CSR csr, err := submitCSR(client, csrData, signerName, usages, requestedLifetime) if err != nil { return nil, nil, err } log.Debugf("CSR (%v) has been created", csr.Name) // clean up certificate request after deletion defer func() { _ = cleanupCSR(client, csr) }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 18:11:22 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
func (ssc *StatefulSetController) enqueueSSAfter(ss *apps.StatefulSet, duration time.Duration) { key, err := controller.KeyFunc(ss) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", ss, err)) return } ssc.queue.AddAfter(key, duration) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
nodeLister corelisters.NodeLister nodeListerSynced cache.InformerSynced nodeQueue workqueue.TypedDelayingInterface[string] terminatedPodThreshold int gcCheckPeriod time.Duration quarantineTime time.Duration } func NewPodGC(ctx context.Context, kubeClient clientset.Interface, podInformer coreinformers.PodInformer, nodeInformer coreinformers.NodeInformer, terminatedPodThreshold int) *PodGCController {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0)