Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 224 for clusters (0.05 sec)

  1. src/main/java/jcifs/util/SmbCircuitBreaker.java

                    openStateStartTime.set(0);
                }
    
                if (newState == State.OPEN) {
                    openStateStartTime.set(System.currentTimeMillis());
                }
    
                // Reset counters based on transition
                switch (newState) {
                case CLOSED:
                    failureCount.set(0);
                    successCount.set(0);
                    halfOpenAttempts.set(0);
                    break;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  2. docs/sts/ldap.md

    ## Sample `POST` Request
    
    ```
    http://minio.cluster:9000?Action=AssumeRoleWithLDAPIdentity&LDAPUsername=foouser&LDAPPassword=foouserpassword&Version=2011-06-15&DurationSeconds=7200
    ```
    
    ## Sample Response
    
    ```
    <?xml version="1.0" encoding="UTF-8"?>
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/base/Joiner.java

               * modified concurrently), or it might have been only an estimate to begin with (for a
               * collection like ConcurrentHashMap, which sums up several counters that may not be in
               * sync with one another). We accommodate that by resizing as necessary.
               */
              toJoin = Arrays.copyOf(toJoin, expandedCapacity(toJoin.length, toJoin.length + 1));
            }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 15:16:19 UTC 2025
    - 21K bytes
    - Viewed (0)
  4. tensorflow/c/c_api.h

    // A Server instance encapsulates a set of devices and a Session target that
    // can participate in distributed training. A server belongs to a cluster
    // (specified by a ClusterSpec), and corresponds to a particular task in a
    // named job. The server can communicate with any other server in the same
    // cluster.
    
    // In-process TensorFlow server.
    typedef struct TF_Server TF_Server;
    
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

       * <p>Usage example:
       *
       * {@snippet :
       * ListenableFuture<Integer> fetchCounterFuture = ...;
       *
       * // Falling back to a zero counter in case an exception happens when
       * // processing the RPC to fetch counters.
       * ListenableFuture<Integer> faultTolerantFuture = Futures.catching(
       *     fetchCounterFuture, FetchException.class, x -> 0, directExecutor());
       * }
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  6. cmd/api-errors.go

    		Description:    "Cannot add remote target endpoint since this server is in a cluster replication setup",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrReplicationDenyEditError: {
    		Code:           "XMinioReplicationDenyEdit",
    		Description:    "Cannot alter local replication config since this server is in a cluster replication setup",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (1)
  7. cmd/bucket-lifecycle.go

    	return obj, nil
    }
    
    // transition object to target specified by the transition ARN. When an object is transitioned to another
    // storage specified by the transition ARN, the metadata is left behind on source cluster and original content
    // is moved to the transition tier. Note that in the case of encrypted objects, entire encrypted stream is moved
    // to the transition tier without decrypting or re-encrypting.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

                settingsBuilder.put("discovery.type", "single-node");
                // settingsBuilder.putList("discovery.seed_hosts", "127.0.0.1:9301");
                // settingsBuilder.putList("cluster.initial_master_nodes", "127.0.0.1:9301");
            })
                    .build(newConfigs().clusterName("ArraySettingsTest")
                            .numOfNode(1)
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 37.2K bytes
    - Viewed (0)
  9. cmd/admin-bucket-handlers.go

    					continue
    				}
    				v, _ := globalBucketMetadataSys.Get(bucket)
    				bucketMap[bucket] = &v
    			}
    
    			if globalSiteReplicationSys.isEnabled() && v.Suspended() {
    				rpt.SetStatus(bucket, fileName, fmt.Errorf("Cluster replication is enabled for this site, so the versioning state cannot be suspended."))
    				continue
    			}
    
    			if rcfg, _ := globalBucketObjectLockSys.Get(bucket); rcfg.LockEnabled && v.Suspended() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
  10. cmd/peer-rest-client.go

    	}()
    }
    
    // newPeerRestClients creates new peer clients.
    // The two slices will point to the same clients,
    // but 'all' will contain nil entry for local client.
    // The 'all' slice will be in the same order across the cluster.
    func newPeerRestClients(endpoints EndpointServerPools) (remote, all []*peerRESTClient) {
    	if !globalIsDistErasure {
    		// Only useful in distributed setups
    		return nil, nil
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top