- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 111 for Kata (0.43 sec)
-
cmd/data-usage_test.go
Harshavardhana <******@****.***> 1711552240 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
Hidden: true, }, cli.BoolFlag{ Usage: "display inline data keys and sizes", Name: "data", }, cli.BoolFlag{ Usage: "export inline data", Name: "export", }, cli.BoolFlag{ Usage: "combine inline data", Name: "combine", }, } app.Action = func(c *cli.Context) error { ndjson := c.Bool("ndjson") if c.Bool("data") && c.Bool("combine") {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/erasure-object_test.go
t.Fatalf("Expected GetObject reading data to succeed, but failed with %v", err) } gr.Close() const expectedHash = "fffb6377948ebea75ad2b8058e849ef5" foundHash := fmt.Sprintf("%x", h.Sum(nil)) if foundHash != expectedHash { t.Fatalf("Expected data to have md5sum = `%s`, found `%s`", expectedHash, foundHash) } } // Test reading an object with some outdated data in some disks
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
data, _, err := readConfigWithMetadata(ctx, store, rebalMetaName, opts) if err != nil { return err } if len(data) == 0 { return nil } if len(data) <= 4 { return fmt.Errorf("rebalanceMeta: no data") } // Read header switch binary.LittleEndian.Uint16(data[0:2]) { case rebalMetaFmt: default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
internal/event/name.go
} *name = eventName return nil } // MarshalJSON - encodes to JSON data. func (name Name) MarshalJSON() ([]byte, error) { return json.Marshal(name.String()) } // UnmarshalJSON - decodes JSON data. func (name *Name) UnmarshalJSON(data []byte) error { var s string if err := json.Unmarshal(data, &s); err != nil { return err } eventName, err := ParseName(s) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/object_api_suite_test.go
func newTestReaderEOF(data []byte) io.Reader { return &testOneByteReadEOF{false, data} } // OneByteReadEOF - implements io.Reader which returns 1 byte along with io.EOF error. type testOneByteReadEOF struct { eof bool data []byte } func (r *testOneByteReadEOF) Read(p []byte) (n int, err error) { if r.eof { return 0, io.EOF } n = copy(p, r.data) r.eof = true return n, io.EOF }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} done(&err) }() // Copy inline data to a new buffer to function with deadlines. if len(fi.Data) > 0 { fi.Data = append(grid.GetByteBufferCap(len(fi.Data))[:0], fi.Data...) } return xioutil.WithDeadline[RenameDataResp](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (res RenameDataResp, err error) { if len(fi.Data) > 0 { defer grid.PutByteBuffer(fi.Data) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/update.go
func parseReleaseData(data string) (sha256Sum []byte, releaseTime time.Time, releaseInfo string, err error) { defer func() { if err != nil { err = AdminError{ Code: AdminUpdateUnexpectedFailure, Message: err.Error(), StatusCode: http.StatusInternalServerError, } } }() fields := strings.Fields(data) if len(fields) != 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
internal/event/target/nats.go
data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}}) if err != nil { return err } if target.stanConn != nil { if target.args.Streaming.Async { _, err = target.stanConn.PublishAsync(target.args.Subject, data, nil) } else { err = target.stanConn.Publish(target.args.Subject, data) } } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/s3select/message.go
payloadCh chan *bytes.Buffer finBytesScanned, finBytesProcessed int64 errCh chan []byte doneCh chan struct{} } func (writer *messageWriter) write(data []byte) bool { if _, err := writer.writer.Write(data); err != nil { return false } writer.writer.(http.Flusher).Flush() return true } func (writer *messageWriter) start() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0)