Wikibase
MediaWiki Wikibase extension
Loading...
Searching...
No Matches
Wikibase\Repo\ChangeModification\DispatchChangesJob Class Reference
+ Inheritance diagram for Wikibase\Repo\ChangeModification\DispatchChangesJob:
+ Collaboration diagram for Wikibase\Repo\ChangeModification\DispatchChangesJob:

Public Member Functions

 __construct (SubscriptionLookup $subscriptionLookup, EntityChangeLookup $changeLookup, EntityIdParser $entityIdParser, JobQueueGroupFactory $jobQueueGroupFactory, ChangeStore $changeStore, LoggerInterface $logger, StatsdDataFactoryInterface $stats, array $params)
 
 run ()
 

Static Public Member Functions

static makeJobSpecification (string $entityIdSerialization)
 
static newFromGlobalState ( $unused, array $params)
 

Private Member Functions

 logUnsubscribedWikisWithSitelinkChanges ( $dispatchingClientSites, $subscribedClientSites)
 
 getWikiIdsWithChangedSitelinks (array $changes)
 
 deleteChangeRows (array $changes)
 
 filterClientWikis (array $allClientWikis, array $subscribedClientSites, array $wikisWithSitelinkChanges)
 
 getClientWikis (SettingsArray $repoSettings)
 
 getClientJobSpecification (array $changes)
 

Private Attributes

const ENTITY_ID_KEY = 'entityId'
 
 $entityIdSerialization
 
 $subscriptionLookup
 
 $entityIdParser
 
 $jobQueueGroupFactory
 
 $changeLookup
 
 $changeStore
 
 $logger
 
 $stats
 

Detailed Description

Constructor & Destructor Documentation

◆ __construct()

Wikibase\Repo\ChangeModification\DispatchChangesJob::__construct ( SubscriptionLookup $subscriptionLookup,
EntityChangeLookup $changeLookup,
EntityIdParser $entityIdParser,
JobQueueGroupFactory $jobQueueGroupFactory,
ChangeStore $changeStore,
LoggerInterface $logger,
StatsdDataFactoryInterface $stats,
array $params )

Member Function Documentation

◆ deleteChangeRows()

Wikibase\Repo\ChangeModification\DispatchChangesJob::deleteChangeRows ( array $changes)
private
Parameters
Change[]$changes

◆ filterClientWikis()

Wikibase\Repo\ChangeModification\DispatchChangesJob::filterClientWikis ( array $allClientWikis,
array $subscribedClientSites,
array $wikisWithSitelinkChanges )
private
Parameters
string[]$allClientWikisas returned by getClientWikis().
string[]$subscribedClientSitessites subscribed to this entityId
string[]$wikisWithSitelinkChangessites whose sitelink was changed
Returns
string[] A mapping of client wiki site IDs to logical database names.

◆ getClientJobSpecification()

Wikibase\Repo\ChangeModification\DispatchChangesJob::getClientJobSpecification ( array $changes)
private
Parameters
EntityChange[]$changes

◆ getClientWikis()

Wikibase\Repo\ChangeModification\DispatchChangesJob::getClientWikis ( SettingsArray $repoSettings)
private
Returns
string[] A mapping of client wiki site IDs to logical database names.

◆ getWikiIdsWithChangedSitelinks()

Wikibase\Repo\ChangeModification\DispatchChangesJob::getWikiIdsWithChangedSitelinks ( array $changes)
private
Returns
string[]

◆ logUnsubscribedWikisWithSitelinkChanges()

Wikibase\Repo\ChangeModification\DispatchChangesJob::logUnsubscribedWikisWithSitelinkChanges ( $dispatchingClientSites,
$subscribedClientSites )
private

◆ makeJobSpecification()

static Wikibase\Repo\ChangeModification\DispatchChangesJob::makeJobSpecification ( string $entityIdSerialization)
static

◆ newFromGlobalState()

static Wikibase\Repo\ChangeModification\DispatchChangesJob::newFromGlobalState ( $unused,
array $params )
static

◆ run()

Wikibase\Repo\ChangeModification\DispatchChangesJob::run ( )

Member Data Documentation

◆ $changeLookup

Wikibase\Repo\ChangeModification\DispatchChangesJob::$changeLookup
private

◆ $changeStore

Wikibase\Repo\ChangeModification\DispatchChangesJob::$changeStore
private

◆ $entityIdParser

Wikibase\Repo\ChangeModification\DispatchChangesJob::$entityIdParser
private

◆ $entityIdSerialization

Wikibase\Repo\ChangeModification\DispatchChangesJob::$entityIdSerialization
private

◆ $jobQueueGroupFactory

Wikibase\Repo\ChangeModification\DispatchChangesJob::$jobQueueGroupFactory
private

◆ $logger

Wikibase\Repo\ChangeModification\DispatchChangesJob::$logger
private

◆ $stats

Wikibase\Repo\ChangeModification\DispatchChangesJob::$stats
private

◆ $subscriptionLookup

Wikibase\Repo\ChangeModification\DispatchChangesJob::$subscriptionLookup
private

◆ ENTITY_ID_KEY

const Wikibase\Repo\ChangeModification\DispatchChangesJob::ENTITY_ID_KEY = 'entityId'
private

The documentation for this class was generated from the following file: