- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 334 for refreshed (0.28 sec)
-
pkg/ctrlz/assets/templates/modules/last-refresh.html
{{ define "last-refresh" }} <p class="last-refresh">Last refreshed: <span id="last-refresh"></span></p> <script> function updateRefreshTime() { var d = new Date(); document.getElementById("last-refresh").innerText = d.toLocaleString(); } updateRefreshTime() </script>
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 306 bytes - Viewed (0) -
cmd/lock-rest-server.go
type lockRESTServer struct { ll *localLocker } // RefreshHandler - refresh the current lock func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(context.Background(), *args) if err != nil { return l.makeResp(resp, err) } if !refreshed { return l.makeResp(resp, errLockNotFound) } return l.makeResp(resp, err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 5.9K bytes - Viewed (0) -
internal/dsync/drwmutex.go
log("dsync: Unable to call Refresh failed with %s for %#v at %s\n", err, args, c) } else { ch <- refreshResult{refreshed: refreshed} log("dsync: Refresh returned false for %#v at %s\n", args, c) } }(index, c) } // Wait until we have either // // a) received all refresh responses // b) received too many refreshed for quorum to be still possible // c) timed out //
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/time_budget.go
sync.Mutex clock clock.Clock budget time.Duration maxBudget time.Duration refresh time.Duration // last store last access time last time.Time } func newTimeBudget() timeBudget { result := &timeBudgetImpl{ clock: clock.RealClock{}, budget: time.Duration(0), refresh: refreshPerSecond, maxBudget: maxBudget, } result.last = result.clock.Now() return result }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.6K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
lockMap map[string]int64 // Refresh returns lock not found if set to true lockNotFound bool // Set to true if you want peers servers to do not respond responseDelay int64 } func (l *lockServer) setRefreshReply(refreshed bool) { l.mutex.Lock() defer l.mutex.Unlock() l.lockNotFound = !refreshed } func (l *lockServer) setResponseDelay(responseDelay time.Duration) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
pkg/serviceaccount/metrics.go
Name: "legacy_tokens_total", Help: "Cumulative legacy service account tokens used", StabilityLevel: metrics.ALPHA, }, ) // StaleTokensTotal is the number of stale projected tokens not refreshed on // client side. staleTokensTotal = metrics.NewCounter( &metrics.CounterOpts{ Subsystem: kubeServiceAccountSubsystem, Name: "stale_tokens_total",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/kubelet/container/runtime_cache.go
type runtimeCache struct { sync.Mutex // The underlying container runtime used to update the cache. getter podsGetter // The interval after which the cache should be refreshed. cachePeriod time.Duration // Last time when cache was updated. cacheTime time.Time // The content of the cache. pods []*Pod } // GetPods returns the cached pods if they are not outdated; otherwise, it
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 04:03:51 UTC 2023 - 2.9K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
return restClient.Call("/v1/unlock", args) } func (restClient *ReconnectRESTClient) Refresh(ctx context.Context, args LockArgs) (refreshed bool, err error) { return restClient.Call("/v1/refresh", args) } func (restClient *ReconnectRESTClient) ForceUnlock(ctx context.Context, args LockArgs) (reply bool, err error) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
platforms/jvm/language-java/src/integTest/groovy/org/gradle/java/compile/incremental/AbstractCrossTaskIncrementalCompilationIntegrationTest.groovy
import spock.lang.Issue abstract class AbstractCrossTaskIncrementalCompilationIntegrationTest extends AbstractCrossTaskIncrementalCompilationSupport { def "detects change to dependency and ensures class dependency info refreshed"() { source api: ["class A {}", "class B extends A {}"] source impl: ["class SomeImpl {}", "class ImplB extends B {}", "class ImplB2 extends ImplB {}"] impl.snapshot { run language.compileTaskName }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Feb 06 23:55:46 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/kubelet/token/token_manager.go
// * Check the cache for the current token request. // * If the token exists and does not require a refresh, return the current token. // * Attempt to refresh the token. // * If the token is refreshed successfully, save it in the cache and return the token. // * If refresh fails and the old token is still valid, log an error and return the old token. // * If refresh fails and the old token is no longer valid, return an error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 6.1K bytes - Viewed (0)