ILoadMonitor.php 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. <?php
  2. /**
  3. * Database load monitoring interface
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation; either version 2 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License along
  16. * with this program; if not, write to the Free Software Foundation, Inc.,
  17. * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
  18. * http://www.gnu.org/copyleft/gpl.html
  19. *
  20. * @file
  21. * @ingroup Database
  22. */
  23. namespace Wikimedia\Rdbms;
  24. use Psr\Log\LoggerAwareInterface;
  25. use BagOStuff;
  26. use WANObjectCache;
  27. /**
  28. * An interface for database load monitoring
  29. *
  30. * @ingroup Database
  31. */
  32. interface ILoadMonitor extends LoggerAwareInterface {
  33. /**
  34. * Construct a new LoadMonitor with a given LoadBalancer parent
  35. *
  36. * @param ILoadBalancer $lb LoadBalancer this instance serves
  37. * @param BagOStuff $sCache Local server memory cache
  38. * @param WANObjectCache $wCache Local cluster memory cache
  39. * @param array $options Options map
  40. */
  41. public function __construct(
  42. ILoadBalancer $lb, BagOStuff $sCache, WANObjectCache $wCache, array $options = []
  43. );
  44. /**
  45. * Perform load ratio adjustment before deciding which server to use
  46. *
  47. * @param int[] &$weightByServer Map of (server index => float weight)
  48. * @param string|bool $domain
  49. */
  50. public function scaleLoads( array &$weightByServer, $domain );
  51. /**
  52. * Get an estimate of replication lag (in seconds) for each server
  53. *
  54. * Values may be "false" if replication is too broken to estimate
  55. *
  56. * @param int[] $serverIndexes
  57. * @param string $domain
  58. * @return array Map of (server index => float|int|bool)
  59. */
  60. public function getLagTimes( array $serverIndexes, $domain );
  61. }