- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 175 for req (0.17 sec)
-
maven-core/src/test/java/org/apache/maven/toolchain/DefaultToolchainManagerPrivateTest.java
// prepare MavenSession session = mock(MavenSession.class); MavenExecutionRequest req = new DefaultMavenExecutionRequest(); when(session.getRequest()).thenReturn(req); Map<String, List<ToolchainModel>> groupedToolchains = new HashMap<>(); req.setToolchains(groupedToolchains); List<ToolchainModel> basicToolchains = new ArrayList<>();
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Sat Apr 15 17:24:20 GMT 2023 - 5.7K bytes - Viewed (0) -
cmd/signature-v4.go
for k, v := range req.Form { if !defaultSigParams.Contains(k) { query[k] = v } } // Get the encoded query. encodedQuery := query.Encode() // Verify if date query is same. if req.Form.Get(xhttp.AmzDate) != query.Get(xhttp.AmzDate) { return ErrSignatureDoesNotMatch } // Verify if expires query is same. if req.Form.Get(xhttp.AmzExpires) != query.Get(xhttp.AmzExpires) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
internal/config/cache/cache.go
// busy already. ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, c.Endpoint+mcacheV1Check, bytes.NewReader(buf)) if err != nil { return nil, err } resp, err := c.clnt.Do(req) if err != nil { return nil, err } defer xhttp.DrainBody(resp.Body) switch resp.StatusCode {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
factory.Client = &fake.RESTClient{ GroupVersion: schema.GroupVersion{Group: "", Version: "v1"}, NegotiatedSerializer: ns, Client: fake.CreateHTTPClient(func(req *http.Request) (*http.Response, error) { switch p, m := req.URL.Path, req.Method; { case p == "/namespaces/istio-system/deployments/foo" && m == "GET": body := cmdtesting.ObjBody(codec, attachDeploy("istio-system"))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
cmd/erasure-common.go
return errDiskNotFound } return disks[index].ReadMultiple(ctx, req, resps[index]) }, index) } dataArray := make([]ReadMultipleResp, 0, len(req.Files)) // Merge results. They should come in order from each. for _, wantFile := range req.Files { quorum := 0 toAdd := ReadMultipleResp{ Bucket: req.Bucket, Prefix: req.Prefix, File: wantFile, } for i := range resps {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/WebApiUtil.java
} public static void setError(final int statusCode, final Exception e) { LaRequestUtil.getOptionalRequest().ifPresent(req -> req.setAttribute(WEB_API_EXCEPTION, new WebApiException(statusCode, e))); } public static void validate() {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/generic-handlers.go
// like healthCheck request func guessIsHealthCheckReq(req *http.Request) bool { if req == nil { return false } aType := getRequestAuthType(req) return aType == authTypeAnonymous && (req.Method == http.MethodGet || req.Method == http.MethodHead) && (req.URL.Path == healthCheckPathPrefix+healthCheckLivenessPath || req.URL.Path == healthCheckPathPrefix+healthCheckReadinessPath ||
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultSettingsBuilder.java
try { DefaultSettingsBuildingRequest req = new DefaultSettingsBuildingRequest(); req.setUserProperties(toProperties(session.getUserProperties())); req.setSystemProperties(toProperties(session.getSystemProperties())); if (request.getGlobalSettingsSource().isPresent()) { req.setGlobalSettingsSource(new MappedSettingsSource(
Java - Registered: Sun Mar 24 03:35:10 GMT 2024 - Last Modified: Tue Dec 05 08:11:33 GMT 2023 - 5.6K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
testPod := "testpod" testNS := "testns" // Fake out a test HTTP server and use that instead of a real HTTP server over gRPC to validate req/resp flows testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { defer req.Body.Close() data, err := io.ReadAll(req.Body) assert.NoError(t, err) var msg nodeagent.CNIPluginAddEvent err = json.Unmarshal(data, &msg) assert.NoError(t, err)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
tokens := strings.Fields(target.args.AuthToken) switch len(tokens) { case 2: req.Header.Set("Authorization", target.args.AuthToken) case 1: req.Header.Set("Authorization", "Bearer "+target.args.AuthToken) } req.Header.Set("Content-Type", "application/json") return target.httpClient.Do(req) } // Close the target. Will cancel all active requests.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Nov 17 20:02:26 GMT 2023 - 6.7K bytes - Viewed (0)