Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for sites (0.2 sec)

  1. cmd/site-replication.go

    		info.Sites = append(info.Sites, peer)
    	}
    	sort.Slice(info.Sites, func(i, j int) bool {
    		return info.Sites[i].Name < info.Sites[j].Name
    	})
    
    	info.ServiceAccountAccessKey = c.state.ServiceAccountAccessKey
    	return info, nil
    }
    
    const (
    	makeBucketWithVersion   = "MakeBucketWithVersioning"
    	configureReplication    = "ConfigureReplication"
    	deleteBucket            = "DeleteBucket"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  2. cmd/api-errors.go

    		Code:           "XMinioSiteReplicationConfigMissingError",
    		Description:    "Site not found in site replication configuration",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrSiteReplicationIAMConfigMismatch: {
    		Code:           "XMinioSiteReplicationIAMConfigMismatch",
    		Description:    "IAM configuration mismatch between sites",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrAdminRebalanceAlreadyStarted: {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  3. cmd/erasure-server-pool.go

    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    
    	err := z.s3Peer.DeleteBucket(ctx, bucket, opts)
    	if err == nil || isErrBucketNotFound(err) {
    		// If site replication is configured, hold on to deleted bucket state until sites sync
    		if opts.SRDeleteOp == MarkDelete {
    			z.s3Peer.MakeBucket(context.Background(), pathJoin(minioMetaBucket, bucketMetaPrefix, deletedBucketsPrefix, bucket), MakeBucketOptions{})
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    		return
    	}
    
    	ot, err := objAPI.GetObjectTags(ctx, bucket, object, opts)
    	if err != nil {
    		// if object/version is not found locally, but exists on peer site - proxy
    		// the tagging request to peer site. The response to client will
    		// return tags from peer site.
    		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    			proxytgts := getProxyTargets(ctx, bucket, object, opts)
    			if !proxytgts.Empty() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. cmd/bucket-targets.go

    			return tgt.Arn, true
    		}
    	}
    	if !target.Type.IsValid() {
    		return
    	}
    	return generateARN(target, deplID), false
    }
    
    // getRemoteARNForPeer returns the remote target for a peer site in site replication
    func (sys *BucketTargetSys) getRemoteARNForPeer(bucket string, peer madmin.PeerInfo) string {
    	sys.RLock()
    	defer sys.RUnlock()
    	tgts := sys.targetsMap[bucket]
    	for _, target := range tgts {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  6. cmd/endpoint-ellipses.go

    	setIndexes  [][]uint64 // All the sets.
    }
    
    // Supported set sizes this is used to find the optimal
    // single set size.
    var setSizes = []uint64{2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16}
    
    // getDivisibleSize - returns a greatest common divisor of
    // all the ellipses sizes.
    func getDivisibleSize(totalSizes []uint64) (result uint64) {
    	gcd := func(x, y uint64) uint64 {
    		for y != 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    	}
    }
    
    // Uploads an object using DummyDataGen directly via the http
    // handler. Each part in a multipart object is a new DummyDataGen
    // instance (so the part sizes are needed to reconstruct the whole
    // object). When `len(partSizes) == 1`, asMultipart is used to upload
    // the object as multipart with 1 part or as a regular single object.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  8. cmd/object-api-interface.go

    	Force      bool             // Force deletion
    	SRDeleteOp SRBucketDeleteOp // only when site replication is enabled
    }
    
    // BucketOptions provides options for ListBuckets and GetBucketInfo call.
    type BucketOptions struct {
    	Deleted bool // true only when site replication is enabled
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  9. cmd/sts-handlers.go

    	updatedAt, err := globalIAMSys.SetTempUser(ctx, cred.AccessKey, cred, "")
    	if err != nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInternalError, err)
    		return
    	}
    
    	// Call hook for site replication.
    	if cred.ParentUser != globalActiveCred.AccessKey {
    		replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{
    			Type: madmin.SRIAMItemSTSAcc,
    			STSCredential: &madmin.SRSTSCredential{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
  10. cmd/data-scanner.go

    			sizeS.failedSize += oi.Size
    			sizeS.failedCount++
    		case replication.Completed, replication.CompletedLegacy:
    			tgtSizeS.replicatedSize += oi.Size
    			tgtSizeS.replicatedCount++
    			sizeS.replicatedSize += oi.Size
    			sizeS.replicatedCount++
    		}
    		sizeS.replTargetStats[arn] = tgtSizeS
    	}
    
    	if oi.ReplicationStatus == replication.Replica {
    		sizeS.replicaSize += oi.Size
    		sizeS.replicaCount++
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
Back to top