- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for responses (0.08 sec)
-
istioctl/pkg/xds/client.go
err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration func DialOptions(opts clioptions.CentralControlPlaneOptions,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/kube/client.go
if err != nil { return nil, err } if len(res) > 0 { result[istiod.Name] = res } } // If any Discovery servers responded, treat as a success if len(result) > 0 { return result, nil } return nil, nil } func (c *client) EnvoyDo(ctx context.Context, podName, podNamespace, method, path string) ([]byte, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0)