- Sort Score
- Num 10 results
- Language All
Results 831 - 840 of 1,301 for range (0.04 seconds)
-
cmd/callhome.go
return } healthCtx, healthCancel := context.WithTimeout(ctx, deadline) defer healthCancel() healthInfoCh := make(chan madmin.HealthInfo) query := url.Values{} for _, k := range madmin.HealthDataTypesList { query.Set(string(k), "true") } healthInfo := madmin.HealthInfo{ TimeStamp: time.Now().UTC(), Version: madmin.HealthInfoVersion, Minio: madmin.MinioHealthInfo{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
cmd/dynamic-timeouts.go
// adjust changes the value of the dynamic timeout based on the // previous results func (dt *dynamicTimeout) adjust(entries [dynamicTimeoutLogSize]time.Duration) { failures, maxDur := 0, time.Duration(0) for _, dur := range entries[:] { if dur == maxDuration { failures++ } else if dur > maxDur { maxDur = dur } } failPct := float64(failures) / float64(len(entries))
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.5K bytes - Click Count (0) -
internal/jwt/parser_test.go
tk, _ := j.SignedString([]byte("HelloSecret")) return tk } func TestParserParse(t *testing.T) { // Iterate over test data set and run tests for _, data := range jwtTestData { t.Run(data.name, func(t *testing.T) { // Parse the token var err error // Figure out correct claims type switch claims := data.claims.(type) { case *MapClaims:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0) -
docs/sts/assume-role.go
} fmt.Printf("Calling list objects on bucket named `%s` with temp creds:\n===\n", bucketToList) objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{}) for obj := range objCh { if obj.Err != nil { log.Fatalf("Listing error: %v", obj.Err) } fmt.Printf("Key: %s\nSize: %d\nLast Modified: %s\n===\n", obj.Key, obj.Size, obj.LastModified) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sat Aug 17 01:24:54 GMT 2024 - 4.4K bytes - Click Count (1) -
internal/config/compress/compress.go
} ) // Parses the given compression exclude list `extensions` or `content-types`. func parseCompressIncludes(include string) ([]string, error) { includes := strings.Split(include, config.ValueSeparator) for _, e := range includes { if len(e) == 0 { return nil, config.ErrInvalidCompressionIncludesValue(nil).Msg("extension/mime-type cannot be empty") } if e == "/" {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sat Sep 06 17:37:10 GMT 2025 - 5K bytes - Click Count (0) -
cmd/object-api-getobjectinfo_test.go
// Valid case with existing object (Test number 12). {"test-getobjectinfo", "Asia/asiapics.jpg", resultCases[0], nil, true}, {"test-getobjectinfo", "Asia/empty-dir/", resultCases[1], nil, true}, } for i, testCase := range testCases { result, err := obj.GetObjectInfo(context.Background(), testCase.bucketName, testCase.objectName, opts) if err != nil && testCase.shouldPass {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 5.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cookie.kt
} expiresAt = currentTimeMillis + deltaMilliseconds if (expiresAt < currentTimeMillis || expiresAt > MAX_DATE) { expiresAt = MAX_DATE // Handle overflow & limit the date range. } } // If the domain is present, it must domain match. Otherwise we have a host-only cookie. val urlHost = url.host if (domain == null) { domain = urlHostCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 23.1K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/NtTransQuerySecurityDescTest.java
bb.putShort((short) fid); bb.put((byte) 0x00); // Reserved bb.put((byte) 0x00); // Reserved bb.putInt(securityInformation); return bb.array(); } /** * Provide a range of values that are valid for the constructor. */ static Stream<org.junit.jupiter.params.provider.Arguments> validInputs() { return Stream.of(org.junit.jupiter.params.provider.Arguments.of(0x0001, 0x00000000),
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 4.6K bytes - Click Count (0) -
internal/bucket/replication/rule_test.go
opts: ObjectOpts{Name: "c2test", DeleteMarker: false, OpType: MetadataReplicationType, Replica: true}, // 1. Replica mod sync enabled; a replica expectedResult: true, }, } for i, tc := range testCases { t.Run(fmt.Sprintf("Test_%d", i+1), func(t *testing.T) { cfg, err := ParseConfig(bytes.NewReader([]byte(tc.inputConfig))) if err != nil { t.Fatalf("Got unexpected error: %v", err) }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.6K bytes - Click Count (0) -
cmd/object-handlers-common.go
if objInfo.ModTime.IsZero() || objInfo.ModTime.Equal(time.Unix(0, 0)) { return false } // Check if the part number is correct. if opts.PartNumber > 1 { partFound := false for _, pi := range objInfo.Parts { if pi.Number == opts.PartNumber { partFound = true break } } if !partFound { // According to S3 we don't need to set any object information here.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Jul 23 12:36:06 GMT 2025 - 15.2K bytes - Click Count (0)