- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 272 for refreshed (0.13 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) -
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) -
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) -
tests/integration/ambient/cacert_rotation_test.go
"cert-chain-alt-2.pem", "root-cert-alt.pem"); err != nil { t.Errorf("failed to update CA secret: %v", err) } // perform one retry to handle race condition where ztunnel cert is refreshed before Istiod certificates are reloaded retry.UntilSuccess(func() error { newWorkloadCert := waitForWorkloadCertUpdate(t, ztunnelPod, sa, istioCtl, originalWorkloadSecret)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver.go
evictionDuration time.Duration // Refresher job running interval. refreshInterval time.Duration // Refresher job running interval on failure. refreshIntervalOnFailure time.Duration // Refresher job default running interval without failure. refreshDefaultInterval time.Duration retryInterval time.Duration // How many times refresh job has detected JWT public key change happened, used in unit test.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0) -
src/internal/trace/reader.go
if ok, err := r.order.Advance(&bc.ev, r.gen.evTable, bc.m, r.gen.gen); !ok || err != nil { return ok, err } // Refresh the cursor's event. ok, err := bc.nextEvent(r.gen.batches[bc.m], r.gen.freq) if err != nil { return false, err } if ok { // If we successfully refreshed, update the heap. heapUpdate(r.frontier, i) } else { // There's nothing else to read. Delete this cursor from the frontier.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0)