in gapic/agent_communication_client.go [212:225]
func (c *gRPCClient) SendAgentMessage(ctx context.Context, req *agentcommunicationpb.SendAgentMessageRequest, opts ...gax.CallOption) (*agentcommunicationpb.SendAgentMessageResponse, error) {
ctx = gax.InsertMetadataIntoOutgoingContext(ctx, c.xGoogHeaders...)
opts = append((*c.CallOptions).SendAgentMessage[0:len((*c.CallOptions).SendAgentMessage):len((*c.CallOptions).SendAgentMessage)], opts...)
var resp *agentcommunicationpb.SendAgentMessageResponse
err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error {
var err error
resp, err = executeRPC(ctx, c.client.SendAgentMessage, req, settings.GRPC, c.logger, "SendAgentMessage")
return err
}, opts...)
if err != nil {
return nil, err
}
return resp, nil
}