ILoadBalancer.php

Go to the documentation of this file.

<?php
namespace Wikimedia\Rdbms;
 
interface ILoadBalancer {
    public const DB_REPLICA = -1;
    public const DB_PRIMARY = -2;
 
    // phpcs:disable MediaWiki.Usage.DeprecatedConstantUsage.DB_MASTER
    public const DB_MASTER = self::DB_PRIMARY;
    // phpcs:enable MediaWiki.Usage.DeprecatedConstantUsage.DB_MASTER
 
    public const DOMAIN_ANY = '';
    public const GROUP_GENERIC = '';
 
    public const CONN_UNTRACKED_GAUGE = 1;
    public const CONN_TRX_AUTOCOMMIT = 2;
    public const CONN_SILENCE_ERRORS = 4;
    public const CONN_INTENT_WRITABLE = 8;
 
    public function getClusterName(): string;
 
    public function getLocalDomainID(): string;
 
    public function resolveDomainID( $domain ): string;
 
    public function redefineLocalDomain( $domain );
 
    public function setTempTablesOnlyMode( $value, $domain );
 
    public function getReaderIndex( $group = false );
 
    public function waitFor( DBPrimaryPos $pos );
 
    public function waitForAll( DBPrimaryPos $pos, $timeout = null );
 
    public function getAnyOpenConnection( $i, $flags = 0 );
 
    public function getConnection( $i, $groups = [], $domain = false, $flags = 0 );
 
    public function getServerConnection( $i, $domain, $flags = 0 );
 
    public function reuseConnection( IDatabase $conn );
 
    public function getConnectionRef( $i, $groups = [], $domain = false, $flags = 0 ): IDatabase;
 
    public function getConnectionInternal( $i, $groups = [], $domain = false, $flags = 0 ): IDatabase;
 
    public function getMaintenanceConnectionRef( $i, $groups = [], $domain = false, $flags = 0 ): DBConnRef;
 
    public function getWriterIndex();
 
    public function getServerCount();
 
    public function hasReplicaServers();
 
    public function hasStreamingReplicaServers();
 
    public function getServerName( $i ): string;
 
    public function getServerInfo( $i );
 
    public function getServerType( $i );
 
    public function getServerAttributes( $i );
 
    public function getPrimaryPos();
 
    public function getReplicaResumePos();
 
    public function closeConnection( IDatabase $conn );
 
    public function hasPrimaryConnection();
 
    public function hasPrimaryChanges();
 
    public function explicitTrxActive();
 
    public function lastPrimaryChangeTimestamp();
 
    public function hasOrMadeRecentPrimaryChanges( $age = null );
 
    public function laggedReplicaUsed();
 
    public function getReadOnlyReason( $domain = false );
 
    public function pingAll();
 
    public function getMaxLag();
 
    public function getLagTimes();
 
    public function waitForPrimaryPos( IDatabase $conn );
 
    public function setTransactionListener( $name, callable $callback = null );
 
    public function setTableAliases( array $aliases );
 
    public function setIndexAliases( array $aliases );
 
    public function setDomainAliases( array $aliases );
}