- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,531 for startLine (0.22 sec)
-
pkg/controller/certificates/certificate_controller.go
} cc.queue.Add(key) } func (cc *CertificateController) syncFunc(ctx context.Context, key string) error { logger := klog.FromContext(ctx) startTime := time.Now() defer func() { logger.V(4).Info("Finished syncing certificate request", "csr", key, "elapsedTime", time.Since(startTime)) }() csr, err := cc.csrLister.Get(key) if errors.IsNotFound(err) { logger.V(3).Info("csr has been deleted", "csr", key) return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/endpoint.go
if orchestrated && hostResolveToLocalhost(endpoints[i]) { // time elapsed timeElapsed := time.Since(startTime) // log error only if more than a second has elapsed if timeElapsed > time.Second { reqInfo.AppendTags("elapsedTime", humanize.RelTime(startTime, startTime.Add(timeElapsed), "elapsed", "", )) ctx := logger.SetReqInfo(GlobalContext,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelInterpolator.java
} static class BuildTimestampValueSource extends AbstractValueSource { private final Instant startTime; private final Map<String, String> properties; BuildTimestampValueSource(Instant startTime, Map<String, String> properties) { super(false); this.startTime = startTime; this.properties = properties; } @Override
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 20K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
logger := klog.FromContext(ctx) logger.V(4).Info("Processing PV", "PV", klog.KRef("", pvName)) startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PV", "PV", klog.KRef("", pvName), "cost", time.Since(startTime)) }() pv, err := c.pvLister.Get(pvName) if apierrors.IsNotFound(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
tc.queue.Forget(key) return true } func (tc *TokenCleaner) syncFunc(ctx context.Context, key string) error { logger := klog.FromContext(ctx) startTime := time.Now() defer func() { logger.V(4).Info("Finished syncing secret", "secret", key, "elapsedTime", time.Since(startTime)) }() namespace, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/controller/serviceaccount/serviceaccounts_controller.go
c.queue.AddRateLimited(key) return true } func (c *ServiceAccountsController) syncNamespace(ctx context.Context, key string) error { startTime := time.Now() defer func() { klog.FromContext(ctx).V(4).Info("Finished syncing namespace", "namespace", key, "duration", time.Since(startTime)) }() ns, err := c.nsLister.Get(key) if apierrors.IsNotFound(err) { return nil } if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
rv.queue.AddRateLimited(key) return true } func (rv *ResourceVersionController) sync(ctx context.Context, key string) error { logger := klog.FromContext(ctx) startTime := time.Now() // SVM is a cluster scoped resource so we don't care about the namespace _, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/main/java/org/gradle/initialization/DefaultBuildRequestMetaData.java
private final long startTime; private final boolean interactive; public DefaultBuildRequestMetaData(BuildClientMetaData clientMetaData, long startTime, boolean interactive) { this.clientMetaData = clientMetaData; this.startTime = startTime; this.interactive = interactive; } public DefaultBuildRequestMetaData(long startTime) { this(startTime, false); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:55:06 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary_test.go
Name: "kubelet", StartTime: cgroupStatsMap["/kubelet"].cs.StartTime, CPU: cgroupStatsMap["/kubelet"].cs.CPU, Memory: cgroupStatsMap["/kubelet"].cs.Memory, }) assert.Contains(summary.Node.SystemContainers, statsapi.ContainerStats{ Name: "misc", StartTime: cgroupStatsMap["/misc"].cs.StartTime, CPU: cgroupStatsMap["/misc"].cs.CPU,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
svmc.queue.AddRateLimited(key) return true } func (svmc *SVMController) sync(ctx context.Context, key string) error { logger := klog.FromContext(ctx) startTime := time.Now() if svmc.dependencyGraphBuilder == nil { logger.V(4).Info("dependency graph builder is not set. we will skip migration") return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0)