func()

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
}