- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 131 for Writer (0.2 sec)
-
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 41.3K 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
internal/s3select/sql/record.go
type Record interface { Get(name string) (*Value, error) // Set a value. // Can return a different record type. Set(name string, value *Value) (Record, error) WriteCSV(writer io.Writer, opts WriteCSVOpts) error WriteJSON(writer io.Writer) error // Clone the record and if possible use the destination provided. Clone(dst Record) Record Reset() // Returns underlying representation
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.4K bytes - Viewed (0) -
cmd/xl-storage-format-v1_gen.go
func (z *ChecksumInfo) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "PartNumber" err = en.Append(0x83, 0xaa, 0x50, 0x61, 0x72, 0x74, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72) if err != nil { return } err = en.WriteInt(z.PartNumber) if err != nil { err = msgp.WrapError(err, "PartNumber") return } // write "Algorithm"
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 40.2K 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 42.4K bytes - Viewed (0) -
cmd/post-policy_test.go
if !corruptedMultipart { var writer io.Writer var err error if noFilename { writer, err = w.CreateFormField("file") } else { writer, err = w.CreateFormFile("file", "upload.txt") } if err != nil { // return nil, err return nil, err } writer.Write(objData) // Close before creating the new request. w.Close() }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/object-handlers_test.go
}, } // Iterating over the cases, fetching the object validating the response. for i, testCase := range testCases { // 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.MethodHead, getHeadObjectURL("", testCase.bucketName, testCase.objectName),
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 160K bytes - Viewed (0) -
cmd/metacache-stream_test.go
"src/compress/lzw/reader.go", "src/compress/lzw/reader_test.go", "src/compress/lzw/writer.go", "src/compress/lzw/writer_test.go", "src/compress/testdata/", "src/compress/testdata/e.txt", "src/compress/testdata/gettysburg.txt", "src/compress/testdata/pi.txt", "src/compress/zlib/", "src/compress/zlib/example_test.go", "src/compress/zlib/reader.go", "src/compress/zlib/reader_test.go", "src/compress/zlib/writer.go", "src/compress/zlib/writer_test.go"} func loadMetacacheSample(t testing.TB) *metacacheReader...
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 15K bytes - Viewed (0) -
internal/crypto/sse.go
partKey := key.DerivePartKey(uint32(partID)) return EncryptSinglePart(r, ObjectKey(partKey)) } // DecryptSinglePart decrypts an io.Writer which must an object // uploaded with the single-part PUT API. The offset and length // specify the requested range. func DecryptSinglePart(w io.Writer, offset, length int64, key ObjectKey) io.WriteCloser { const PayloadSize = 1 << 16 // DARE 2.0 w = ioutil.LimitedWriter(w, offset%PayloadSize, length)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/s3select/message.go
} result := writer.write(newRecordsMessage(writer.payloadBuffer[0:writer.payloadBufferIndex])) if result { atomic.AddInt64(&writer.bytesReturned, int64(writer.payloadBufferIndex)) writer.payloadBufferIndex = 0 } return result } // Finish is the last call to the message writer - it sends any // remaining record payload, then sends statistics and finally the end // message.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0)