- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of about 10,000 for recur1 (0.22 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/filter.go
func NewRecorder(w Interface) *Recorder { r := &Recorder{} r.Interface = Filter(w, r.record) return r } // record is a FilterFunc and tracks each received event. func (r *Recorder) record(in Event) (Event, bool) { r.lock.Lock() defer r.lock.Unlock() r.events = append(r.events, in) return in, true } // Events returns a copy of the events sent across this recorder.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.8K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
return nil, fmt.Errorf("could not initialize ephemeral volume controller: %w", err) } return ec, nil } func (ec *ephemeralController) enqueuePod(obj interface{}) { pod, ok := obj.(*v1.Pod) if !ok { return } // Ignore pods which are already getting deleted. if pod.DeletionTimestamp != nil { return } for _, vol := range pod.Spec.Volumes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/monitoring.go
func IncrementEnvoyFilterErrorMetric(pt PatchType) { if !features.EnableEnvoyFilterMetrics { return } envoyFilterStatus.With(patchType.Value(string(pt))).With(resultType.Value(string(Error))).Record(1) } func RecordMetrics() { if !features.EnableEnvoyFilterMetrics { return } envoyFilterMutex.RLock() defer envoyFilterMutex.RUnlock() for name, pmap := range envoyFilterStatusMap {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/test_helpers.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 3.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java
ComponentUtil.getCrawlerStatsHelper().record(urlQueue, StatsAction.CHILD_URL); } } @Override protected void processProcessChildUrlsByException(final Object... objs) { super.processProcessChildUrlsByException(objs); if (objs.length > 1 && objs[1] instanceof final UrlQueue<?> urlQueue) { ComponentUtil.getCrawlerStatsHelper().record(urlQueue, StatsAction.CHILD_URLS); } }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
c.serviceCIDRsSynced = c.serviceCIDRInformer.HasSynced return c } // Controller manages selector-based service ipAddress. type Controller struct { cidrs []string // order matters, first cidr defines the default IP family client clientset.Interface eventBroadcaster record.EventBroadcaster eventRecorder record.EventRecorder serviceCIDRInformer cache.SharedIndexInformer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
return nil, fmt.Errorf("Controller: Invalid --cluster-cidr, mask size of cluster CIDR must be less than or equal to --node-cidr-mask-size configured for CIDR family") } } } ic := &Controller{ cloud: cloud, kubeClient: kubeClient, eventBroadcaster: record.NewBroadcaster(record.WithContext(ctx)), clusterCIDRs: clusterCIDRs,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/volume_host.go
return "" } func (ctrl *PersistentVolumeController) GetPodsDir() string { return "" } func (ctrl *PersistentVolumeController) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string { return "" } func (ctrl *PersistentVolumeController) GetPodPluginDir(podUID types.UID, pluginName string) string { return "" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
return true } return false } // Implementing VolumeHost interface func (expc *expandController) GetPluginDir(pluginName string) string { return "" } func (expc *expandController) GetVolumeDevicePluginDir(pluginName string) string { return "" } func (expc *expandController) GetPodsDir() string { return "" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/cache.go
record, ok := c.cache.Get(c.keyFunc(key)) if !ok { return nil } return record.(value.Read) } // set caches the record for the key func (c *simpleCache) set(key []byte, transformer value.Read) { c.mu.Lock() defer c.mu.Unlock() if len(key) == 0 { panic("key must not be empty") } if transformer == nil { panic("transformer must not be nil") } c.cache.Set(c.keyFunc(key), transformer, c.ttl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 31 20:26:58 UTC 2023 - 3.5K bytes - Viewed (0)