Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for plastid (0.24 sec)

  1. cmd/tier-last-day-stats.go

    	// within the hour since l.UpdatedAt
    	if since < 1 {
    		return
    	}
    
    	idx, lastIdx := t.Hour(), l.UpdatedAt.Hour()
    
    	l.UpdatedAt = t // update to the latest time index
    
    	if since >= 24 {
    		l.Bins = [24]tierStats{}
    		return
    	}
    
    	for lastIdx != idx {
    		lastIdx = (lastIdx + 1) % 24
    		l.Bins[lastIdx] = tierStats{}
    	}
    }
    
    func (l *lastDayTierStats) clone() lastDayTierStats {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    	uploadID := r.Form.Get(xhttp.UploadID)
    	partIDString := r.Form.Get(xhttp.PartNumber)
    
    	partID, err := strconv.Atoi(partIDString)
    	if err != nil || partID <= 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidPart), r.URL)
    		return
    	}
    
    	// check partID with maximum part ID for multipart objects
    	if isMaxPartID(partID) {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidMaxParts), r.URL)
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    	if err := checkNewMultipartArgs(ctx, srcBucket, srcObject); err != nil {
    		return PartInfo{}, err
    	}
    
    	return z.PutObjectPart(ctx, destBucket, destObject, uploadID, partID,
    		srcInfo.PutObjReader, dstOpts)
    }
    
    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-api-multipart_test.go

    		// Test case  1-4.
    		// Cases with invalid bucket name.
    		{bucketName: ".test", objName: "obj", PartID: 1, expectedError: fmt.Errorf("%s", "Bucket name invalid: .test")},
    		{bucketName: "------", objName: "obj", PartID: 1, expectedError: fmt.Errorf("%s", "Bucket name invalid: ------")},
    		{
    			bucketName: "$this-is-not-valid-too", objName: "obj", PartID: 1,
    			expectedError: fmt.Errorf("%s", "Bucket name invalid: $this-is-not-valid-too"),
    		},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 77.1K bytes
    - Viewed (0)
  5. cmd/metacache-server-pool.go

    	}
    	entries.reuse = true
    	truncated := entries.len() > o.Limit || err == nil
    	entries.truncate(o.Limit)
    	if !o.Transient && truncated {
    		if o.ID == "" {
    			entries.listID = mustGetUUID()
    		} else {
    			entries.listID = o.ID
    		}
    	}
    	if !truncated {
    		return entries, io.EOF
    	}
    	return entries, nil
    }
    
    // listMerged will list across all sets and return a merged results stream.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  6. cmd/encryption-v1.go

    	metadata       map[string]string
    
    	partDecRelOffset, partEncRelOffset int64
    
    	copySource bool
    	// Customer Key
    	customerKeyHeader string
    }
    
    func (d *DecryptBlocksReader) buildDecrypter(partID int) error {
    	m := cloneMSS(d.metadata)
    	// Initialize the first decrypter; new decrypters will be
    	// initialized in Read() operation as needed.
    	var key []byte
    	var err error
    	if d.copySource {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  7. internal/event/target/elasticsearch.go

    	"time"
    
    	elasticsearch7 "github.com/elastic/go-elasticsearch/v7"
    	"github.com/minio/highwayhash"
    	"github.com/minio/minio/internal/event"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v2/net"
    	"github.com/pkg/errors"
    )
    
    // Elastic constants
    const (
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    		var cp []CompletePart
    		cumulativeSum := int64(0)
    		for i, partLen := range partSizes {
    			partID := i + 1
    			partSrc := NewDummyDataGen(partLen, cumulativeSum)
    			cumulativeSum += partLen
    			req, errP := newTestSignedRequestV4(http.MethodPut,
    				getPutObjectPartURL("", bucketName, objectName, upID, fmt.Sprintf("%d", partID)),
    				partLen, partSrc, creds.AccessKey, creds.SecretKey, metadata)
    			if errP != nil {
    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)
  9. cmd/metacache-entries.go

    	}
    	return res
    }
    
    // metaCacheEntriesSorted contains metacache entries that are sorted.
    type metaCacheEntriesSorted struct {
    	o metaCacheEntries
    	// list id is not serialized
    	listID string
    	// Reuse buffers
    	reuse bool
    	// Contain the last skipped object after an ILM expiry evaluation
    	lastSkippedEntry string
    }
    
    // shallowClone will create a shallow clone of the array objects,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  10. cmd/erasure-multipart.go

    		partNumber := partI.Number
    		if partID != partNumber {
    			internalLogIf(ctx, fmt.Errorf("part.%d.meta has incorrect corresponding part number: expected %d, got %d", partID, partID, partI.Number))
    			return oi, InvalidPart{
    				PartNumber: partID,
    			}
    		}
    
    		// Add the current part.
    		fi.AddObjectPart(partI.Number, partI.ETag, partI.Size, partI.ActualSize, partI.ModTime, partI.Index, partI.Checksums)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
Back to top