Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 208 for newReader (0.09 sec)

  1. internal/s3select/select.go

    			if simdjson.SupportedCPU() {
    				s3Select.recordReader = simdj.NewReader(s3Select.progressReader, &s3Select.Input.JSONArgs)
    			} else {
    				s3Select.recordReader = json.NewPReader(s3Select.progressReader, &s3Select.Input.JSONArgs)
    			}
    		} else {
    			// Document mode.
    			s3Select.recordReader = json.NewReader(s3Select.progressReader, &s3Select.Input.JSONArgs)
    		}
    
    		return nil
    	case parquetFormat:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  2. internal/crypto/key.go

    	mac.Write([]byte(domain))
    	mac.Write([]byte(SealAlgorithm))
    	mac.Write([]byte(path.Join(bucket, object))) // use path.Join for canonical 'bucket/object'
    	mac.Sum(sealingKey[:0])
    	if n, err := sio.Encrypt(&encryptedKey, bytes.NewReader(key[:]), sio.Config{Key: sealingKey[:], CipherSuites: fips.DARECiphers()}); n != 64 || err != nil {
    		logger.CriticalIf(context.Background(), errors.New("Unable to generate sealed key"))
    	}
    	sealedKey := SealedKey{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:28:10 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/line_test.go

    	})
    }
    
    func testBadInstParser(t *testing.T, goarch string, tests []badInstTest) {
    	for i, test := range tests {
    		arch, ctxt := setArch(goarch)
    		tokenizer := lex.NewTokenizer("", strings.NewReader(test.input+"\n"), nil)
    		parser := NewParser(ctxt, arch, tokenizer)
    
    		err := tryParse(t, func() {
    			parser.Parse()
    		})
    
    		switch {
    		case err == nil:
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users.go

    		return
    	}
    	data, err := io.ReadAll(r.Body)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    	reader := bytes.NewReader(data)
    	zr, err := zip.NewReader(reader, int64(len(data)))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    
    	var skipped, removed, added madmin.IAMEntities
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  5. internal/mountinfo/mountinfo_linux_test.go

    		/dev/1    /path/to/1   type1	flags 1 1
    		/dev/2 /path/to/2 type2 flags,1,2=3 2 2
    		`
    	// Success case, verifies if parsing works properly.
    	{
    		mounts, err := parseMountFrom(strings.NewReader(successCase))
    		if err != nil {
    			t.Errorf("expected success")
    		}
    		if len(mounts) != 3 {
    			t.Fatalf("expected 3 mounts, got %d", len(mounts))
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. cmd/object-api-deleteobject_test.go

    		}
    
    		for _, object := range testCase.objectToUploads {
    			md5Bytes := md5.Sum([]byte(object.content))
    			oi, err := obj.PutObject(context.Background(), testCase.bucketName, object.name, mustGetPutObjReader(t, strings.NewReader(object.content),
    				int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{})
    			if err != nil {
    				t.Log(oi)
    				t.Fatalf("%s : %s", instanceType, err.Error())
    			}
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  7. internal/bucket/object/lock/lock_test.go

    			expectedErr: nil,
    			expectErr:   false,
    		},
    	}
    	for _, tt := range tests {
    		tt := tt
    		t.Run("", func(t *testing.T) {
    			_, err := ParseObjectLockConfig(strings.NewReader(tt.value))
    			//nolint:gocritic
    			if tt.expectedErr == nil {
    				if err != nil {
    					t.Fatalf("error: expected = <nil>, got = %v", err)
    				}
    			} else if err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  8. docs/debugging/inspect/decrypt-v2.go

    func extractInspectV2(pk []byte, r io.Reader, w io.Writer, okMsg string) error {
    	privKey, err := bytesToPrivateKey(pk)
    	if err != nil {
    		return fmt.Errorf("decoding key returned: %w", err)
    	}
    
    	sr, err := estream.NewReader(r)
    	if err != nil {
    		return err
    	}
    
    	sr.SetPrivateKey(privKey)
    	sr.ReturnNonDecryptable(true)
    
    	// Debug corrupted streams.
    	if false {
    		sr.SkipEncrypted(true)
    		return sr.DebugStream(os.Stdout)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 11 21:22:47 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. internal/etag/etag_test.go

    	},
    }
    
    func TestReader(t *testing.T) {
    	for i, test := range readerTests {
    		reader := NewReader(context.Background(), strings.NewReader(test.Content), test.ETag, nil)
    		if _, err := io.Copy(io.Discard, reader); err != nil {
    			t.Fatalf("Test %d: read failed: %v", i, err)
    		}
    		if ETag := reader.ETag(); !Equal(ETag, test.ETag) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  10. cmd/object-handlers_test.go

    				int64(testCase.dataLen), testCase.chunkSize, bytes.NewReader(testCase.data),
    				testCase.accessKey, testCase.secretKey)
    		case testCase.contentEncoding == "":
    			req, err = newTestStreamingSignedRequest(http.MethodPut,
    				getPutObjectURL("", testCase.bucketName, testCase.objectName),
    				int64(testCase.dataLen), testCase.chunkSize, bytes.NewReader(testCase.data),
    				testCase.accessKey, testCase.secretKey)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
Back to top