- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 395 for Writer (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/bucket/replication/datatypes_gen.go
if err != nil { err = msgp.WrapError(err) return } (*z) = StatusType(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z StatusType) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteString(string(z)) if err != nil { err = msgp.WrapError(err) return } return } // MarshalMsg implements msgp.MarshalerCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.4K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Decrypt.java
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Dec 17 09:50:45 GMT 2024 - 2.1K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/builtin/BuiltinShellCommandRegistryFactory.java
result.loggerLevel = shellContext.loggerLevel; result.coloredOutput = shellContext.coloredOutput; result.terminal = shellContext.terminal; result.writer = shellContext.writer; result.installationSettingsPath = shellContext.installationSettingsPath; result.projectSettingsPath = shellContext.projectSettingsPath;Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Jun 07 06:22:47 GMT 2025 - 12.3K bytes - Click Count (0) -
cmd/bitrot.go
func closeBitrotReaders(rs []io.ReaderAt) { for _, r := range rs { if r != nil { if br, ok := r.(io.Closer); ok { br.Close() } } } } // Close all the writers. func closeBitrotWriters(ws []io.Writer) []error { errs := make([]error, len(ws)) for i, w := range ws { if w == nil { errs[i] = errDiskNotFound continue } if bw, ok := w.(io.Closer); ok {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.7K bytes - Click Count (0) -
internal/grid/msg_gen.go
} // EncodeMsg implements msgp.Encodable func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 4 // write "ID" err = en.Append(0x84, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteBytes((z.ID)[:]) if err != nil { err = msgp.WrapError(err, "ID") return } // write "Host" err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74) if err != nil { return
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 22.4K bytes - Click Count (0) -
cmd/batch-job-common-types_gen.go
return } // EncodeMsg implements msgp.Encodable func (z BatchJobKV) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "Key" err = en.Append(0x82, 0xa3, 0x4b, 0x65, 0x79) if err != nil { return } err = en.WriteString(z.Key) if err != nil { err = msgp.WrapError(err, "Key") return } // write "Value" err = en.Append(0xa5, 0x56, 0x61, 0x6c, 0x75, 0x65) if err != nil { return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 21.9K bytes - Click Count (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)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.3K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance_gen.go
func (z rebalanceInfo) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "startTs" err = en.Append(0x83, 0xa7, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x73) if err != nil { return } err = en.WriteTime(z.StartTime) if err != nil { err = msgp.WrapError(err, "StartTime") return } // write "stopTs" err = en.Append(0xa6, 0x73, 0x74, 0x6f, 0x70, 0x54, 0x73)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.8K bytes - Click Count (0) -
internal/logger/target/console/console.go
"github.com/minio/minio/internal/color" "github.com/minio/minio/internal/logger" ) // Target implements loggerTarget to send log // in plain or json format to the standard output. type Target struct { output io.Writer } // Validate - validate if the tty can be written to func (c *Target) Validate() error { return nil } // Endpoint returns the backend endpoint func (c *Target) Endpoint() string { return "" }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.9K bytes - Click Count (0) -
cmd/erasure-encode_test.go
} writers := make([]io.Writer, len(disks)) for i, disk := range disks { if disk == OfflineDisk { continue } writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(int64(len(data[test.offset:]))), test.algorithm, erasure.ShardSize()) } n, err := erasure.Encode(t.Context(), bytes.NewReader(data[test.offset:]), writers, buffer, erasure.dataBlocks+1)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.8K bytes - Click Count (0)