Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for checkRequest (0.11 sec)

  1. samples/extauthz/cmd/extauthz/main.go

    }
    
    func (s *extAuthzServerV2) logRequest(allow string, request *authv2.CheckRequest) {
    	httpAttrs := request.GetAttributes().GetRequest().GetHttp()
    	log.Printf("[gRPCv2][%s]: %s%s, attributes: %v\n", allow, httpAttrs.GetHost(),
    		httpAttrs.GetPath(),
    		request.GetAttributes())
    }
    
    func (s *extAuthzServerV2) allow(request *authv2.CheckRequest) *authv2.CheckResponse {
    	s.logRequest("allowed", request)
    	return &authv2.CheckResponse{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 15 18:23:48 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. pkg/test/framework/components/authz/provider.go

    		}),
    		headerNotContains(hType, map[string][]string{
    			XExtAuthzAdditionalHeaderOverride: {override},
    		}))
    
    	return checkRequest(opts, expectAllowed, checkHeaders)
    }
    
    func checkRequest(opts echo.CallOptions, expectAllowed bool, checkHeaders echo.Checker) echo.Checker {
    	switch {
    	case opts.Port.Protocol.IsGRPC():
    		switch opts.HTTP.Headers.Get(XExtAuthz) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 23 16:02:21 UTC 2022
    - 5.9K bytes
    - Viewed (0)
  3. samples/extauthz/cmd/extauthz/main_test.go

    		},
    	}
    	for _, tc := range cases {
    		t.Run(tc.name, func(t *testing.T) {
    			var got int
    			if tc.isGRPCV3 {
    				resp, err := grpcV3Client.Check(context.Background(), &authv3.CheckRequest{
    					Attributes: &authv3.AttributeContext{
    						Request: &authv3.AttributeContext_Request{
    							Http: &authv3.AttributeContext_HttpRequest{
    								Host:    "localhost",
    								Path:    "/check",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 23 16:58:02 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go

    	evaluator := e.registry.Get(a.GetResource().GroupResource())
    	if evaluator == nil {
    		return quotas, nil
    	}
    	return CheckRequest(quotas, a, evaluator, e.config.LimitedResources)
    }
    
    // CheckRequest is a static version of quotaEvaluator.checkRequest, possible to be called from outside.
    func CheckRequest(quotas []corev1.ResourceQuota, a admission.Attributes, evaluator quota.Evaluator,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbTreeImpl.java

                        // this used to trigger "invalid operation..."
                        throw new SmbException("Service is null in state " + this.connectionState.get());
                    }
                    checkRequest(transport, req, svc);
    
                }
    
                if ( this.isDfs() && !"IPC".equals(svc) && !"IPC$".equals(this.share) && request instanceof RequestWithPath ) {
                    /*
    Registered: Wed Jun 12 15:45:55 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 29.6K bytes
    - Viewed (0)
Back to top