Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 221 for replies (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/notification.go

    				info.Disks = getOfflineDisks(client.host.String(), globalEndpoints)
    			}
    			replies[idx] = info
    		}(client, i)
    	}
    	wg.Wait()
    
    	// Add local to this server.
    	replies = append(replies, objLayer.LocalStorageInfo(ctx, metrics))
    
    	storageInfo.Backend = objLayer.BackendInfo()
    	for _, sinfo := range replies {
    		storageInfo.Disks = append(storageInfo.Disks, sinfo.Disks...)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  2. cmd/auth-handler_test.go

    	if err := signRequestV4(req, cred.AccessKey, cred.SecretKey); err != nil {
    		t.Fatalf("Unable to initialized new signed http request %s", err)
    	}
    	return req
    }
    
    // Tests is requested authenticated function, tests replies for s3 errors.
    func TestIsReqAuthenticated(t *testing.T) {
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  3. cmd/erasure-object.go

    	// Default deleteMarker to true if object is under versioning
    	deleteMarker := opts.Versioned
    
    	if opts.VersionID != "" {
    		// case where replica version needs to be deleted on target cluster
    		if versionFound && opts.DeleteMarkerReplicationStatus() == replication.Replica {
    			markDelete = false
    		}
    		if opts.VersionPurgeStatus().Empty() && opts.DeleteMarkerReplicationStatus().Empty() {
    			markDelete = false
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  4. docs/bucket/replication/DESIGN.md

    replication is configured, any incoming uploads and metadata changes to versions created on the target, will sync back to the source and be marked as `REPLICA` on the source. AWS, as well as MinIO do not by default sync metadata changes on a object version marked `REPLICA` back to source. This requires a setting in the replication configuration called [replica modification sync](https://aws.amazon.com/about-aws/whats-new/2020/12/amazon-s3-replication-adds-support-two-way-replication/).
    
    For active-active...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  5. docs/site-replication/README.md

    # Automatic Site Replication
    
    This feature allows multiple independent MinIO sites (or clusters) that are using the same external IDentity Provider (IDP) to be configured as replicas. In this situation the set of replica sites are referred to as peer sites or just sites. When site-replication is enabled on a set of sites, the following changes are replicated to all other sites:
    
    - Creation and deletion of buckets and objects
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  6. internal/bucket/replication/rule.go

    	}
    	return r.ExistingObjectReplication.Validate()
    }
    
    // MetadataReplicate  returns true if object is not a replica or in the case of replicas,
    // replica modification sync is enabled.
    func (r Rule) MetadataReplicate(obj ObjectOpts) bool {
    	if !obj.Replica {
    		return true
    	}
    	return obj.Replica && r.SourceSelectionCriteria.ReplicaModifications.Status == Enabled
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  7. docs/bucket/replication/README.md

    ## Replica Modification sync
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.3K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/math/IntMathTest.java

          }
        }
      }
    
      // Relies on the correctness of BigIntegerMath.log2 for all modes except UNNECESSARY.
      public void testLog2MatchesBigInteger() {
        for (int x : POSITIVE_INTEGER_CANDIDATES) {
          for (RoundingMode mode : ALL_SAFE_ROUNDING_MODES) {
            assertEquals(BigIntegerMath.log2(valueOf(x), mode), IntMath.log2(x, mode));
          }
        }
      }
    
      // Relies on the correctness of isPowerOfTwo(int).
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 19:31:30 GMT 2025
    - 24.1K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        if (replica.containsKey(newValue)) {
          replica.get(newValue).incrementAndGet();
        } else {
          replica.put(newValue, new AtomicInteger(1));
        }
      }
    
      private static void removeMinFromReplica(
          SortedMap<Integer, AtomicInteger> replica, int minValue) {
        Integer replicatedMinValue = replica.firstKey();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  10. internal/bucket/replication/datatypes.go

    	// CompletedLegacy was called "COMPLETE" incorrectly.
    	CompletedLegacy StatusType = "COMPLETE"
    
    	// Failed - replication failed.
    	Failed StatusType = "FAILED"
    
    	// Replica - this is a replica.
    	Replica StatusType = "REPLICA"
    )
    
    // String returns string representation of status
    func (s StatusType) String() string {
    	return string(s)
    }
    
    // Empty returns true if this status is not set
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 03 06:45:06 GMT 2025
    - 2.3K bytes
    - Click Count (0)
Back to Top