Mostly a fairly standard usage with the exception of the \Wikimedia\Rdbms\ILBFactory::getLocalDomainID call below:
$this->lbFactory->waitForReplication( [ 'domain' => $this->lbFactory->getLocalDomainID(), ] ); $loadBalancer = $this->lbFactory->getMainLB(); $db = $loadBalancer->getConnection( DB_MASTER );