edu.internet2.middleware.grouper.app.provisioning

Class GrouperProvisioningLogicIncremental

java.lang.Object

edu.internet2.middleware.grouper.app.provisioning.GrouperProvisioningLogicIncremental

public class GrouperProvisioningLogicIncremental
extends Object

Constructor Summary

Constructors

Constructor and Description
GrouperProvisioningLogicIncremental()

Method Summary

Modifier and Type	Method and Description
void	acknowledgeMessagesProcessed() acknowledgeMessages processed
void	addErrorsToQueue()
void	convertInconsistentEventsToRecalc()
void	convertToFullSync()
void	convertToGroupSync() convert many membership changes to a group sync
void	copyIncrementalStateToWrappers()
void	filterByGroupNotProvisionable() take out events that are not provisionable to this target
void	filterByGroupSync() filter events that happened after the last group sync
void	filterByGroupSyncHelper(int[] filterByGroupSyncGroups, Map<String,ProvisioningGroupWrapper> groupUuidToProvisioningGroupWrapper, Iterator<GrouperIncrementalDataItem> iterator, GrouperIncrementalDataItem grouperIncrementalDataItem, String currentGroupId)
void	filterByProvisioningFullSync() filter events that happened after the last full sync
void	filterByProvisioningFullSync(GrouperIncrementalDataToProcess grouperIncrementalDataToProcess, int[] skippedEventsDueToFullSync, long lastFullSyncMillis)
void	filterByProvisioningFullSync(Set<GrouperIncrementalDataItem> grouperIncrementalDataItems, int[] skippedEventsDueToFullSync, long lastFullSyncMillis)
void	filterNonRecalcActionsCapturedByRecalc() filter events that happened after the last full sync
void	filterUnneededActions() if a non recalc action is expected to not change the target, then ignore it
GrouperProvisioner	getGrouperProvisioner() reference back up to the provisioner
void	incrementalCheckChangeLog()
boolean	incrementalCheckForAndRunFullSync()
void	incrementalCheckMessages()
void	organizeRecalcAndNonRecalcRequestsEntities() make sure the list of groups/entities (without memberships) includes all the groups/entities for memberships
void	organizeRecalcAndNonRecalcRequestsEntities(GrouperIncrementalDataToProcess grouperIncrementalDataToProcess, int[] organizeRecalcAndNonRecalcRequests, boolean recalc) make sure the list of groups/entities (without memberships) includes all the groups/entities for memberships
void	propagateProvisioningAttributes()
boolean	provisioningMessageQueueHasMessages(String provisionerName) see if queue has messages
void	recalcEventsDuringFullSync() filter events that happened after the last full sync
void	recalcEventsDuringFullSync(Set<GrouperIncrementalDataItem> grouperIncrementalDataItemsWithRecalc, Set<GrouperIncrementalDataItem> grouperIncrementalDataItemsWithoutRecalc, int[] recalcEventsDuringFullSync, long lastFullSyncStartMillis, long lastFullSyncEndMillis)
void	recalcEventsDuringGroupSync() filter events that happened after the last group sync
void	retrieveIncrementalTargetData()
void	retrieveTargetIncrementalMembershipsWithRecalcWhereGroupIsNotRecalc()
void	setGrouperProvisioner(GrouperProvisioner grouperProvisioner1) reference back up to the provisioner
void	setupIncrementalClonesOfGroupProvisioningObjects() TODO what is this? make a deep copy of grouper provisioning data into the grouper provisioning objects to delete

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GrouperProvisioningLogicIncremental

public GrouperProvisioningLogicIncremental()

Method Detail

provisioningMessageQueueHasMessages

public boolean provisioningMessageQueueHasMessages(String provisionerName)

see if queue has messages

Parameters:

provisionerName -

Returns:

true if has messages

getGrouperProvisioner

public GrouperProvisioner getGrouperProvisioner()

reference back up to the provisioner

Returns:

the provisioner

setGrouperProvisioner

public void setGrouperProvisioner(GrouperProvisioner grouperProvisioner1)

reference back up to the provisioner

Parameters:

grouperProvisioner1 -

acknowledgeMessagesProcessed

public void acknowledgeMessagesProcessed()

acknowledgeMessages processed

Parameters:

esbEventContainersToProcess -

gcGrouperSync -

lastProcessedSequenceNumber -

filterByGroupNotProvisionable

public void filterByGroupNotProvisionable()

take out events that are not provisionable to this target

Parameters:

esbEventContainersToProcess -

grouperProvisioningProcessingResult -

filterByProvisioningFullSync

public void filterByProvisioningFullSync()

filter events that happened after the last full sync

Parameters:

esbEventContainers -

gcGrouperSync -

filterByProvisioningFullSync

public void filterByProvisioningFullSync(GrouperIncrementalDataToProcess grouperIncrementalDataToProcess,
                                         int[] skippedEventsDueToFullSync,
                                         long lastFullSyncMillis)

Parameters:

grouperIncrementalDataToProcess -

skippedEventsDueToFullSync -

lastFullSyncMillis -

filterByProvisioningFullSync

public void filterByProvisioningFullSync(Set<GrouperIncrementalDataItem> grouperIncrementalDataItems,
                                         int[] skippedEventsDueToFullSync,
                                         long lastFullSyncMillis)

filterByGroupSync

public void filterByGroupSync()

filter events that happened after the last group sync

Parameters:

esbEventContainers -

gcGrouperSync -

filterByGroupSyncHelper

public void filterByGroupSyncHelper(int[] filterByGroupSyncGroups,
                                    Map<String,ProvisioningGroupWrapper> groupUuidToProvisioningGroupWrapper,
                                    Iterator<GrouperIncrementalDataItem> iterator,
                                    GrouperIncrementalDataItem grouperIncrementalDataItem,
                                    String currentGroupId)

Parameters:

filterByGroupSyncGroups -

groupUuidToProvisioningGroupWrapper -

iterator -

grouperIncrementalDataItem -

currentGroupId -

incrementalCheckForAndRunFullSync

public boolean incrementalCheckForAndRunFullSync()

Returns:

if should continue

incrementalCheckMessages

public void incrementalCheckMessages()

setupIncrementalClonesOfGroupProvisioningObjects

public void setupIncrementalClonesOfGroupProvisioningObjects()

TODO what is this? make a deep copy of grouper provisioning data into the grouper provisioning objects to delete

propagateProvisioningAttributes

public void propagateProvisioningAttributes()

incrementalCheckChangeLog

public void incrementalCheckChangeLog()

recalcEventsDuringFullSync

public void recalcEventsDuringFullSync()

filter events that happened after the last full sync

Parameters:

esbEventContainers -

gcGrouperSync -

recalcEventsDuringFullSync

public void recalcEventsDuringFullSync(Set<GrouperIncrementalDataItem> grouperIncrementalDataItemsWithRecalc,
                                       Set<GrouperIncrementalDataItem> grouperIncrementalDataItemsWithoutRecalc,
                                       int[] recalcEventsDuringFullSync,
                                       long lastFullSyncStartMillis,
                                       long lastFullSyncEndMillis)

addErrorsToQueue

public void addErrorsToQueue()

filterNonRecalcActionsCapturedByRecalc

public void filterNonRecalcActionsCapturedByRecalc()

filter events that happened after the last full sync

Parameters:

esbEventContainers -

gcGrouperSync -

organizeRecalcAndNonRecalcRequestsEntities

public void organizeRecalcAndNonRecalcRequestsEntities()

make sure the list of groups/entities (without memberships) includes all the groups/entities for memberships

Parameters:

esbEventContainers -

gcGrouperSync -

organizeRecalcAndNonRecalcRequestsEntities

public void organizeRecalcAndNonRecalcRequestsEntities(GrouperIncrementalDataToProcess grouperIncrementalDataToProcess,
                                                       int[] organizeRecalcAndNonRecalcRequests,
                                                       boolean recalc)

make sure the list of groups/entities (without memberships) includes all the groups/entities for memberships

Parameters:

grouperIncrementalDataToProcess -

organizeRecalcAndNonRecalcRequests -

convertToGroupSync

public void convertToGroupSync()

convert many membership changes to a group sync

convertToFullSync

public void convertToFullSync()

recalcEventsDuringGroupSync

public void recalcEventsDuringGroupSync()

filter events that happened after the last group sync

Parameters:

esbEventContainers -

gcGrouperSync -

filterUnneededActions

public void filterUnneededActions()

if a non recalc action is expected to not change the target, then ignore it

convertInconsistentEventsToRecalc

public void convertInconsistentEventsToRecalc()

copyIncrementalStateToWrappers

public void copyIncrementalStateToWrappers()

retrieveTargetIncrementalMembershipsWithRecalcWhereGroupIsNotRecalc

public void retrieveTargetIncrementalMembershipsWithRecalcWhereGroupIsNotRecalc()

retrieveIncrementalTargetData

public void retrieveIncrementalTargetData()