Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for CloseRespFn (0.12 sec)

  1. internal/config/identity/plugin/config.go

    	if err != nil {
    		return args, config.Errorf("unable to generate ARN from the plugin config: %v", err)
    	}
    
    	args = Args{
    		URL:         u,
    		AuthToken:   authToken,
    		Transport:   transport,
    		CloseRespFn: closeRespFn,
    		RolePolicy:  rolePolicy,
    		RoleARN:     roleArn,
    	}
    	if err = args.Validate(); err != nil {
    		return args, err
    	}
    	return args, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. internal/config/policy/opa/config.go

    	}
    
    	u, err := xnet.ParseHTTPURL(opaURL)
    	if err != nil {
    		return args, err
    	}
    	args = Args{
    		URL:         u,
    		AuthToken:   authToken,
    		Transport:   transport,
    		CloseRespFn: closeRespFn,
    	}
    	if err = args.Validate(); err != nil {
    		return args, err
    	}
    	return args, nil
    }
    
    // New - initializes opa policy engine connector.
    func New(args Args) *Opa {
    	// No opa args.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. internal/config/policy/plugin/config.go

    	httpSettings.EnableHTTP2 = enableHTTP2
    	transport := httpSettings.NewHTTPTransportWithTimeout(time.Minute)
    
    	args = Args{
    		URL:         u,
    		AuthToken:   getCfg(AuthToken),
    		Transport:   transport,
    		CloseRespFn: closeRespFn,
    	}
    	if err = args.Validate(); err != nil {
    		return args, err
    	}
    	return args, nil
    }
    
    // New - initializes Authorization Management Plugin.
    func New(args Args) *AuthZPlugin {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. internal/config/identity/openid/openid.go

    		pubKeys:            r.pubKeys,
    		roleArnPolicyMap:   make(map[arn.ARN]string, len(r.roleArnPolicyMap)),
    		transport:          r.transport,
    		closeRespFn:        r.closeRespFn,
    	}
    	for k, v := range r.arnProviderCfgsMap {
    		cfg.arnProviderCfgsMap[k] = v
    	}
    	for k, v := range r.ProviderCfgs {
    		cfg.ProviderCfgs[k] = v
    	}
    	for k, v := range r.roleArnPolicyMap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. internal/config/identity/openid/jwt.go

    func parseDiscoveryDoc(u *xnet.URL, transport http.RoundTripper, closeRespFn func(io.ReadCloser)) (DiscoveryDoc, error) {
    	d := DiscoveryDoc{}
    	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
    	if err != nil {
    		return d, err
    	}
    	clnt := http.Client{
    		Transport: transport,
    	}
    	resp, err := clnt.Do(req)
    	if err != nil {
    		return d, err
    	}
    	defer closeRespFn(resp.Body)
    	if resp.StatusCode != http.StatusOK {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. internal/config/identity/openid/jwt_test.go

    		Enabled: true,
    		pubKeys: pubKeys,
    		arnProviderCfgsMap: map[arn.ARN]*providerCfg{
    			DummyRoleARN: &provider,
    		},
    		ProviderCfgs: map[string]*providerCfg{
    			"1": &provider,
    		},
    		closeRespFn: func(rc io.ReadCloser) {
    			rc.Close()
    		},
    	}
    
    	var claims jwtgo.MapClaims
    	if err = cfg.Validate(context.Background(), DummyRoleARN, token, "", "", claims); err != nil {
    		t.Fatal(err)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  7. cmd/iam.go

    		} else {
    			authZPluginCfg.URL = opaCfg.URL
    			authZPluginCfg.AuthToken = opaCfg.AuthToken
    			authZPluginCfg.Transport = opaCfg.Transport
    			authZPluginCfg.CloseRespFn = opaCfg.CloseRespFn
    		}
    	}
    
    	setGlobalAuthZPlugin(polplugin.New(authZPluginCfg))
    
    	sys.Lock()
    	sys.LDAPConfig = ldapConfig
    	sys.OpenIDConfig = openidConfig
    	sys.STSTLSConfig = stsTLSConfig
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
Back to top