Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 184 for Read (0.16 sec)

  1. internal/ioutil/read_file.go

    )
    
    // ReadFileWithFileInfo reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) {
    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, nil, err
    	}
    	defer f.Close()
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-process.go

    	processIORCharBytesMD             = NewCounterMD(processIORCharBytes, "Total bytes read by the process from the underlying storage system including cache, /proc/[pid]/io rchar")
    	processIOReadBytesMD              = NewCounterMD(processIOReadBytes, "Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 16:07:23 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  3. internal/etag/reader.go

    		}
    	}
    	return &Reader{
    		src:      r,
    		md5:      md5.New(),
    		checksum: etag,
    	}
    }
    
    // Read reads up to len(p) bytes from the underlying
    // io.Reader as specified by the io.Reader interface.
    func (r *Reader) Read(p []byte) (int, error) {
    	n, err := r.src.Read(p)
    	r.readN += int64(n)
    	r.md5.Write(p[:n])
    
    	if err == io.EOF && len(r.checksum) != 0 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  4. cmd/perf-tests.go

    }
    
    type firstByteRecorder struct {
    	t *time.Time
    	r io.Reader
    }
    
    func (f *firstByteRecorder) Read(p []byte) (n int, err error) {
    	if f.t != nil || len(p) == 0 {
    		return f.r.Read(p)
    	}
    	// Read a single byte.
    	n, err = f.r.Read(p[:1])
    	if n > 0 {
    		t := time.Now()
    		f.t = &t
    	}
    	return n, err
    }
    
    // Runs the speedtest on local MinIO process.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 28 18:04:17 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  5. docs/metrics/README.md

    - Liveness probe available at `/minio/health/live`
    - Cluster probe available at `/minio/health/cluster`
    
    Read more on how to use these endpoints in [MinIO healthcheck guide](https://github.com/minio/minio/blob/master/docs/metrics/healthcheck/README.md).
    
    ## Prometheus Probe
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 29 18:35:20 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex.go

    	isReadLock := false
    	return dm.lockBlocking(ctx, cancel, id, source, isReadLock, opts)
    }
    
    // RLock holds a read lock on dm.
    //
    // If one or more read locks are already in use, it will grant another lock.
    // Otherwise the calling go routine blocks until the mutex is available.
    func (dm *DRWMutex) RLock(id, source string) {
    	isReadLock := true
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  7. docs/sts/ldap.md

    MINIO_IDENTITY_LDAP_LOOKUP_BIND_DN*          (string)    DN for LDAP read-only service account used to perform DN and group lookups
    MINIO_IDENTITY_LDAP_LOOKUP_BIND_PASSWORD     (string)    Password for LDAP read-only service account used to perform DN and group lookups
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.4K bytes
    - Viewed (1)
  8. cmd/admin-handlers_test.go

    	}
    
    	// Add a few concurrent read locks to the mix
    	for i := 0; i < 50; i++ {
    		resource := fmt.Sprintf("bucket/get-object-%d", i)
    		lri := lockRequesterInfo{
    			Name:   resource,
    			UID:    mustGetUUID(),
    			Owner:  owners[i%len(owners)],
    			Quorum: 2,
    		}
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    		// concurrent read lock, same resource different uid
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  9. cmd/metrics-v3-system-drive.go

    		"Reads per second on a drive",
    		allDriveLabels...)
    	driveReadsKBPerSecMD = NewGaugeMD(driveReadsKBPerSec,
    		"Kilobytes read per second on a drive",
    		allDriveLabels...)
    	driveReadsAwaitMD = NewGaugeMD(driveReadsAwait,
    		"Average time for read requests served on a drive",
    		allDriveLabels...)
    	driveWritesPerSecMD = NewGaugeMD(driveWritesPerSec,
    		"Writes per second on a drive",
    		allDriveLabels...)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  10. cmd/object-api-interface.go

    	MTime                time.Time // Is only set in POST/PUT operations
    	Expires              time.Time // Is only used in POST/PUT operations
    
    	DeleteMarker            bool // Is only set in DELETE operations for delete marker replication
    	CheckDMReplicationReady bool // Is delete marker ready to be replicated - set only during HEAD
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
Back to top