Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ClientOptions (0.23 sec)

  1. staging/src/k8s.io/cli-runtime/pkg/resource/interfaces.go

    	if len(transforms) == 0 {
    		return c
    	}
    	return &clientOptions{c: c, transforms: transforms}
    }
    
    type clientOptions struct {
    	c          RESTClient
    	transforms []RequestTransform
    }
    
    func (c *clientOptions) modify(req *rest.Request) *rest.Request {
    	for _, transform := range c.transforms {
    		transform(req)
    	}
    	return req
    }
    
    func (c *clientOptions) Get() *rest.Request {
    	return c.modify(c.c.Get())
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 23:00:24 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  2. 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)
  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. 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)
  5. 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