Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for whale (0.29 sec)

  1. cmd/server_test.go

    	c.Assert(putMD5, getMD5)
    }
    
    // TestGetPartialObjectMisAligned - tests get object partially miss-aligned.
    // create a large buffer of miss-aligned data and upload it.
    // then make partial range requests to while fetching it back and assert the response content.
    func (s *TestSuiteCommon) TestGetPartialObjectMisAligned(c *check) {
    	// generate a random bucket name.
    	bucketName := getRandomBucketName()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  2. cmd/metrics-v2.go

    	return MetricDescription{
    		Namespace: bucketMetricNamespace,
    		Subsystem: requestsSubsystem,
    		Name:      canceledTotal,
    		Help:      "Total number of S3 requests that were canceled from the client while processing on a bucket",
    		Type:      counterMetric,
    	}
    }
    
    func getILMNodeMetrics() *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval: 10 * time.Second,
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    		return err == toObjectErr(errVolumeNotFound, bucket)
    	}
    	return false
    }
    
    // CopyObjectHandler - Copy Object
    // ----------
    // This implementation of the PUT operation adds an object to a bucket
    // while reading the object from another source.
    // Notice: The S3 client can send secret keys in headers for encryption related jobs,
    // the handler should ensure to remove these keys before sending them to the object layer.
    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)
  4. cmd/bucket-replication.go

    	}
    	tgtArns := cfg.FilterTargetArns(opts)
    	for _, tgtArn := range tgtArns {
    		tgt := globalBucketTargetSys.GetRemoteTargetClient(bucket, tgtArn)
    		// the target online status should not be used here while deciding
    		// whether to replicate as the target could be temporarily down
    		opts.TargetArn = tgtArn
    		replicate := cfg.Replicate(opts)
    		var synchronous bool
    		if tgt != nil {
    			synchronous = tgt.replicateSync
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  5. cmd/site-replication.go

    		}
    	}
    
    	// leave some gaps in priority numbers for flexibility
    	return maxPrio + 10
    }
    
    // returns a slice with site names participating in site replciation but unspecified while adding
    // a new site.
    func getMissingSiteNames(oldDeps, newDeps set.StringSet, currSites []madmin.PeerInfo) []string {
    	diff := oldDeps.Difference(newDeps)
    	var diffSlc []string
    	for _, v := range currSites {
    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)
  6. cmd/object-handlers_test.go

    	caseNumber := 0
    	signFns := []testSignedReqFn{newTestSignedRequestV2, newTestSignedRequestV4}
    	for _, oi := range objectInputs {
    		objLen := objectLength(oi)
    		for _, sf := range signFns {
    			// Read whole object
    			mkGetReq(oi, "", caseNumber, sf)
    			caseNumber++
    
    			// No range requests are possible if the
    			// object length is 0
    			if objLen == 0 {
    				continue
    			}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top