Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 401 for unneeded (0.11 sec)

  1. docs/distributed/README.md

    taking the total count to _(existing_servers\*m)+(newly_added_servers\*m)_ drives. New object upload requests automatically start using the least used cluster. This expansion strategy works endlessly, so you can perpetually expand your clusters as needed.  When you restart, it is immediate and non-disruptive to the applications. Each group of servers in the command-line is called a pool. There are 2 server pools in this example. New objects are placed in server pools in proportion to the amount of...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	sconfig.Net.TLS.Config.InsecureSkipVerify = h.kconfig.TLS.SkipVerify
    	sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth
    	sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. cmd/erasure.go

    	// Otherwise same set of buckets get scanned across erasure sets always.
    	// at any given point in time. This allows different buckets to be scanned
    	// in different order per erasure set, this wider spread is needed when
    	// there are lots of buckets with different order of objects in them.
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	permutes := r.Perm(len(buckets))
    	// Add new buckets first
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. api/maven-api-settings/src/main/mdo/settings.mdo

        <class java.clone="deep">
          <name>RepositoryBase</name>
          <version>1.0.0+</version>
          <superClass>IdentifiableBase</superClass>
          <description>
            Repository contains the information needed
            for establishing connections with remote repository
          </description>
          <fields>
            <field>
              <name>name</name>
              <version>1.0.0+</version>
              <description>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Oct 08 13:46:42 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  5. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/MavenRepositorySystemSupplier.java

     * thrown away immediately once repository system was created and there is no need for more instances. If new
     * repository system instance needed, new instance of this class must be created. For proper shut down of returned
     * repository system instance(s) use {@link RepositorySystem#shutdown()} method on supplied instance(s).
     * <p>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. istioctl/pkg/workload/workload.go

    		for k, v := range metaMap {
    			clusterEnv[k] = v
    		}
    	}
    
    	return os.WriteFile(filepath.Join(dir, "cluster.env"), []byte(mapToString(clusterEnv)), filePerms)
    }
    
    // Get and store the needed certificate and token. The certificate comes from the CA root cert, and
    // the token is generated by kubectl under the workload group's namespace and service account
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  7. internal/grid/handlers.go

    	// A non-nil error value will be returned as RemoteErr(msg) to client.
    	// No client information or cancellation (deadline) is available.
    	// Include this in payload if needed.
    	// Payload should be recycled with PutByteBuffer if not needed after the call.
    	SingleHandlerFn func(payload []byte) ([]byte, *RemoteErr)
    
    	// StatelessHandlerFn must handle incoming stateless request.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/handling-errors.md

    There are some situations in where it's useful to be able to add custom headers to the HTTP error. For example, for some types of security.
    
    You probably won't need to use it directly in your code.
    
    But in case you needed it for an advanced scenario, you can add custom headers:
    
    ```Python hl_lines="14"
    {!../../docs_src/handling_errors/tutorial002.py!}
    ```
    
    ## Install custom exception handlers
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

      override fun close() {
        source.close()
      }
    
      /**
       * Decompression of the header block occurs above the framing layer. This class lazily reads
       * continuation frames as they are needed by [Hpack.Reader.readHeaders].
       */
      internal class ContinuationSource(
        private val source: BufferedSource,
      ) : Source {
        var length: Int = 0
        var flags: Int = 0
        var streamId: Int = 0
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/testing/AbstractPackageSanityTests.java

       * needs to be created in order to invoke a method or constructor. The default value isn't used in
       * testing {@link Object#equals} because more than one sample instances are needed for testing
       * inequality.
       */
      protected final <T> void setDefault(Class<T> type, T value) {
        tester.setDefault(type, value);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 19:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (0)
Back to top