- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for Req (0.02 sec)
-
src/test/java/org/codelibs/fess/helper/AccessTokenHelperTest.java
MockletHttpServletRequest req = getMockRequest(); req.addHeader("Authorization", "Bearer " + token); assertEquals(token, accessTokenHelper.getAccessTokenFromRequest(req)); } public void test_getAccessTokenFromRequest_ok1() { final String token = accessTokenHelper.generateAccessToken(); MockletHttpServletRequest req = getMockRequest(); req.addHeader("Authorization", token);
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.1K bytes - Viewed (0) -
internal/grid/handlers.go
// The request may be reused, so caller should clear any fields. func (h *SingleHandler[Req, Resp]) NewRequest() Req { return h.newReq() } // Register a handler for a Req -> Resp roundtrip. // Requests are automatically recycled. func (h *SingleHandler[Req, Resp]) Register(m *Manager, handle func(req Req) (resp Resp, err *RemoteErr), subroute ...string) error { if h.newReq == nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 27.7K bytes - Viewed (0) -
internal/kms/kms.go
k.updateMetrics(err, time.Since(start)) return plaintext, err } // MAC generates the checksum of the given req.Message using the key // with the req.Name at the KMS. func (k *KMS) MAC(ctx context.Context, req *MACRequest) ([]byte, error) { if req.Name == "" { req.Name = k.DefaultKey } start := time.Now() mac, err := k.conn.MAC(ctx, req)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 11.5K bytes - Viewed (0) -
cmd/auth-handler_test.go
req := mustNewRequest(method, urlStr, contentLength, body, t) req.Header.Set("Content-Md5", "invalid-digest") cred := globalActiveCred if err := signRequestV4(req, cred.AccessKey, cred.SecretKey); err != nil { t.Fatalf("Unable to initialized new signed http request %s", err) } return req }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.4K 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() {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.9K bytes - Viewed (0) -
internal/kms/kes.go
return nil, errDecryptionFailed(err) } return plaintext, nil } // MAC generates the checksum of the given req.Message using the key // with the req.Name at the KMS. func (c *kesConn) MAC(ctx context.Context, req *MACRequest) ([]byte, error) { mac, err := c.client.HMAC(context.Background(), req.Name, req.Message) if err != nil { if errors.Is(err, kes.ErrKeyNotFound) { return nil, ErrKeyNotFound }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
internal/kms/stub.go
func (s *StubKMS) CreateKey(_ context.Context, req *CreateKeyRequest) error { if s.containsKeyName(req.Name) { return ErrKeyExists } s.KeyNames = append(s.KeyNames, req.Name) return nil } // GenerateKey is a non-functional stub. func (s StubKMS) GenerateKey(_ context.Context, req *GenerateKeyRequest) (DEK, error) { if !s.containsKeyName(req.Name) { return DEK{}, ErrKeyNotFound } return DEK{
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 3.6K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
} }() userDefined := make(map[string]string, len(req.UserMetadata)) for k, v := range req.UserMetadata { userDefined[k] = v } userDefined[xhttp.AmzObjectTagging] = s3utils.TagEncode(req.UserTags) if opts.Kind != nil { encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx) if err != nil { errs[idx] = err
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/handlers/forwarder.go
} } if xfPort := req.Header.Get(xForwardedPort); xfPort == "" { req.Header.Set(xForwardedPort, forwardedPort(req)) } if xfHost := req.Header.Get(xForwardedHost); xfHost == "" && req.Host != "" { req.Header.Set(xForwardedHost, req.Host) } } func forwardedPort(req *http.Request) string { if req == nil { return "" } if _, port, err := net.SplitHostPort(req.Host); err == nil && port != "" {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0) -
internal/logger/logger.go
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 22 09:43:48 UTC 2024 - 12.4K bytes - Viewed (0)