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

Copyright

GPL-2.0-or-later

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[]	$allClientWikis	as returned by getClientWikis().
string[]	$subscribedClientSites	sites subscribed to this entityId
string[]	$wikisWithSitelinkChanges	sites 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:

• repo/includes/ChangeModification/DispatchChangesJob.php