- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,747 for synced (0.07 sec)
-
internal/kms/secret-key.go
func (secretKey) Version(ctx context.Context) (string, error) { return "v1", nil } // APIs returns an error since the builtin KMS does not provide a list of APIs. func (secretKey) APIs(ctx context.Context) ([]madmin.KMSAPI, error) { return nil, ErrNotSupported } // Status returns a set of endpoints and their KMS status. Since, the builtin KMS is not // external it returns "127.0.0.1: online".
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 8.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
} /** * Schedules {@code callable} on the specified {@code executor}, returning a {@code Future}. * * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.0 (but only since 33.4.0 in the Android flavor) */ @J2ktIncompatible @GwtIncompatible // java.util.concurrent.ScheduledExecutorService // TODO(cpovirk): Return ListenableScheduledFuture?
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableBiMap.java
* reconstructed using public factory methods. This ensures that the implementation types remain * as implementation details. * * <p>Since the bimap is immutable, ImmutableBiMap doesn't require special logic for keeping the * bimap and its inverse in sync during serialization, the way AbstractBiMap does. */ @J2ktIncompatible // serialization
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 22.6K bytes - Viewed (0) -
cmd/os-instrumented.go
operations [osMetricLast]uint64 latency [osMetricLast]lockedLastMinuteLatency } // time an os action. func (o *osMetrics) time(s osMetric) func() { startTime := time.Now() return func() { duration := time.Since(startTime) atomic.AddUint64(&o.operations[s], 1) o.latency[s].add(duration) } } // incTime will increment time on metric s with a specific duration. func (o *osMetrics) incTime(s osMetric, d time.Duration) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 15 01:09:38 UTC 2024 - 6.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
defer done() for !releaseAll(ctx, dm.clnt, tolerance, owner, &locks, isReadLock, restClnts, dm.Names...) { time.Sleep(time.Duration(dm.rng.Float64() * float64(dm.lockRetryMinInterval))) if time.Since(started) > dm.clnt.Timeouts.UnlockCall { return } } }() } // RUnlock releases a read lock held on dm. // // It is a run-time error if dm is not locked on entry to RUnlock.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
} } // Round the request time *down* to whole minute. reqTimeMinute := reqStartTime.Truncate(time.Minute) if reqTimeMinute.After(h.currentMinute.statsTime) { // Drop the last full minute now, since we got a request for a time we // are not yet tracking. h.updateLastFullMinute(reqTimeMinute) } var entry *serviceRTTMinuteStats switch { case reqTimeMinute.Equal(h.currentMinute.statsTime):
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/metrics-resource.go
// It also maintains the count of number of times this metric // was collected since the server started, and the sum, // average and max values across the same. type ResourceMetric struct { Name MetricName Labels map[string]string // value captured in current cycle Current float64 // Used when system provides cumulative (since uptime) values // helps in calculating the current value by comparing the new
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 23:30:33 UTC 2024 - 17.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
* ({@code this}) will be cancelled and interrupted. * * @param timeout when to time out the future * @param scheduledExecutor The executor service to enforce the timeout. * @since 28.0 (but only since 33.4.0 in the Android flavor) */ @J2ktIncompatible @GwtIncompatible // ScheduledExecutorService public final FluentFuture<V> withTimeout(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (0) -
cmd/tier-last-day-stats.go
func (l *lastDayTierStats) forwardTo(t time.Time) { if t.IsZero() { t = time.Now() } since := t.Sub(l.UpdatedAt).Hours() // within the hour since l.UpdatedAt if since < 1 { return } idx, lastIdx := t.Hour(), l.UpdatedAt.Hour() l.UpdatedAt = t // update to the latest time index if since >= 24 { l.Bins = [24]tierStats{} return } for lastIdx != idx {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 2.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.6.md
- [Node Binaries](#node-binaries) - [Changelog since v1.6.12](#changelog-since-v1612) - [Other notable changes](#other-notable-changes) - [v1.6.12](#v1612) - [Downloads for v1.6.12](#downloads-for-v1612) - [Client Binaries](#client-binaries-1) - [Server Binaries](#server-binaries-1) - [Node Binaries](#node-binaries-1) - [Changelog since v1.6.11](#changelog-since-v1611) - [Other notable changes](#other-notable-changes-1)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 304K bytes - Viewed (0)