Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewDefaultTokenProvider (0.56 sec)

  1. security/pkg/nodeagent/caclient/credentials.go

    type DefaultTokenProvider struct {
    	opts *security.Options
    }
    
    var _ credentials.PerRPCCredentials = &DefaultTokenProvider{}
    
    func NewDefaultTokenProvider(opts *security.Options) credentials.PerRPCCredentials {
    	return &DefaultTokenProvider{opts}
    }
    
    func (t *DefaultTokenProvider) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. security/pkg/nodeagent/caclient/providers/citadel/client.go

    func NewCitadelClient(opts *security.Options, tlsOpts *TLSOptions) (*CitadelClient, error) {
    	c := &CitadelClient{
    		tlsOpts:  tlsOpts,
    		opts:     opts,
    		provider: caclient.NewDefaultTokenProvider(opts),
    	}
    
    	conn, err := c.buildConnection()
    	if err != nil {
    		citadelClientLog.Errorf("Failed to connect to endpoint %s: %v", opts.CAEndpoint, err)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. pkg/istio-agent/xds_proxy.go

    	}
    	options, err := istiogrpc.ClientOptions(nil, tlsOpts)
    	if err != nil {
    		return nil, err
    	}
    	if sa.secOpts.CredFetcher != nil {
    		options = append(options, grpc.WithPerRPCCredentials(caclient.NewDefaultTokenProvider(sa.secOpts)))
    	}
    	return options, nil
    }
    
    // Returns the TLS option to use when talking to Istiod
    func (p *XdsProxy) getTLSOptions(agent *Agent) (*istiogrpc.TLSOptions, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 27.9K bytes
    - Viewed (0)
Back to top