Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Raw (0.13 sec)

  1. internal/hash/checksum.go

    func NewChecksumFromData(t ChecksumType, data []byte) *Checksum {
    	if !t.IsSet() {
    		return nil
    	}
    	h := t.Hasher()
    	h.Write(data)
    	raw := h.Sum(nil)
    	c := Checksum{Type: t, Encoded: base64.StdEncoding.EncodeToString(raw), Raw: raw}
    	if !c.Valid() {
    		return nil
    	}
    	return &c
    }
    
    // ReadCheckSums will read checksums from b and return them.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/erasure-common.go

    	for _, i := range r.Perm(len(disks)) {
    		if disks[i] != nil && disks[i].IsLocal() {
    			newDisks = append(newDisks, disks[i])
    		}
    	}
    	return newDisks
    }
    
    // readMultipleFiles Reads raw data from all specified files from all disks.
    func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) {
    	resps := make([]chan ReadMultipleResp, len(disks))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/metrics.go

    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "capacity_raw", "total"),
    			"Total capacity online in the cluster",
    			nil, nil),
    		prometheus.GaugeValue,
    		float64(GetTotalCapacity(server.Disks)),
    	)
    
    	// Report total capacity free
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "capacity_raw_free", "total"),
    			"Total free capacity online in the cluster",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cluster-health.go

    }
    
    const (
    	healthCapacityRawTotalBytes    = "capacity_raw_total_bytes"
    	healthCapacityRawFreeBytes     = "capacity_raw_free_bytes"
    	healthCapacityUsableTotalBytes = "capacity_usable_total_bytes"
    	healthCapacityUsableFreeBytes  = "capacity_usable_free_bytes"
    )
    
    var (
    	healthCapacityRawTotalBytesMD = NewGaugeMD(healthCapacityRawTotalBytes,
    		"Total cluster raw storage capacity in bytes")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  5. internal/http/listener.go

    	for i := range listener.listeners {
    		addrs = append(addrs, listener.listeners[i].Addr())
    	}
    
    	return addrs
    }
    
    // TCPOptions specify customizable TCP optimizations on raw socket
    type TCPOptions struct {
    	UserTimeout int // this value is expected to be in milliseconds
    	// When the net.Conn is idle for more than ReadTimeout duration, we close the connection on the client proactively.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  6. internal/http/transports.go

    		TLSClientConfig:       &tlsClientConfig,
    		ForceAttemptHTTP2:     s.EnableHTTP2,
    		// Go net/http automatically unzip if content-type is
    		// gzip disable this feature, as we are always interested
    		// in raw stream.
    		DisableCompression: true,
    	}
    
    	// https://github.com/golang/go/issues/23559
    	// https://github.com/golang/go/issues/42534
    	// https://github.com/golang/go/issues/43989
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    					if _, ok := idMap[id]; ok {
    						res = append(res, disk)
    					}
    				}
    			}
    		}
    	}
    	return res
    }
    
    // GetRawData will return all files with a given raw path to the callback.
    // Errors are ignored, only errors from the callback are returned.
    // For now only direct file paths are supported.
    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)
  8. cmd/metrics-v2.go

    	s3MetricNamespace        MetricNamespace = "minio_s3"
    )
    
    const (
    	cacheSubsystem            MetricSubsystem = "cache"
    	capacityRawSubsystem      MetricSubsystem = "capacity_raw"
    	capacityUsableSubsystem   MetricSubsystem = "capacity_usable"
    	driveSubsystem            MetricSubsystem = "drive"
    	interfaceSubsystem        MetricSubsystem = "if"
    	memSubsystem              MetricSubsystem = "mem"
    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)
  9. cmd/metacache-server-pool.go

    					rpc.UpdateMetacacheListing(ctx, *c)
    				}
    			}
    		}()
    		o.ID = ""
    	}
    
    	// Do listing in-place.
    	// Create output for our results.
    	// Create filter for results.
    	o.debugln("Raw List", o)
    	filterCh := make(chan metaCacheEntry, o.Limit)
    	listCtx, cancelList := context.WithCancel(ctx)
    	filteredResults := o.gatherResults(listCtx, filterCh)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	var listErr error
    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)
  10. cmd/storage-datatypes.go

    				return i
    			}
    		}
    		return -1
    	}
    
    	for i, ver := range f.Versions {
    		if ver.VersionID == v {
    			return i
    		}
    	}
    	return -1
    }
    
    // RawFileInfo - represents raw file stat information as byte array.
    // The above means that any added/deleted fields are incompatible.
    // Make sure to bump the internode version at storage-rest-common.go
    type RawFileInfo struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
Back to top