- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for responses (0.11 sec)
-
pkg/test/echo/client.go
} return nil } func (c *Client) Echo(ctx context.Context, request *proto.EchoRequest) (Response, error) { resp, err := c.client.Echo(ctx, request) if err != nil { return Response{}, err } return parseResponse(resp.Message), nil } // ForwardEcho sends the given forward request and parses the response for easier processing. Only fails if the request fails.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 4.1K bytes - Viewed (0) -
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)