Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 127 for Writer (0.17 sec)

  1. docs/config/README.md

    delete_cleanup_interval         (duration)  set to change intervals when deleted objects are permanently deleted from ".trash" folder (default: '5m')
    odirect                         (boolean)   set to enable or disable O_DIRECT for read and writes under special conditions. NOTE: do not disable O_DIRECT without prior testing (default: 'on')
    root_access                     (boolean)   turn 'off' root credential access for all API calls including s3, admin operations (default: 'on')
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    			})
    
    			healthy := erasureSetUpCount[poolIdx][setIdx].online >= poolWriteQuorums[poolIdx]
    			if !healthy {
    				storageLogIf(logger.SetReqInfo(ctx, reqInfo),
    					fmt.Errorf("Write quorum may be lost on pool: %d, set: %d, expected write quorum: %d",
    						poolIdx, setIdx, poolWriteQuorums[poolIdx]), logger.FatalKind)
    			}
    			result.Healthy = result.Healthy && healthy
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  3. docs/docker/README.md

    The command creates a new local directory `~/minio/data` in your user home directory. It then starts the MinIO container with the `-v` argument to map the local path (`~/minio/data`) to the specified virtual container directory (`/data`). When MinIO writes data to `/data`, that data is actually written to the local path `~/minio/data` where it can persist between container restarts.
    
    ### Windows
    
    ```sh
    docker run \
      -p 9000:9000 \
      -p 9001:9001 \
      --name minio1 \
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 8.2K bytes
    - Viewed (0)
  4. internal/ioutil/ioutil.go

    // executes at least one write operation if it is closed.
    //
    // This can be useful within the context of HTTP. At least
    // one write operation must happen to send the HTTP headers
    // to the peer.
    type WriteOnCloser struct {
    	io.Writer
    	hasWritten bool
    }
    
    func (w *WriteOnCloser) Write(p []byte) (int, error) {
    	w.hasWritten = true
    	return w.Writer.Write(p)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    		metrics = append(metrics, MetricV2{
    			Description: MetricDescription{
    				Namespace: minioNamespace,
    				Subsystem: "locks",
    				Name:      "write_total",
    				Help:      "Number of current WRITE locks on this peer",
    				Type:      gaugeMetric,
    			},
    			Value: float64(st.Writes),
    		})
    		metrics = append(metrics, MetricV2{
    			Description: MetricDescription{
    				Namespace: minioNamespace,
    				Subsystem: "locks",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  6. cmd/erasure-encode.go

    import (
    	"context"
    	"fmt"
    	"io"
    	"sync"
    )
    
    // Writes in parallel to writers
    type parallelWriter struct {
    	writers     []io.Writer
    	writeQuorum int
    	errs        []error
    }
    
    // Write writes data to writers in parallel.
    func (p *parallelWriter) Write(ctx context.Context, blocks [][]byte) error {
    	var wg sync.WaitGroup
    
    	for i := range p.writers {
    		if p.writers[i] == nil {
    			p.errs[i] = errDiskNotFound
    			continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 3K bytes
    - Viewed (0)
  7. cmd/admin-bucket-handlers.go

    			size:    int64(sz),
    			mode:    0o600,
    			modTime: time.Now(),
    			isDir:   false,
    			sys:     nil,
    		})
    		if zerr == nil {
    			header.Method = zip.Deflate
    			zwriter, zerr := zipWriter.CreateHeader(header)
    			if zerr == nil {
    				io.Copy(zwriter, r)
    			}
    		}
    	}
    
    	cfgFiles := []string{
    		bucketPolicyConfig,
    		bucketNotificationConfig,
    		bucketLifecycleConfig,
    		bucketSSEConfig,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    		}
    		mid.respMu.Lock()
    		resp(mid.closed)
    		mid.respMu.Unlock()
    	}
    }
    
    // wsWriter writes websocket messages.
    type wsWriter struct {
    	tmp [ws.MaxHeaderSize]byte
    }
    
    // writeMessage writes a message to w without allocations.
    func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error {
    	const fin = true
    	var frame ws.Frame
    	if s.ClientSide() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  9. cmd/background-newdisks-heal-ops_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *healingTracker) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 25
    	// write "ID"
    	err = en.Append(0xde, 0x0, 0x19, 0xa2, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.ID)
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "PoolIndex"
    	err = en.Append(0xa9, 0x50, 0x6f, 0x6f, 0x6c, 0x49, 0x6e, 0x64, 0x65, 0x78)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 17:05:40 GMT 2024
    - 21.5K bytes
    - Viewed (0)
  10. internal/ioutil/ioutil_test.go

    	}
    }
    
    func TestCloseOnWriter(t *testing.T) {
    	writer := WriteOnClose(io.Discard)
    	if writer.HasWritten() {
    		t.Error("WriteOnCloser must not be marked as HasWritten")
    	}
    	writer.Write(nil)
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    	}
    
    	writer = WriteOnClose(io.Discard)
    	writer.Close()
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 11:02:31 GMT 2024
    - 5.1K bytes
    - Viewed (0)
Back to top