- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 362 for expiring (0.38 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/cache/expiring.go
) // NewExpiring returns an initialized expiring cache. func NewExpiring() *Expiring { return NewExpiringWithClock(clock.RealClock{}) } // NewExpiringWithClock is like NewExpiring but allows passing in a custom // clock for testing. func NewExpiringWithClock(clock clock.Clock) *Expiring { return &Expiring{ clock: clock, cache: make(map[interface{}]entry), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 22 15:51:23 UTC 2023 - 5.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/server/scaninfo/DaemonScanInfoIntegrationSpec.groovy
} else { executer.withArgument('waitForExpiration') } executer.run() then: file(EXPIRATION_EVENT).text.startsWith "onExpirationEvent fired with: expiring daemon with TestExpirationStrategy uuid:" where: continuous << [true, false] } def "daemon expiration listener is implicitly for the current build only"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 9.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonRegistryUnavailableExpirationStrategy.java
final File daemonRegistryDir = daemonContext.getDaemonRegistryDir(); if (!new DaemonDir(daemonRegistryDir).getRegistry().canRead()) { LOG.warn("Daemon registry {} became unreadable. Expiring daemon.", daemonRegistryDir); return new DaemonExpirationResult(GRACEFUL_EXPIRE, REGISTRY_BECAME_UNREADABLE); } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache.go
maxSize int evictionList list.List entries map[interface{}]*list.Element } // NewLRUExpireCache creates an expiring cache with the given size func NewLRUExpireCache(maxSize int) *LRUExpireCache { return NewLRUExpireCacheWithClock(maxSize, realClock{}) } // NewLRUExpireCacheWithClock creates an expiring cache with the given size, using the specified clock to obtain the current time.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 4.3K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-go-create-without-running-g.go
// // GoCreate events can happen on bare Ps in a variety of situations and // and earlier version of the parser assumed this wasn't possible. At // the time of writing, one such example is goroutines created by expiring // timers. package main import ( "internal/trace" "internal/trace/event/go122" testgen "internal/trace/internal/testgen/go122" ) func main() { testgen.Main(gen) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 996 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cache_simple.go
limitations under the License. */ package cache import ( "time" utilcache "k8s.io/apimachinery/pkg/util/cache" "k8s.io/utils/clock" ) type simpleCache struct { cache *utilcache.Expiring } func newSimpleCache(clock clock.Clock) cache { return &simpleCache{cache: utilcache.NewExpiringWithClock(clock)} } func (c *simpleCache) get(key string) (*cacheRecord, bool) { record, ok := c.cache.Get(key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 1.2K bytes - Viewed (0) -
src/net/http/internal/testcert/testcert.go
// Package testcert contains a test-only localhost certificate. package testcert import "strings" // LocalhostCert is a PEM-encoded TLS cert with SAN IPs // "127.0.0.1" and "[::1]", expiring at Jan 29 16:00:00 2084 GMT. // generated from src/crypto/tls: // go run generate_cert.go --rsa-bits 2048 --host 127.0.0.1,::1,example.com --ca --start-date "Jan 1 00:00:00 1970" --duration=1000000h
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jan 08 00:24:25 UTC 2022 - 3.6K bytes - Viewed (0) -
pkg/controller/bootstrap/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package bootstrap provides automatic processes necessary for bootstraping. // This includes managing and expiring tokens along with signing well known // configmaps with those tokens.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 10 20:47:25 UTC 2017 - 831 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CookieJar.kt
* implementations may store cookies in memory; sophisticated ones may use the file system or * database to hold accepted cookies. The [cookie storage model][rfc_6265_53] specifies policies for * updating and expiring cookies. * * [rfc_6265_53]: https://tools.ietf.org/html/rfc6265#section-5.3 */ interface CookieJar { /** * Saves [cookies] from an HTTP response to this store according to this jar's policy. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/cache.go
import ( "bytes" "time" "unsafe" utilcache "k8s.io/apimachinery/pkg/util/cache" "k8s.io/apiserver/pkg/storage/value" "k8s.io/utils/clock" ) type simpleCache struct { cache *utilcache.Expiring ttl time.Duration } func newSimpleCache(clock clock.Clock, ttl time.Duration) *simpleCache { cache := utilcache.NewExpiringWithClock(clock)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 2.6K bytes - Viewed (0)