Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 1,301 for range (0.02 seconds)

  1. internal/store/queuestore.go

    	store.RLock()
    	defer store.RUnlock()
    
    	entries := make([]string, 0, len(store.entries))
    	for entry := range store.entries {
    		entries = append(entries, entry)
    	}
    
    	// Sort entries...
    	sort.Slice(entries, func(i, j int) bool {
    		return store.entries[entries[i]] < store.entries[entries[j]]
    	})
    
    	for i := range entries {
    		keys = append(keys, parseKey(entries[i]))
    	}
    
    	return keys
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  2. buildscripts/heal-manual.go

    			fmt.Println("Healstatus on items ===")
    			for _, item := range status.Items {
    				if err = enc.Encode(&item); err != nil {
    					log.Fatalln(err)
    				}
    			}
    			break
    		}
    		if status.Summary == "stopped" {
    			fmt.Println("Healstatus on items ===")
    			fmt.Println("Heal failed with", status.FailureDetail)
    			break
    		}
    
    		for _, item := range status.Items {
    			if err = enc.Encode(&item); err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 27 09:47:58 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  3. cmd/encryption-v1.go

    }
    
    // GetDecryptedRange - To decrypt the range (off, length) of the
    // decrypted object stream, we need to read the range (encOff,
    // encLength) of the encrypted object stream to decrypt it, and
    // compute skipLen, the number of bytes to skip in the beginning of
    // the encrypted range.
    //
    // In addition we also compute the object part number for where the
    // requested range starts, along with the DARE sequence number within
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 38K bytes
    - Click Count (0)
  4. internal/s3select/sql/stringfuncs_test.go

    	dropCases := []struct {
    		input, resultExpected string
    		matchExpected         bool
    	}{
    		{"", "", false},
    		{"a", "", true},
    		{"ab", "b", true},
    		{"தமிழ்", "மிழ்", true},
    	}
    
    	for i, tc := range dropCases {
    		res, ok := dropRune(tc.input)
    		if res != tc.resultExpected || ok != tc.matchExpected {
    			t.Errorf("DropRune Case %d failed", i)
    		}
    	}
    
    	matcherCases := []struct {
    		iText, iPat        string
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.1K bytes
    - Click Count (0)
  5. cmd/main.go

    DESCRIPTION:
      {{.Description}}
    
    USAGE:
      {{.HelpName}} {{if .VisibleFlags}}[FLAGS] {{end}}COMMAND{{if .VisibleFlags}}{{end}} [ARGS...]
    
    COMMANDS:
      {{range .VisibleCommands}}{{join .Names ", "}}{{ "\t" }}{{.Usage}}
      {{end}}{{if .VisibleFlags}}
    FLAGS:
      {{range .VisibleFlags}}{{.}}
      {{end}}{{end}}
    VERSION:
      {{.Version}}
    `
    
    func newApp(name string) *cli.App {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jul 30 22:59:48 GMT 2024
    - 6.5K bytes
    - Click Count (0)
  6. cmd/typed-errors.go

    var errServerTimeMismatch = errors.New("Server times are too far apart")
    
    // errInvalidRange - returned when given range value is not valid.
    var errInvalidRange = errors.New("Invalid range")
    
    // errInvalidRangeSource - returned when given range value exceeds
    // the source object size.
    var errInvalidRangeSource = errors.New("Range specified exceeds source object size")
    
    // error returned by disks which are to be initialized are waiting for the
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 16 07:34:24 GMT 2025
    - 5.9K bytes
    - Click Count (1)
  7. cmd/kms-handlers_test.go

    				"Action": ["kms:CreateKey"],
    				"Resource": ["arn:minio:kms:::non-matching-key-name"] }`,
    
    			wantStatusCode: http.StatusForbidden,
    			wantResp:       []string{"AccessDenied"},
    		},
    	}
    	for testNum, test := range tests {
    		t.Run(fmt.Sprintf("%d %s", testNum+1, test.name), func(t *testing.T) {
    			execKMSTest(t, test, adminTestBed)
    		})
    	}
    }
    
    func TestKMSHandlersKeyStatus(t *testing.T) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  8. clause/benchmarks_test.go

    		for _, clause := range clauses {
    			stmt.AddClause(clause)
    		}
    
    		stmt.Build("SELECT", "FROM", "WHERE")
    		_ = stmt.SQL.String()
    	}
    }
    
    func BenchmarkComplexSelect(b *testing.B) {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Oct 07 12:14:14 GMT 2022
    - 1.9K bytes
    - Click Count (0)
  9. schema/naming.go

    	commonInitialismsReplacer *strings.Replacer
    )
    
    func init() {
    	commonInitialismsForReplacer := make([]string, 0, len(commonInitialisms))
    	for _, initialism := range commonInitialisms {
    		commonInitialismsForReplacer = append(commonInitialismsForReplacer, initialism, cases.Title(language.Und).String(initialism))
    	}
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Wed Jun 12 03:46:59 GMT 2024
    - 5.3K bytes
    - Click Count (0)
  10. internal/bucket/encryption/bucket-sse-config.go

    func (b *BucketSSEConfig) Algo() Algorithm {
    	for _, rule := range b.Rules {
    		return rule.DefaultEncryptionAction.Algorithm
    	}
    	return ""
    }
    
    // KeyID returns the KMS key ID specified by the SSE configuration.
    // If the SSE configuration does not specify SSE-KMS it returns an
    // empty key ID.
    func (b *BucketSSEConfig) KeyID() string {
    	for _, rule := range b.Rules {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 4.9K bytes
    - Click Count (0)
Back to Top