- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ClientOptions (0.23 sec)
-
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) -
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) -
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) -
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) -
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)