- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 73 for Tata (0.23 sec)
-
cmd/bucket-replication.go
case resyncMetaFormat: default: return brs, fmt.Errorf("resyncMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2])) } switch binary.LittleEndian.Uint16(data[2:4]) { case resyncMetaVersion: default: return brs, fmt.Errorf("resyncMeta: unknown version: %d", binary.LittleEndian.Uint16(data[2:4])) } // OK, parse data. if _, err = brs.UnmarshalMsg(data[4:]); err != nil {
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/storage-datatypes_gen.go
return } if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err) return } z.Data = nil } else { z.Data, err = dc.ReadBytes(z.Data) if err != nil { err = msgp.WrapError(err, "Data") return } } z.NumVersions, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "NumVersions") return }
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/test-utils_test.go
2 // CRLF } func mustGetPutObjReader(t TestErrHandler, data io.Reader, size int64, md5hex, sha256hex string) *PutObjReader { hr, err := hash.NewReader(context.Background(), data, size, md5hex, sha256hex, size) if err != nil { t.Fatal(err) } return NewPutObjReader(hr) } // calculateSignedChunkLength - calculates the length of the overall stream (data + metadata)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/site-replication.go
data, err := readConfig(GlobalContext, objAPI, getSRResyncFilePath(dID)) if err != nil { return rs, err } if len(data) == 0 { // Seems to be empty. return rs, nil } if len(data) <= 4 { return rs, fmt.Errorf("site resync: no data") } // Read resync meta header switch binary.LittleEndian.Uint16(data[0:2]) { case siteResyncMetaFormat:
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/erasure-metadata.go
} else { parities[index] = metadata.Erasure.ParityBlocks } } 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) -
migrator/migrator.go
sql, _ := fc() fmt.Println(sql + ";") l.Interface.Trace(ctx, begin, fc, err) } // GormDataTypeInterface gorm data type interface type GormDataTypeInterface interface { GormDBDataType(*gorm.DB, *schema.Field) string } // RunWithValue run migration with statement value
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 07:15:49 GMT 2024 - 29K bytes - Viewed (0) -
internal/grid/handlers.go
// WithSharedResponse indicates it is unsafe to reuse the response // when it has been returned on a handler. // This will disable automatic response recycling/pooling. // Typically this is used when the response sharing part of its data structure. func (h *SingleHandler[Req, Resp]) WithSharedResponse() *SingleHandler[Req, Resp] { h.sharedResp = true return h } // NewResponse creates a new response.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/metrics-resource.go
type PeerResourceMetrics struct { Metrics map[MetricSubsystem]ResourceMetrics Errors []string } // ResourceMetrics is a map of unique key identifying // a resource metric (e.g. reads_per_sec_{node}_{drive}) // to its data type ResourceMetrics map[string]ResourceMetric // ResourceMetric represents a single resource metric // The metrics are collected from all servers periodically // and stored in the resource metrics map.
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/name_test.go
} for i, testCase := range testCases { data, err := xml.Marshal(testCase.name) expectErr := (err != nil) if expectErr != testCase.expectErr { t.Fatalf("test %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr) } if !testCase.expectErr { if !reflect.DeepEqual(data, testCase.expectedData) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/storage-datatypes.go
func (r *RenameDataInlineHandlerParams) Recycle() { if r == nil { return } if cap(r.FI.Data) >= xioutil.SmallBlock { grid.PutByteBuffer(r.FI.Data) r.FI.Data = nil } } // RenameFileHandlerParams are parameters for RenameFileHandler. type RenameFileHandlerParams struct { DiskID string `msg:"id"` SrcVolume string `msg:"sv"` SrcFilePath string `msg:"sp"` DstVolume string `msg:"dv"`
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)