- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for Write (0.19 sec)
-
cmd/storage-datatypes_gen.go
func (z *CheckPartsHandlerParams) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 4 // write "id" err = en.Append(0x84, 0xa2, 0x69, 0x64) if err != nil { return } err = en.WriteString(z.DiskID) if err != nil { err = msgp.WrapError(err, "DiskID") return } // write "v" err = en.Append(0xa1, 0x76) if err != nil { return } err = en.WriteString(z.Volume)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K bytes - Viewed (0) -
cmd/data-usage-cache_gen.go
err = msgp.WrapError(err, "Tiers") return } // map header, size 3 // write "ts" err = en.Append(0x83, 0xa2, 0x74, 0x73) if err != nil { return } err = en.WriteUint64(za0002.TotalSize) if err != nil { err = msgp.WrapError(err, "Tiers", za0001, "TotalSize") return } // write "nv" err = en.Append(0xa2, 0x6e, 0x76) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 100.8K bytes - Viewed (0) -
cmd/metrics-v2.go
Value: float64(st.Total), }) metrics = append(metrics, MetricV2{ Description: MetricDescription{ Namespace: minioNamespace, Subsystem: "locks", Name: "write_total", Help: "Number of current WRITE locks on this peer", Type: gaugeMetric, }, Value: float64(st.Writes), }) metrics = append(metrics, MetricV2{ Description: MetricDescription{
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/bucket-replication.go
}, }) return err } // filterReplicationStatusMetadata filters replication status metadata for COPY func filterReplicationStatusMetadata(metadata map[string]string) map[string]string { // Copy on write dst := metadata var copied bool delKey := func(key string) { if _, ok := metadata[key]; !ok { return } if !copied { dst = make(map[string]string, len(metadata))
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) -
cmd/object-handlers.go
if rs != nil || opts.PartNumber > 0 { statusCodeWritten = true w.WriteHeader(http.StatusPartialContent) } // Write object content to response body if _, err = xioutil.Copy(httpWriter, gr); err != nil { if !httpWriter.HasWritten() && !statusCodeWritten { // write error response only if no data or headers has been written to client yet writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
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) -
cmd/site-replication.go
var rules []lifecycle.Rule for _, rule := range rMap { rules = append(rules, rule) } // no rules, return if len(rules) == 0 { return []byte{}, nil } // get final list for write finalLcCfg := lifecycle.Lifecycle{ XMLName: xmlName, Rules: rules, ExpiryUpdatedAt: &updatedAt, } if err := finalLcCfg.Validate(); err != nil { return []byte{}, err }
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) -
cmd/admin-handlers.go
bugLogIf(ctx, err) writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // Write a version for making *incompatible* changes. // The AdminClient will reject any version it does not know. if publicKey == nil { w.Write([]byte{1}) w.Write(key[:]) } stream, err := sio.AES_256_GCM.Stream(key[:]) if err != nil { bugLogIf(ctx, err) return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
cmd/server_test.go
// data to be written into buffer. data := "1234567890" // seed the random number generator once. rand.Seed(3) // generate a random number between 13 and 200. randInt := getRandomRange(13, 200, -1) // write into buffer till length of the buffer is greater than the generated random number. for i := 0; i <= randInt; i += 10 { buffer.WriteString(data) } // String content which is used for put object range test.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/object-handlers_test.go
for k, value := range customHeaders { req.Header.Set(k, value) } } checksumData := func(b []byte, h hash.Hash) string { h.Reset() _, err := h.Write(b) if err != nil { t.Fatal(err) } return base64.StdEncoding.EncodeToString(h.Sum(nil)) } // test cases with inputs and expected result for GetObject. testCases := []struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0)