Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for WriteCloser (0.11 sec)

  1. internal/ioutil/ioutil.go

    type DeadlineWriter struct {
    	io.WriteCloser
    	timeout time.Duration
    	err     error
    }
    
    // NewDeadlineWriter wraps a writer to make it respect given deadline
    // value per Write(). If there is a blocking write, the returned Writer
    // will return whenever the timer hits (the return values are n=0
    // and err=context.DeadlineExceeded.)
    func NewDeadlineWriter(w io.WriteCloser, timeout time.Duration) io.WriteCloser {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. cmd/object-api-datatypes.go

    	UserTags string
    
    	// List of individual parts, maximum size of upto 10,000
    	Parts []ObjectPartInfo `json:"-"`
    
    	// Implements writer and reader used by CopyObject API
    	Writer       io.WriteCloser `json:"-" msg:"-"`
    	Reader       *hash.Reader   `json:"-" msg:"-"`
    	PutObjReader *PutObjReader  `json:"-" msg:"-"`
    
    	metadataOnly bool
    	versionOnly  bool // adds a new version, only used by CopyObject
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. 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
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  5. src/archive/zip/writer.go

    	if len(b) == 0 {
    		return 0, nil
    	}
    	return 0, errors.New("zip: write to directory")
    }
    
    type fileWriter struct {
    	*header
    	zipw      io.Writer
    	rawCount  *countWriter
    	comp      io.WriteCloser
    	compCount *countWriter
    	crc32     hash.Hash32
    	closed    bool
    }
    
    func (w *fileWriter) Write(p []byte) (int, error) {
    	if w.closed {
    		return 0, errors.New("zip: write to closed file")
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top