Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 48 for topo (0.2 sec)

  1. cmd/bitrot-whole.go

    	filePath  string
    	shardSize int64 // This is the shard size of the erasure logic
    	hash.Hash       // For bitrot hash
    }
    
    func (b *wholeBitrotWriter) Write(p []byte) (int, error) {
    	err := b.disk.AppendFile(context.TODO(), b.volume, b.filePath, p)
    	if err != nil {
    		return 0, err
    	}
    	_, err = b.Hash.Write(p)
    	if err != nil {
    		return 0, err
    	}
    	return len(p), nil
    }
    
    func (b *wholeBitrotWriter) Close() error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  2. internal/s3select/parquet/reader.go

    	if se == nil {
    		return v, nil
    	}
    
    	var value interface{}
    	switch val := v.(type) {
    	case []byte:
    		// TODO: only strings are supported in s3select output (not
    		// binary arrays) - perhaps we need to check the annotation to
    		// ensure it's UTF8 encoded.
    		value = string(val)
    	case [12]byte:
    		// TODO: This is returned for the parquet INT96 type. We just
    		// treat it same as []byte (but AWS S3 treats it as a large int)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  3. cmd/storage-errors.go

    var errFileVersionNotFound = StorageErr("file version not found")
    
    // errTooManyOpenFiles - too many open files.
    var errTooManyOpenFiles = StorageErr("too many open files, please increase 'ulimit -n'")
    
    // errFileNameTooLong - given file name is too long than supported length.
    var errFileNameTooLong = StorageErr("file name too long")
    
    // errVolumeExists - cannot create same volume again.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  4. cmd/data-scanner_test.go

    	versioned := vcfg.Status == "Enabled"
    	wants := make([]ObjectInfo, 2)
    	for i, fi := range fivs[:2] {
    		wants[i] = fi.ToObjectInfo(bucket, obj, versioned)
    	}
    	gots, err := item.applyNewerNoncurrentVersionLimit(context.TODO(), objAPI, fivs, es)
    	if err != nil {
    		t.Fatalf("Failed with err: %v", err)
    	}
    	if len(gots) != len(wants) {
    		t.Fatalf("Expected %d objects but got %d", len(wants), len(gots))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  5. internal/hash/errors.go

    }
    
    // SizeTooSmall reader size too small
    type SizeTooSmall struct {
    	Want int64
    	Got  int64
    }
    
    func (e SizeTooSmall) Error() string {
    	return fmt.Sprintf("Size small: got %d, want %d", e.Got, e.Want)
    }
    
    // SizeTooLarge reader size too large
    type SizeTooLarge struct {
    	Want int64
    	Got  int64
    }
    
    func (e SizeTooLarge) Error() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon May 15 21:08:54 GMT 2023
    - 2.4K bytes
    - Viewed (0)
  6. internal/bucket/replication/destination.go

    	XMLName      xml.Name `xml:"Destination" json:"Destination"`
    	Bucket       string   `xml:"Bucket" json:"Bucket"`
    	StorageClass string   `xml:"StorageClass" json:"StorageClass"`
    	ARN          string
    	// EncryptionConfiguration TODO: not needed for MinIO
    }
    
    func (d Destination) isValidStorageClass() bool {
    	if d.StorageClass == "" {
    		return true
    	}
    	return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY"
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4K bytes
    - Viewed (2)
  7. cmd/signature-v4-utils.go

    			//   expectation  =  "100-continue" | expectation-extension
    			//
    			// So it safe to assume that '100-continue' is what would
    			// be sent, for the time being keep this work around.
    			// Adding a *TODO* to remove this later when Golang server
    			// doesn't filter out the 'Expect' header.
    			extractedSignedHeaders.Set(header, "100-continue")
    		case "host":
    			// Go http server removes "host" from Request.Header
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  8. cmd/erasure-sets_test.go

    		{"object", 37},
    		{"The Shining Script <v1>.pdf", 38},
    		{"Cost Benefit Analysis (2009-2010).pptx", 59},
    		{"117Gn8rfHL2ACARPAhaFd0AGzic9pUbIA/5OCn5A", 35},
    		{"SHØRT", 49},
    		{"There are far too many object names, and far too few bucket names!", 8},
    		{"a/b/c/", 159},
    		{"/a/b/c", 96},
    		{string([]byte{0xff, 0xfe, 0xfd}), 147},
    	}
    
    	// Tests hashing order to be consistent.
    	for i, testCase := range testCases {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 07:21:56 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  9. NOTICE

    MinIO Project, (C) 2015-2023 MinIO, Inc.
    
    This product includes software developed at MinIO, Inc.
    (https://min.io/).
    
    The MinIO project contains unmodified/modified subcomponents too with
    separate copyright notices and license terms. Your use of the source
    code for these subcomponents is subject to the terms and conditions
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 18 18:33:50 GMT 2023
    - 367 bytes
    - Viewed (0)
  10. internal/config/crypto.go

    		KMSKey:    key.Ciphertext,
    		Algorithm: algorithm,
    		Nonce:     nonce,
    	})
    	if err != nil {
    		return nil, err
    	}
    	if len(metadata) > MaxMetadataSize {
    		return nil, errors.New("config: encryption metadata is too large")
    	}
    	header[0] = Version
    	binary.LittleEndian.PutUint32(header[1:], uint32(len(metadata)))
    	buffer.Write(header[:])
    	buffer.Write(metadata)
    
    	return io.MultiReader(
    		&buffer,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 4.8K bytes
    - Viewed (0)
Back to top