Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 212 for newHeader (0.07 sec)

  1. 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)
  2. cmd/test-utils_test.go

    	}
    	newReq := req
    	newReq.Body = io.NopCloser(
    		bytes.NewReader(bytes.Join([][]byte{newChunkHdr, newChunk[:len(newChunk)/2]},
    			[]byte(""))),
    	)
    	return newReq, nil
    }
    
    // Malform data given a request signed using streaming signature V4.
    func malformDataSigV4(req *http.Request, newByte byte) (*http.Request, error) {
    	bufReader := bufio.NewReader(req.Body)
    	hexChunkSize, chunkSignature, err := readChunkLine(bufReader)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  3. internal/config/subnet/subnet.go

    	}
    	body, err := json.Marshal(payload)
    	if err != nil {
    		return "", err
    	}
    	r, err := http.NewRequest(http.MethodPost, reqURL, bytes.NewReader(body))
    	if err != nil {
    		return "", err
    	}
    
    	r.Header.Set("Content-Type", "application/json")
    
    	return c.submitPost(r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 27 16:35:36 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  4. internal/bucket/replication/rule_test.go

    			expectedResult: true,
    		},
    	}
    
    	for i, tc := range testCases {
    		tc := tc
    		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)
    			}
    			if got := cfg.Rules[0].MetadataReplicate(tc.opts); got != tc.expectedResult {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.6K bytes
    - Viewed (0)
  5. src/archive/zip/register.go

    }
    
    var flateReaderPool sync.Pool
    
    func newFlateReader(r io.Reader) io.ReadCloser {
    	fr, ok := flateReaderPool.Get().(io.ReadCloser)
    	if ok {
    		fr.(flate.Resetter).Reset(r, nil)
    	} else {
    		fr = flate.NewReader(r)
    	}
    	return &pooledFlateReader{fr: fr}
    }
    
    type pooledFlateReader struct {
    	mu sync.Mutex // guards Close and Read
    	fr io.ReadCloser
    }
    
    func (r *pooledFlateReader) Read(p []byte) (n int, err error) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  6. internal/config/identity/openid/provider/keycloak.go

    	values.Set("client_id", clientID)
    	values.Set("client_secret", clientSecret)
    	values.Set("grant_type", "client_credentials")
    
    	req, err := http.NewRequest(http.MethodPost, k.oeConfig.TokenEndpoint, strings.NewReader(values.Encode()))
    	if err != nil {
    		return err
    	}
    	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    
    	resp, err := k.client.Do(req)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:12:07 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. cmd/veeam-sos-api.go

    			ci.Capacity = quotaSize
    		}
    		ci.Available = ci.Capacity - ci.Used
    
    		buf = encodeResponse(&ci)
    	default:
    		return nil, errFileNotFound
    	}
    
    	etag := getMD5Hash(buf)
    	r := bytes.NewReader(buf)
    
    	off, length := int64(0), r.Size()
    	if rs != nil {
    		off, length, err = rs.GetOffsetLength(r.Size())
    		if err != nil {
    			return nil, err
    		}
    	}
    	r.Seek(off, io.SeekStart)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. internal/event/target/webhook.go

    	if err != nil {
    		return err
    	}
    
    	req, err := http.NewRequest(http.MethodPost, target.args.Endpoint.String(), bytes.NewReader(data))
    	if err != nil {
    		return err
    	}
    
    	// Verify if the authToken already contains
    	// <Key> <Token> like format, if this is
    	// already present we can blindly use the
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/io/FilesTest.java

        File asciiFile = getTestFile("ascii.txt");
        assertThrows(NullPointerException.class, () -> Files.newReader(asciiFile, null));
    
        assertThrows(NullPointerException.class, () -> Files.newReader(null, UTF_8));
    
        BufferedReader r = Files.newReader(asciiFile, US_ASCII);
        try {
          assertEquals(ASCII, r.readLine());
        } finally {
          r.close();
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  10. src/archive/zip/reader.go

    		return nil, err
    	}
    	r.f = f
    	return r, err
    }
    
    // NewReader returns a new [Reader] reading from r, which is assumed to
    // have the given size in bytes.
    //
    // If any file inside the archive uses a non-local name
    // (as defined by [filepath.IsLocal]) or a name containing backslashes
    // and the GODEBUG environment variable contains `zipinsecurepath=0`,
    // NewReader returns the reader with an [ErrInsecurePath] error.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top