Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 582 for nBytes (0.06 seconds)

  1. docs/metrics/healthcheck/README.md

    ### Cluster-writeable probe
    
    The reply is '200 OK' if cluster has write quorum if not it returns '503 Service Unavailable'.
    
    ```
    curl http://minio1:9001/minio/health/cluster
    HTTP/1.1 503 Service Unavailable
    Accept-Ranges: bytes
    Content-Length: 0
    Server: MinIO
    Vary: Origin
    X-Amz-Bucket-Region: us-east-1
    X-Minio-Write-Quorum: 3
    X-Amz-Request-Id: 16239D6AB80EBECF
    X-Xss-Protection: 1; mode=block
    Date: Tue, 21 Jul 2020 00:36:14 GMT
    ```
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Jul 06 16:18:38 GMT 2023
    - 2.5K bytes
    - Click Count (0)
  2. cmd/utils.go

    			runtime.GC()
    			var buf bytes.Buffer
    			err := pprof.Lookup("heap").WriteTo(&buf, 0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerBlock:
    		runtime.SetBlockProfileRate(100)
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("block").WriteTo(&buf, 0)
    			runtime.SetBlockProfileRate(0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerMutex:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  3. internal/s3select/csv/recordtransform.go

    	// Change record delimiters to newline.
    	if len(rr.recordDelimiter) == 1 {
    		for idx := 0; idx < len(p); {
    			i := bytes.Index(p[idx:], rr.recordDelimiter)
    			if i < 0 {
    				break
    			}
    			idx += i
    			p[idx] = '\n'
    		}
    		return n, nil
    	}
    
    	// 2 characters...
    	for idx := 0; idx < len(p); {
    		i := bytes.Index(p[idx:], rr.recordDelimiter)
    		if i < 0 {
    			break
    		}
    		idx += i
    
    		p[idx] = '\n'
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.1K bytes
    - Click Count (0)
  4. cmd/object-handlers-common_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"net/http"
    	"net/http/httptest"
    	"testing"
    	"time"
    
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    // Tests - canonicalizeETag()
    func TestCanonicalizeETag(t *testing.T) {
    	testCases := []struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. cmd/streaming-v4-unsigned.go

    	for k := range cr.trailers {
    		wantTrailers[strings.ToLower(k)] = struct{}{}
    	}
    	input := bufio.NewScanner(bytes.NewReader(valueBuffer.Bytes()))
    	for input.Scan() {
    		line := strings.TrimSpace(input.Text())
    		if line == "" {
    			continue
    		}
    		// Find first separator.
    		idx := strings.IndexByte(line, trailerKVSeparator[0])
    		if idx <= 0 || idx >= len(line) {
    			if cr.debug {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  6. internal/config/crypto.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package config
    
    import (
    	"bytes"
    	"context"
    	"crypto/rand"
    	"encoding/binary"
    	"errors"
    	"fmt"
    	"io"
    
    	jsoniter "github.com/json-iterator/go"
    	"github.com/minio/minio/internal/kms"
    	"github.com/secure-io/sio-go"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  7. cmd/admin-handlers-config-kv.go

    	if err != nil {
    		return result, err
    	}
    
    	result.Dynamic, err = result.Cfg.ReadConfig(bytes.NewReader(kvBytes))
    	if err != nil {
    		return result, err
    	}
    
    	result.SubSys, _, _, err = config.GetSubSys(string(kvBytes))
    	if err != nil {
    		return result, err
    	}
    
    	tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes))
    	if err != nil {
    		return result, err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.8K bytes
    - Click Count (1)
  8. api/go1.24.txt

    pkg bytes, func FieldsFuncSeq([]uint8, func(int32) bool) iter.Seq[[]uint8] #61901
    pkg bytes, func FieldsSeq([]uint8) iter.Seq[[]uint8] #61901
    pkg bytes, func Lines([]uint8) iter.Seq[[]uint8] #61901
    pkg bytes, func SplitAfterSeq([]uint8, []uint8) iter.Seq[[]uint8] #61901
    pkg bytes, func SplitSeq([]uint8, []uint8) iter.Seq[[]uint8] #61901
    pkg crypto/cipher, func NewCFBDecrypter //deprecated #69445
    pkg crypto/cipher, func NewCFBEncrypter //deprecated #69445
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Dec 17 21:28:29 GMT 2024
    - 14.2K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

            while (this[mid + end] != '\n'.code.toByte()) {
              end++
            }
            val publicSuffixLength = mid + end - mid
    
            // Compare the bytes. Note that the file stores UTF-8 encoded bytes, so we must compare the
            // unsigned bytes.
            var compareResult: Int
            var currentLabelIndex = labelIndex
            var currentLabelByteIndex = 0
            var publicSuffixByteIndex = 0
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 28 07:33:49 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  10. docs/auditlog/auditlog-echo.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package main
    
    import (
    	"bytes"
    	"encoding/json"
    	"flag"
    	"fmt"
    	"io"
    	"log"
    	"net/http"
    )
    
    var port int
    
    func init() {
    	flag.IntVar(&port, "port", 8080, "Port to listen on")
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 1.5K bytes
    - Click Count (0)
Back to Top