Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ClientOptions (0.2 sec)

  1. pilot/pkg/grpc/grpc.go

    	defaultInitialConnWindowSize       = 1024 * 1024 // default gRPC InitialWindowSize
    	defaultInitialWindowSize           = 1024 * 1024 // default gRPC ConnWindowSize
    )
    
    // ClientOptions returns consistent grpc dial options with custom dial options
    func ClientOptions(options *istiokeepalive.Options, tlsOpts *TLSOptions) ([]grpc.DialOption, error) {
    	if options == nil {
    		options = istiokeepalive.DefaultOption()
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Feb 17 04:27:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  2. pkg/test/echo/client.go

    		}
    		dialOptions = append(dialOptions, grpc.WithTransportCredentials(cfg))
    	} else if strings.HasPrefix(address, "xds:///") {
    		creds, err := xdscreds.NewClientCredentials(xdscreds.ClientOptions{FallbackCreds: insecure.NewCredentials()})
    		if err != nil {
    			return nil, err
    		}
    		dialOptions = append(dialOptions, grpc.WithTransportCredentials(creds))
    	} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Nov 14 20:23:34 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  3. pkg/test/echo/server/forwarder/xds.go

    func (c *xdsProtocol) Close() error {
    	return nil
    }
    
    func newXDSConnection(cfg *Config) (*grpc.ClientConn, error) {
    	var opts []grpc.DialOption
    
    	// transport security
    	creds, err := xds.NewClientCredentials(xds.ClientOptions{FallbackCreds: insecure.NewCredentials()})
    	if err != nil {
    		return nil, err
    	}
    	security := grpc.WithTransportCredentials(creds)
    	if len(cfg.XDSTestBootstrap) > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 10 18:09:08 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  4. security/pkg/nodeagent/caclient/providers/citadel/client.go

    			SAN:           c.opts.CAEndpointSAN,
    		}
    	}
    	return nil
    }
    
    func (c *CitadelClient) buildConnection() (*grpc.ClientConn, error) {
    	tlsOpts := c.getTLSOptions()
    	opts, err := istiogrpc.ClientOptions(nil, tlsOpts)
    	if err != nil {
    		return nil, err
    	}
    	opts = append(opts,
    		grpc.WithPerRPCCredentials(c.provider),
    		security.CARetryInterceptor(),
    	)
    	conn, err := grpc.Dial(c.opts.CAEndpoint, opts...)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 4.9K bytes
    - Viewed (0)
Back to top