- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ClientOptions (0.31 sec)
-
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) -
platforms/software/resources-s3/src/test/groovy/org/gradle/internal/resource/transport/aws/s3/S3ClientTest.groovy
s3Properties.getEndpoint() >> someEndpoint when: S3Client s3Client = new S3Client(credentials(), s3Properties) then: s3Client.amazonS3Client.clientOptions.pathStyleAccess == true s3Client.amazonS3Client.endpoint == someEndpoint.get() } def "should apply endpoint override with path style access without credentials"() { setup:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 10.3K 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) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
if err != nil { log.Error(err) } }() ctx, cancel := context.WithTimeout(context.Background(), time.Second*30) defer cancel() creds, _ := xdscreds.NewClientCredentials(xdscreds.ClientOptions{ FallbackCreds: insecure.NewCredentials(), }) conn, err := grpc.DialContext(ctx, fmt.Sprintf("xds:///%s.test.svc.cluster.local:%d", svcname, port), grpc.WithTransportCredentials(creds), grpc.WithBlock(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
tlsOpts, err := p.getTLSOptions(sa) if err != nil { return nil, fmt.Errorf("failed to get TLS options to talk to upstream: %v", err) } 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))) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0)