Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 51 for Breiding (0.16 sec)

  1. docs/metrics/README.md

    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)
  2. docs/debugging/inspect/decrypt-v2.go

    		}
    		if stream.Name == "inspect.zip" {
    			if extracted {
    				return keepFileErr{errors.New("multiple inspect.zip streams found")}
    			}
    			_, err := io.Copy(w, stream)
    			if err != nil {
    				return fmt.Errorf("reading inspect stream: %w", err)
    			}
    			fmt.Println(okMsg)
    			extracted = true
    			continue
    		}
    		if err := stream.Skip(); err != nil {
    			return fmt.Errorf("stream skip: %w", err)
    		}
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 21:22:47 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  3. internal/etag/reader.go

    			return n, VerifyError{
    				Expected: r.checksum,
    				Computed: etag,
    			}
    		}
    	}
    	return n, err
    }
    
    // ETag returns the ETag of all the content read
    // so far. Reading more content changes the MD5
    // checksum. Therefore, calling ETag multiple
    // times may return different results.
    func (r *Reader) ETag() ETag {
    	sum := r.md5.Sum(nil)
    	return ETag(sum)
    }
    
    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/object-api-interface.go

    	// Object operations.
    
    	// GetObjectNInfo returns a GetObjectReader that satisfies the
    	// ReadCloser interface. The Close method runs any cleanup
    	// functions, so it must always be called after reading till EOF
    	//
    	// IMPORTANTLY, when implementations return err != nil, this
    	// function MUST NOT return a non-nil ReadCloser.
    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)
  5. cmd/s3-zip-handlers.go

    		ContentType: mime.TypeByExtension(filepath.Ext(object)),
    	}
    
    	var rc io.ReadCloser
    
    	if file.UncompressedSize64 > 0 {
    		// There may be number of header bytes before the content.
    		// Reading 64K extra. This should more than cover name and any "extra" details.
    		end := file.Offset + int64(file.CompressedSize64) + 64<<10
    		if end > zipObjInfo.Size {
    			end = zipObjInfo.Size
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    func (er erasureObjects) newMultipartUpload(ctx context.Context, bucket string, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) {
    	if opts.CheckPrecondFn != nil {
    		// Lock the object before reading.
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		rctx := lkctx.Context()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    			case ObjectNotFound, InsufficientReadQuorum:
    				retryWait()
    				continue
    			}
    			// Allow one fast retry for other errors.
    			if retries > 0 {
    				return entries, fmt.Errorf("reading first part metadata: %v", err)
    			}
    			retryWait()
    			continue
    		}
    
    		partN, err := o.findFirstPart(fi)
    		switch {
    		case err == nil:
    		case errors.Is(err, io.ErrUnexpectedEOF):
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  8. internal/logger/reqinfo.go

    	Val interface{}
    }
    
    // ObjectVersion object version key/versionId
    type ObjectVersion struct {
    	ObjectName string
    	VersionID  string `json:"VersionId,omitempty"`
    }
    
    // ReqInfo stores the request info.
    // Reading/writing directly to struct requires appropriate R/W lock.
    type ReqInfo struct {
    	RemoteHost   string           // Client Host/IP
    	Host         string           // Node Host/IP
    	UserAgent    string           // User Agent
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  9. internal/s3select/csv/reader.go

    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    	dst = dst[:skip]
    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    		if err != nil && err != io.ErrUnexpectedEOF {
    			// If an EOF happens after reading some but not all the bytes,
    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    	// Read until next line.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  10. cmd/object-api-utils.go

    }
    
    // Returns true if input bucket is a reserved minio bucket 'minio'.
    func isMinioReservedBucket(bucketName string) bool {
    	return bucketName == minioReservedBucket
    }
    
    // returns a slice of hosts by reading a slice of DNS records
    func getHostsSlice(records []dns.SrvRecord) []string {
    	hosts := make([]string, len(records))
    	for i, r := range records {
    		hosts[i] = net.JoinHostPort(r.Host, string(r.Port))
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
Back to top