- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 121 for arkite (0.14 sec)
-
cmd/background-newdisks-heal-ops_gen.go
func (z *healingTracker) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 25 // write "ID" err = en.Append(0xde, 0x0, 0x19, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.ID) if err != nil { err = msgp.WrapError(err, "ID") return } // write "PoolIndex" err = en.Append(0xa9, 0x50, 0x6f, 0x6f, 0x6c, 0x49, 0x6e, 0x64, 0x65, 0x78) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 21.5K bytes - Viewed (0) -
cmd/metacache_gen.go
} // write "id" err = en.Append(0xa2, 0x69, 0x64) if err != nil { return } err = en.WriteString(z.id) if err != nil { err = msgp.WrapError(err, "id") return } // write "err" err = en.Append(0xa3, 0x65, 0x72, 0x72) if err != nil { return } err = en.WriteString(z.error) if err != nil { err = msgp.WrapError(err, "error") return } // write "root"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 08 18:26:08 GMT 2021 - 10K bytes - Viewed (0) -
cmd/local-locker_gen.go
func (z *lockRequesterInfo) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 9 // write "Name" err = en.Append(0x89, 0xa4, 0x4e, 0x61, 0x6d, 0x65) if err != nil { return } err = en.WriteString(z.Name) if err != nil { err = msgp.WrapError(err, "Name") return } // write "Writer" err = en.Append(0xa6, 0x57, 0x72, 0x69, 0x74, 0x65, 0x72) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 13.8K bytes - Viewed (0) -
src/bytes/example_test.go
buf := bytes.Buffer{} buf.Write([]byte{'h', 'e', 'l', 'l', 'o', ' ', 'w', 'o', 'r', 'l', 'd'}) os.Stdout.Write(buf.Bytes()) // Output: hello world } func ExampleBuffer_AvailableBuffer() { var buf bytes.Buffer for i := 0; i < 4; i++ { b := buf.AvailableBuffer() b = strconv.AppendInt(b, int64(i), 10) b = append(b, ' ') buf.Write(b) } os.Stdout.Write(buf.Bytes()) // Output: 0 1 2 3 }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:40 GMT 2024 - 15K bytes - Viewed (1) -
internal/grid/connection.go
return } c.handleMsg(ctx, m, subID) } } }() // Write function. defer func() { if rec := recover(); rec != nil { gridLogIf(ctx, fmt.Errorf("handleMessages: panic recovered: %v", rec)) debug.PrintStack() } if debugPrint { fmt.Println("handleMessages: write goroutine exited") } cancel(ErrDisconnected) c.connChange.L.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/hash/reader.go
} return nil } func (r *Reader) Read(p []byte) (int, error) { n, err := r.src.Read(p) r.bytesRead += int64(n) if r.sha256 != nil { r.sha256.Write(p[:n]) } if r.contentHasher != nil { r.contentHasher.Write(p[:n]) } if err == io.EOF { // Verify content SHA256, if set. if r.expectedMin > 0 { if r.bytesRead < r.expectedMin {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
cmd/format-erasure_test.go
for i, format := range formats { if format == nil { continue } h := sha256.New() for _, set := range format.Erasure.Sets { for _, diskID := range set { h.Write([]byte(diskID)) } } formatHashes[i] = hex.EncodeToString(h.Sum(nil)) } formatCountMap := make(map[string]int) for _, hash := range formatHashes { if hash == "" { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/metrics-resource.go
writesKBPerSec: "Kilobytes written per second on a drive", readsAwait: "Average time for read requests to be served on a drive", writesAwait: "Average time for write requests to be served on a drive", percUtil: "Percentage of time the disk was busy", usedBytes: "Used bytes on a drive", totalBytes: "Total bytes on a drive",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
{ key := eventData.S3.Bucket.Name + "/" + objectName if target.client.isAtleastV7() { hh, _ := highwayhash.New(magicHighwayHash256Key) // New will never return error since key is 256 bit hh.Write([]byte(key)) hashBytes := hh.Sum(nil) keyHash = base64.URLEncoding.EncodeToString(hashBytes) } else { keyHash = key } } if eventData.EventName == event.ObjectRemovedDelete {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/erasure-metadata.go
} } return } // Returns per object readQuorum and writeQuorum // readQuorum is the min required disks to read data. // writeQuorum is the min required disks to write data. func objectQuorumFromMeta(ctx context.Context, partsMetaData []FileInfo, errs []error, defaultParityCount int) (objectReadQuorum, objectWriteQuorum int, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1)