- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for WriteCloser (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/ringbuffer/ring_buffer.go
r.isFull = false } // WriteCloser returns a WriteCloser that writes to the ring buffer. // When the returned WriteCloser is closed, it will wait for all data to be read before returning. func (r *RingBuffer) WriteCloser() io.WriteCloser { return &writeCloser{RingBuffer: r} } type writeCloser struct { *RingBuffer } // Close provides a close method for the WriteCloser. func (wc *writeCloser) Close() error {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
internal/crypto/sse.go
// 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) decWriter, err := sio.DecryptWriter(w, sio.Config{Key: key[:]}) if err != nil {
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/server-main.go
addrs.Add(globalMinioAddr) } } else { addrs.Add(globalMinioAddr) } return addrs.ToSlice() } var globalLoggerOutput io.WriteCloser func initializeLogRotate(ctx *cli.Context) (io.WriteCloser, error) { lgDir := ctx.String("log-dir") if lgDir == "" { return os.Stderr, nil } lgDirAbs, err := filepath.Abs(lgDir) if err != nil { return nil, err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:18:36 GMT 2025 - 35.9K bytes - Click Count (4)