1. <?php
  3. /**
  4. * Validates configuration for task queues used in batch processing.
  5. *
  6. * @param array $config An array containing the configuration settings.
  7. * Expected keys: 'queue_name', 'worker_count', 'redis_host', 'redis_port', 'redis_password', 'batch_size', 'max_retries'.
  8. * @return array|string Returns an array of validation errors if invalid, or an empty array if valid.
  9. */
  10. function validateTaskQueueConfig(array $config): array
  11. {
  12. $errors = [];
  14. // Validate required parameters
  15. if (!isset($config['queue_name']) || empty($config['queue_name'])) {
  16. $errors[] = 'Queue name is required.';
  17. }
  19. if (!isset($config['worker_count']) || !is_numeric($config['worker_count']) || $config['worker_count'] <= 0) {
  20. $errors[] = 'Worker count must be a positive integer.';
  21. }
  23. if (!isset($config['redis_host']) || empty($config['redis_host'])) {
  24. $errors[] = 'Redis host is required.';
  25. }
  27. if (!isset($config['redis_port']) || !is_numeric($config['redis_port']) || $config['redis_port'] < 1 || $config['redis_port'] > 65535) {
  28. $errors[] = 'Redis port must be a number between 1 and 65535.';
  29. }
  31. if (isset($config['redis_password']) && !empty($config['redis_password'])) {
  32. //Password validation can be expanded, but for now, just check if not empty
  33. }
  35. if (!isset($config['batch_size']) || !is_numeric($config['batch_size']) || $config['batch_size'] <= 0) {
  36. $errors[] = 'Batch size must be a positive integer.';
  37. }
  39. if (!isset($config['max_retries']) || !is_numeric($config['max_retries']) || $config['max_retries'] <= 0) {
  40. $errors[] = 'Max retries must be a positive integer.';
  41. }
  43. //Edge case: Validate batch_size against queue_name (e.g., prevent excessively large batches for short queue names)
  44. if (strlen($config['queue_name']) < 5 && $config['batch_size'] > 1000) {
  45. $errors[] = 'Batch size is too large for the queue name. Consider reducing batch size.';
  46. }
  48. //Edge case: Validate max_retries to be smaller than batch size (to avoid infinite loops)
  49. if ($config['max_retries'] >= $config['batch_size']) {
  50. $errors[] = 'Max retries should be less than batch size to prevent infinite retries.';
  51. }
  54. return $errors;
  55. }
  57. //Example usage
  58. /*
  59. $config = [
  60. 'queue_name' => 'my_queue',
  61. 'worker_count' => 2,
  62. 'redis_host' => 'localhost',
  63. 'redis_port' => 6379,
  64. 'redis_password' => '',
  65. 'batch_size' => 10,
  66. 'max_retries' => 3,
  67. ];
  69. $validationErrors = validateTaskQueueConfig($config);
  71. if (!empty($validationErrors)) {
  72. echo 'Validation Errors: ' . implode(', ', $validationErrors) . "\n";
  73. } else {
  74. echo 'Configuration is valid.\n';
  75. }
  76. */
  78. ?>

Add your comment