Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for TTL (0.11 sec)

  1. internal/cachevalue/cache.go

    // update function, making it ready for use.
    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func() (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    		opts:     opts,
    	}
    }
    
    // InitOnce initializes the cache with a TTL and an update function. It is
    // guaranteed to be called only once.
    func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func() (T, error)) {
    	t.Once.Do(func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. cmd/etcd.go

    	}
    }
    
    func saveKeyEtcdWithTTL(ctx context.Context, client *etcd.Client, key string, data []byte, ttl int64) error {
    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    	lease, err := client.Grant(timeoutCtx, ttl)
    	if err != nil {
    		return etcdErrToErr(err, client.Endpoints())
    	}
    	_, err = client.Put(timeoutCtx, key, string(data), etcd.WithLease(lease.ID))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  3. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt

        for (i in 0 until answerCount) {
          skipName(buf) // name
    
          val type = buf.readShort().toInt() and 0xffff
          buf.readShort() // class
          @Suppress("UNUSED_VARIABLE")
          val ttl = buf.readInt().toLong() and 0xffffffffL // ttl
          val length = buf.readShort().toInt() and 0xffff
    
          if (type == TYPE_A || type == TYPE_AAAA) {
            val bytes = ByteArray(length)
            buf.read(bytes)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  4. pom.xml

    				<configuration>
    					<includes>
    						<include>**/**Test.java</include>
    					</includes>
    					<systemPropertyVariables>
    						<networkaddress.cache.ttl>-1</networkaddress.cache.ttl>
    						<networkaddress.cache.negative.ttl>-1</networkaddress.cache.negative.ttl>
    					</systemPropertyVariables>
    					<properties>
    						<property>
    							<name>listener</name>
    							<value>jcifs.tests.PrintingRunListener</value>
    XML
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Thu Jan 04 13:19:42 GMT 2024
    - 9.3K bytes
    - Viewed (1)
  5. src/main/java/jcifs/smb/DfsImpl.java

    
            CacheEntry ( long ttl ) {
                this.expiration = System.currentTimeMillis() + ttl * 1000L;
                this.map = new ConcurrentHashMap<>();
            }
        }
    
        private static class NegativeCacheEntry <T> extends CacheEntry<T> {
    
            /**
             * @param ttl
             */
            NegativeCacheEntry ( long ttl ) {
                super(ttl);
            }
    
        }
    
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Thu Jan 05 13:07:29 GMT 2023
    - 29.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

          LoadingCache<String, Integer> cache,
          CountingRemovalListener<String, Integer> removalListener,
          WatchedCreatorLoader loader,
          FakeTicker ticker,
          String keyPrefix,
          long ttl) {
    
        int shift1 = 10 + VALUE_PREFIX;
        loader.setValuePrefix(shift1);
        // fill with initial data
        for (int i = 0; i < 10; i++) {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri Aug 05 17:21:46 GMT 2022
    - 18.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/CacheExpirationTest.java

          LoadingCache<String, Integer> cache,
          CountingRemovalListener<String, Integer> removalListener,
          WatchedCreatorLoader loader,
          FakeTicker ticker,
          String keyPrefix,
          long ttl) {
    
        int shift1 = 10 + VALUE_PREFIX;
        loader.setValuePrefix(shift1);
        // fill with initial data
        for (int i = 0; i < 10; i++) {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri Aug 05 17:21:46 GMT 2022
    - 18.7K bytes
    - Viewed (0)
  8. schema/naming.go

    	commonInitialisms         = []string{"API", "ASCII", "CPU", "CSS", "DNS", "EOF", "GUID", "HTML", "HTTP", "HTTPS", "ID", "IP", "JSON", "LHS", "QPS", "RAM", "RHS", "RPC", "SLA", "SMTP", "SSH", "TLS", "TTL", "UID", "UI", "UUID", "URI", "URL", "UTF8", "VM", "XML", "XSRF", "XSS"}
    	commonInitialismsReplacer *strings.Replacer
    )
    
    func init() {
    	commonInitialismsForReplacer := make([]string, 0, len(commonInitialisms))
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Oct 30 09:15:49 GMT 2023
    - 5.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java

    public class AzureAdAuthenticator implements SsoAuthenticator {
    
        private static final Logger logger = LogManager.getLogger(AzureAdAuthenticator.class);
    
        protected static final String AZUREAD_STATE_TTL = "aad.state.ttl";
    
        protected static final String AZUREAD_AUTHORITY = "aad.authority";
    
        protected static final String AZUREAD_TENANT = "aad.tenant";
    
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 28.1K bytes
    - Viewed (0)
  10. cmd/iam-store.go

    		}
    
    		err := store.saveMappedPolicy(ctx, cred.ParentUser, stsUser, false, mp, options{ttl: ttl})
    		if err != nil {
    			return time.Time{}, err
    		}
    
    		cache.iamSTSPolicyMap.Store(cred.ParentUser, mp)
    	}
    
    	u := newUserIdentity(cred)
    	err := store.saveUserIdentity(ctx, accessKey, stsUser, u, options{ttl: ttl})
    	if err != nil {
    		return time.Time{}, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
Back to top