- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 57 for Writer (0.15 sec)
-
cmd/batch-rotate_gen.go
// EncodeMsg implements msgp.Encodable func (z BatchJobKeyRotateEncryption) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "Type" err = en.Append(0x83, 0xa4, 0x54, 0x79, 0x70, 0x65) if err != nil { return } err = en.WriteString(string(z.Type)) if err != nil { err = msgp.WrapError(err, "Type") return } // write "Key" err = en.Append(0xa3, 0x4b, 0x65, 0x79) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 27.1K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
} // EncodeMsg implements msgp.Encodable func (z *BatchJobRequest) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 6 // write "ID" err = en.Append(0x86, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.ID) if err != nil { err = msgp.WrapError(err, "ID") return } // write "User" err = en.Append(0xa4, 0x55, 0x73, 0x65, 0x72) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 18:58:22 GMT 2024 - 18.1K bytes - Viewed (0) -
internal/logger/logger.go
InfoKind = madmin.LogKindInfo ) var ( // DisableErrorLog avoids printing error/event/info kind of logs DisableErrorLog = false // Output allows configuring custom writer, defaults to os.Stderr Output io.Writer = os.Stderr ) var trimStrings []string // TimeFormat - logging time format. const TimeFormat string = "15:04:05 MST 01/02/2006" var matchingFuncNames = [...]string{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_gen.go
// EncodeMsg implements msgp.Encodable func (z *PoolDecommissionInfo) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 16 // write "st" err = en.Append(0xde, 0x0, 0x10, 0xa2, 0x73, 0x74) if err != nil { return } err = en.WriteTime(z.StartTime) if err != nil { err = msgp.WrapError(err, "StartTime") return } // write "ss" err = en.Append(0xa2, 0x73, 0x73) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 04 21:02:54 GMT 2022 - 26.7K bytes - Viewed (0) -
cmd/data-usage-cache.go
dataUsageCacheVerV2 = 2 dataUsageCacheVerV1 = 1 ) // serialize the contents of the cache. func (d *dataUsageCache) serializeTo(dst io.Writer) error { // Add version and compress. _, err := dst.Write([]byte{dataUsageCacheVerCurrent}) if err != nil { return err } enc, err := zstd.NewWriter(dst, zstd.WithEncoderLevel(zstd.SpeedFastest), zstd.WithWindowSize(1<<20),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
internal/config/cache/remote_gen.go
func (z *CondCheck) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 7 // write "ObjectInfo" err = en.Append(0x87, 0xaa, 0x4f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x6e, 0x66, 0x6f) if err != nil { return } err = z.ObjectInfo.EncodeMsg(en) if err != nil { err = msgp.WrapError(err, "ObjectInfo") return } // write "IfMatch"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 18.9K bytes - Viewed (0) -
cmd/erasure-multipart.go
} if len(buffer) > int(fi.Erasure.BlockSize) { buffer = buffer[:fi.Erasure.BlockSize] } writers := make([]io.Writer, len(onlineDisks)) for i, disk := range onlineDisks { if disk == nil { continue } writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, tmpPartPath, erasure.ShardFileSize(data.Size()), DefaultBitrotAlgorithm, erasure.ShardSize()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/bucket-metadata_gen.go
// EncodeMsg implements msgp.Encodable func (z *BucketMetadata) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 22 // write "Name" err = en.Append(0xde, 0x0, 0x16, 0xa4, 0x4e, 0x61, 0x6d, 0x65) if err != nil { return } err = en.WriteString(z.Name) if err != nil { err = msgp.WrapError(err, "Name") return } // write "Created" err = en.Append(0xa7, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x64)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 25 05:52:39 GMT 2023 - 22.1K bytes - Viewed (0) -
cmd/erasure-healing.go
defer grid.PutByteBuffer(buf) writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize()) } else { writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, partPath, tillOffset, DefaultBitrotAlgorithm, erasure.ShardSize()) } } // Heal each part. erasure.Heal() will write the healed
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/object-api-utils_test.go
t.Fatalf("Initializing config.json failed") } objectName := `\../.minio.sys/config/hello.txt` // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request for Get Object end point. req, err := newTestSignedRequestV4(http.MethodPut, getPutObjectURL("", bucketName, objectName),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 23.4K bytes - Viewed (0)