Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 362 for expiring (0.38 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top