Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 162 for newReader (0.04 sec)

  1. cmd/bucket-lifecycle_test.go

    			expectedErr: nil,
    		},
    	}
    	for i, tc := range testCases {
    		lc, err := lifecycle.ParseLifecycleConfig(bytes.NewReader(tc.xml))
    		if err != nil {
    			t.Fatalf("Test %d: Failed to parse lifecycle config %v", i+1, err)
    		}
    
    		err = validateTransitionTier(lc)
    		if err != tc.expectedErr {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 31 09:57:57 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. src/cmd/asm/internal/lex/lex.go

    	tokens []Token  // Body of macro.
    }
    
    // Tokenize turns a string into a list of Tokens; used to parse the -D flag and in tests.
    func Tokenize(str string) []Token {
    	t := NewTokenizer("command line", strings.NewReader(str), nil)
    	var tokens []Token
    	for {
    		tok := t.Next()
    		if tok == scanner.EOF {
    			break
    		}
    		tokens = append(tokens, Make(tok, t.Text()))
    	}
    	return tokens
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  3. src/bytes/example_test.go

    	// Output:
    	// 'Gjnf oevyyvt naq gur fyvgul tbcure...
    }
    
    func ExampleReader_Len() {
    	fmt.Println(bytes.NewReader([]byte("Hi!")).Len())
    	fmt.Println(bytes.NewReader([]byte("こんにちは!")).Len())
    	// Output:
    	// 3
    	// 16
    }
    
    func ExampleRepeat() {
    	fmt.Printf("ba%s", bytes.Repeat([]byte("na"), 2))
    	// Output: banana
    }
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 12 16:07:54 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  4. cmd/erasure-healing-common_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    		t.Run(fmt.Sprintf("case-%d", i), func(t *testing.T) {
    			_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), ObjectOptions{})
    			if err != nil {
    				t.Fatalf("Failed to putObject %v", err)
    			}
    
    			partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  5. cmd/post-policy_test.go

    			t.Fatalf("Test %d: %s: Failed to create HTTP request for PostPolicyHandler: <ERROR> %v", i+1, instanceType, perr)
    		}
    		if testCase.malformedBody {
    			// Change the request body.
    			req.Body = io.NopCloser(bytes.NewReader([]byte("Hello,")))
    		}
    		// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(rec, req)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.6K bytes
    - Viewed (0)
  6. cmd/admin-handlers-idp-config.go

    	}
    
    	cfg, err := readServerConfig(ctx, objectAPI, nil)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	dynamic, err := cfg.ReadConfig(strings.NewReader(cfgData))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// IDP config is not dynamic. Sanity check.
    	if dynamic {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common.go

    		}
    
    		// Always check data, if we got it.
    		if (len(meta.Data) > 0 || meta.Size == 0) && len(meta.Parts) > 0 {
    			checksumInfo := meta.Erasure.GetChecksumInfo(meta.Parts[0].Number)
    			verifyErr := bitrotVerify(bytes.NewReader(meta.Data),
    				int64(len(meta.Data)),
    				meta.Erasure.ShardFileSize(meta.Size),
    				checksumInfo.Algorithm,
    				checksumInfo.Hash, meta.Erasure.ShardSize())
    			dataErrsByPart[0][i] = convPartErrToInt(verifyErr)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 12K bytes
    - Viewed (0)
  8. cmd/object-lambda-handlers_test.go

    						PrincipalID: "test-user",
    					},
    				}, nil
    			}
    
    			body := []byte{}
    			req := httptest.NewRequest("GET", "/objectlambda/"+bucketName+"/"+objectName+"?lambdaArn="+url.QueryEscape(lambdaARN), bytes.NewReader(body))
    			req.Form = url.Values{"lambdaArn": []string{lambdaARN}}
    			req.Header.Set("Host", "localhost")
    			req.Header.Set("X-Amz-Date", time.Now().UTC().Format("20060102T150405Z"))
    			sum := sha256.Sum256(body)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 18 21:56:31 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  9. cmd/common-main.go

    		logger.Fatal(err, "Unable to generate root secret key using KMS")
    	}
    
    	accessKey, err := auth.GenerateAccessKey(20, bytes.NewReader(aKey))
    	if err != nil {
    		logger.Fatal(err, "Unable to generate root access key")
    	}
    	secretKey, err := auth.GenerateSecretKey(32, bytes.NewReader(sKey))
    	if err != nil {
    		logger.Fatal(err, "Unable to generate root secret key")
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  10. cmd/main.go

    	fmt.Fprintln(banner, color.Blue("License:")+color.Bold(" GNU AGPLv3 - https://www.gnu.org/licenses/agpl-3.0.html"))
    	fmt.Fprintln(banner, color.Blue("Copyright:")+color.Bold(" 2015-%s MinIO, Inc.", CopyrightYear))
    	return strings.NewReader(banner.String())
    }
    
    func printMinIOVersion(c *cli.Context) {
    	io.Copy(c.App.Writer, versionBanner(c))
    }
    
    var debugNoExit = env.Get("_MINIO_DEBUG_NO_EXIT", "") != ""
    
    // Main main for minio server.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jul 30 22:59:48 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top