- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,626 for startLine (0.42 sec)
-
pkg/controller/namespace/namespace_controller.go
func (nm *NamespaceController) syncNamespaceFromKey(ctx context.Context, key string) (err error) { startTime := time.Now() logger := klog.FromContext(ctx) defer func() { logger.V(4).Info("Finished syncing namespace", "namespace", key, "duration", time.Since(startTime)) }() namespace, err := nm.lister.Get(key) if errors.IsNotFound(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
"github.com/minio/pkg/v3/env" "github.com/minio/pkg/v3/workers" ) // PoolDecommissionInfo currently decommissioning information type PoolDecommissionInfo struct { StartTime time.Time `json:"startTime" msg:"st"` StartSize int64 `json:"startSize" msg:"ss"` TotalSize int64 `json:"totalSize" msg:"ts"` CurrentSize int64 `json:"currentSize" msg:"cs"` Complete bool `json:"complete" msg:"cmp"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1) -
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) -
subprojects/core/src/main/java/org/gradle/internal/buildevents/BuildStartedTime.java
public class BuildStartedTime { private volatile long startTime; public static BuildStartedTime startingAt(long startTime) { return new BuildStartedTime(startTime); } public BuildStartedTime(long startTime) { this.startTime = startTime; } public long getStartTime() { return startTime; } public void reset(long startTime) { this.startTime = startTime; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Sep 13 03:50:47 UTC 2017 - 1.4K bytes - Viewed (0)