Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for WriteCloser (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
Back to Top