- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for Raw (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
cmd/erasure-server-pool.go
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) -
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) -
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) -
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)