ILoadBalancer.php

Go to the documentation of this file.

<?php
namespace Wikimedia\Rdbms;
 
use Exception;
use InvalidArgumentException;
 
interface ILoadBalancer {
    const DB_REPLICA = -1;
 
    const DB_PRIMARY = -2;
    const DB_MASTER = self::DB_PRIMARY;
 
    const DOMAIN_ANY = '';
 
    const CONN_TRX_AUTOCOMMIT = 1;
    const CONN_TRX_AUTO = 1;
 
    public function __construct( array $params );
 
    public function getReaderIndex( $group = false, $domain = false );
 
    public function waitFor( $pos );
 
    public function waitForOne( $pos, $timeout = null );
 
    public function waitForAll( $pos, $timeout = null );
 
    public function getAnyOpenConnection( $i, $flags = 0 );
 
    public function getConnection( $i, $groups = [], $domain = false, $flags = 0 );
 
    public function reuseConnection( IDatabase $conn );
 
    public function getConnectionRef( $i, $groups = [], $domain = false, $flags = 0 );
 
    public function getLazyConnectionRef( $i, $groups = [], $domain = false, $flags = 0 );
 
    public function getMaintenanceConnectionRef( $db, $groups = [], $domain = false, $flags = 0 );
 
    public function openConnection( $i, $domain = false, $flags = 0 );
 
    public function getWriterIndex();
 
    public function haveIndex( $i );
 
    public function isNonZeroLoad( $i );
 
    public function getServerCount();
 
    public function getServerName( $i );
 
    public function getServerType( $i );
 
    public function getServerInfo( $i );
 
    public function getServerAttributes( $i );
 
    public function getMasterPos();
 
    public function disable();
 
    public function closeAll();
 
    public function closeConnection( IDatabase $conn );
 
    public function commitAll( $fname = __METHOD__ );
 
    public function finalizeMasterChanges();
 
    public function approveMasterChanges( array $options );
 
    public function beginMasterChanges( $fname = __METHOD__ );
 
    public function commitMasterChanges( $fname = __METHOD__ );
 
    public function runMasterPostTrxCallbacks( $type );
 
    public function rollbackMasterChanges( $fname = __METHOD__ );
 
    public function suppressTransactionEndCallbacks();
 
    public function flushReplicaSnapshots( $fname = __METHOD__ );
 
    public function hasMasterConnection();
 
    public function hasMasterChanges();
 
    public function lastMasterChangeTimestamp();
 
    public function hasOrMadeRecentMasterChanges( $age = null );
 
    public function pendingMasterChangeCallers();
 
    public function getLaggedReplicaMode( $domain = false );
 
    public function laggedReplicaUsed();
 
    public function getReadOnlyReason( $domain = false, IDatabase $conn = null );
 
    public function allowLagged( $mode = null );
 
    public function pingAll();
 
    public function forEachOpenConnection( $callback, array $params = [] );
 
    public function forEachOpenMasterConnection( $callback, array $params = [] );
 
    public function forEachOpenReplicaConnection( $callback, array $params = [] );
 
    public function getMaxLag( $domain = false );
 
    public function getLagTimes( $domain = false );
 
    public function safeGetLag( IDatabase $conn );
 
    public function safeWaitForMasterPos( IDatabase $conn, $pos = false, $timeout = 10 );
 
    public function setTransactionListener( $name, callable $callback = null );
 
    public function setDomainPrefix( $prefix );
 
    public function setTableAliases( array $aliases );
 
    public function setIndexAliases( array $aliases );
}