- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,586 for dilation (0.41 sec)
-
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) -
pkg/controller/replicaset/replica_set.go
} rsc.queue.Add(key) } func (rsc *ReplicaSetController) enqueueRSAfter(rs *apps.ReplicaSet, duration time.Duration) { key, err := controller.KeyFunc(rs) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", rs, err)) return } rsc.queue.AddAfter(key, duration) } func (rsc *ReplicaSetController) addRS(logger klog.Logger, obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/doc.go
// packet size to a virtual time, in our version this corresponds to // adding a service time (i.e., duration) to virtual time. // // The third difference is handled by modifying the algorithm to // dispatch based on an initial guess at the request’s service time // (duration) and then make the corresponding adjustments once the // request’s actual service time is known. This is similar, although
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 12:33:30 UTC 2024 - 6.1K bytes - Viewed (0)