Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 653 for initializes (0.27 sec)

  1. internal/cachevalue/cache.go

    }
    
    // NewFromFunc allocates a new cached value instance and initializes it with an
    // 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.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

        assertEquals(Double.doubleToRawLongBits(x), Double.doubleToRawLongBits(y));
      }
    
      /** constructor initializes to given value */
      public void testConstructor() {
        for (double x : VALUES) {
          AtomicDouble a = new AtomicDouble(x);
          assertBitEquals(x, a.get());
        }
      }
    
      /** default constructed initializes to zero */
      public void testConstructor2() {
        AtomicDouble a = new AtomicDouble();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 6.9K bytes
    - Viewed (0)
  3. cmd/erasure-sets_test.go

    	nDisks := 16 // Maximum disks.
    	var erasureDisks []string
    	for i := 0; i < nDisks; i++ {
    		// Do not attempt to create this path, the test validates
    		// so that newErasureSets initializes non existing paths
    		// and successfully returns initialized object layer.
    		disk := filepath.Join(globalTestTmpDir, "minio-"+nextSuffix())
    		erasureDisks = append(erasureDisks, disk)
    		defer os.RemoveAll(disk)
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 12 07:21:56 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  4. internal/config/dns/etcd_dns.go

    // client setting, note this will fail if set to empty when
    // constructor initializes.
    func DomainNames(domainNames []string) EtcdOption {
    	return func(args *CoreDNS) {
    		args.domainNames = domainNames
    	}
    }
    
    // DomainIPs set a list of custom domain IPs, note this will
    // fail if set to empty when constructor initializes.
    func DomainIPs(domainIPs set.StringSet) EtcdOption {
    	return func(args *CoreDNS) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  5. .github/workflows/codeql-analysis.yml

        # the head of the pull request instead of the merge commit.
        - run: git checkout HEAD^2
          if: ${{ github.event_name == 'pull_request' }}
    
        # Initializes the CodeQL tools for scanning.
        - name: Initialize CodeQL
          uses: github/codeql-action/init@v1
          with:
            languages: ${{ matrix.language }}
            # If you wish to specify custom queries, you can do so here or in a config file.
    Others
    - Registered: Fri Mar 01 20:58:10 GMT 2024
    - Last Modified: Wed Jan 19 23:41:02 GMT 2022
    - 2.5K bytes
    - Viewed (0)
  6. cmd/tier-journal.go

    	return &tierDiskJournal{}
    }
    
    // NewTierJournal initializes tier deletion journal
    func NewTierJournal() *TierJournal {
    	j := &TierJournal{
    		tierMemJournal:  newTierMemJournal(1000),
    		tierDiskJournal: newTierDiskJournal(),
    	}
    	return j
    }
    
    // Init initializes an in-memory journal built using a
    // buffered channel for new journal entries. It also initializes the on-disk
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  7. maven-core/src/main/java/org/apache/maven/eventspy/EventSpy.java

             *
             * @return The key-value pairs, never {@code null}.
             */
            Map<String, Object> getData();
        }
    
        /**
         * Initializes the spy.
         *
         * @param context The event spy context, never {@code null}.
         */
        void init(Context context) throws Exception;
    
        /**
         * Notifies the spy of some build event/operation.
         *
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Tue Nov 22 13:26:01 GMT 2022
    - 2.6K bytes
    - Viewed (0)
  8. internal/lock/lock_solaris.go

    // acquire a write lock.
    func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	return lockedOpenFile(path, flag, perm, syscall.F_SETLK)
    }
    
    // LockedOpenFile - initializes a new lock and protects
    // the file from concurrent access across mount points.
    // This implementation doesn't support all the open
    // flags and shouldn't be considered as replacement
    // for os.OpenFile().
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

        assertEquals(Double.doubleToRawLongBits(x), Double.doubleToRawLongBits(y));
      }
    
      /** constructor initializes to given value */
      public void testConstructor() {
        for (double x : VALUES) {
          AtomicDouble a = new AtomicDouble(x);
          assertBitEquals(x, a.get());
        }
      }
    
      /** default constructed initializes to zero */
      public void testConstructor2() {
        AtomicDouble a = new AtomicDouble();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 10.2K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka.go

    	}
    
    	sconfig.Net.KeepAlive = 60 * time.Second
    	sconfig.Net.SASL.User = h.kconfig.SASL.User
    	sconfig.Net.SASL.Password = h.kconfig.SASL.Password
    	initScramClient(h.kconfig, sconfig) // initializes configured scram client.
    	sconfig.Net.SASL.Enable = h.kconfig.SASL.Enable
    
    	tlsConfig, err := saramatls.NewConfig(h.kconfig.TLS.ClientTLSCert, h.kconfig.TLS.ClientTLSKey)
    	if err != nil {
    		return err
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
Back to top