public class GrouperProvisioningLogicIncremental extends Object
Constructor and Description |
---|
GrouperProvisioningLogicIncremental() |
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
|
public boolean provisioningMessageQueueHasMessages(String provisionerName)
provisionerName
- public GrouperProvisioner getGrouperProvisioner()
public void setGrouperProvisioner(GrouperProvisioner grouperProvisioner1)
grouperProvisioner1
- public void acknowledgeMessagesProcessed()
esbEventContainersToProcess
- gcGrouperSync
- lastProcessedSequenceNumber
- public void filterByGroupNotProvisionable()
esbEventContainersToProcess
- grouperProvisioningProcessingResult
- public void filterByProvisioningFullSync()
esbEventContainers
- gcGrouperSync
- public void filterByProvisioningFullSync(GrouperIncrementalDataToProcess grouperIncrementalDataToProcess, int[] skippedEventsDueToFullSync, long lastFullSyncMillis)
grouperIncrementalDataToProcess
- skippedEventsDueToFullSync
- lastFullSyncMillis
- public void filterByProvisioningFullSync(Set<GrouperIncrementalDataItem> grouperIncrementalDataItems, int[] skippedEventsDueToFullSync, long lastFullSyncMillis)
public void filterByGroupSync()
esbEventContainers
- gcGrouperSync
- public void filterByGroupSyncHelper(int[] filterByGroupSyncGroups, Map<String,ProvisioningGroupWrapper> groupUuidToProvisioningGroupWrapper, Iterator<GrouperIncrementalDataItem> iterator, GrouperIncrementalDataItem grouperIncrementalDataItem, String currentGroupId)
filterByGroupSyncGroups
- groupUuidToProvisioningGroupWrapper
- iterator
- grouperIncrementalDataItem
- currentGroupId
- public boolean incrementalCheckForAndRunFullSync()
public void incrementalCheckMessages()
public void setupIncrementalClonesOfGroupProvisioningObjects()
public void propagateProvisioningAttributes()
public void incrementalCheckChangeLog()
public void recalcEventsDuringFullSync()
esbEventContainers
- gcGrouperSync
- public void recalcEventsDuringFullSync(Set<GrouperIncrementalDataItem> grouperIncrementalDataItemsWithRecalc, Set<GrouperIncrementalDataItem> grouperIncrementalDataItemsWithoutRecalc, int[] recalcEventsDuringFullSync, long lastFullSyncStartMillis, long lastFullSyncEndMillis)
public void addErrorsToQueue()
public void filterNonRecalcActionsCapturedByRecalc()
esbEventContainers
- gcGrouperSync
- public void organizeRecalcAndNonRecalcRequestsEntities()
esbEventContainers
- gcGrouperSync
- public void organizeRecalcAndNonRecalcRequestsEntities(GrouperIncrementalDataToProcess grouperIncrementalDataToProcess, int[] organizeRecalcAndNonRecalcRequests, boolean recalc)
grouperIncrementalDataToProcess
- organizeRecalcAndNonRecalcRequests
- public void convertToGroupSync()
public void convertToFullSync()
public void recalcEventsDuringGroupSync()
esbEventContainers
- gcGrouperSync
- public void filterUnneededActions()
public void convertInconsistentEventsToRecalc()
public void copyIncrementalStateToWrappers()
public void retrieveTargetIncrementalMembershipsWithRecalcWhereGroupIsNotRecalc()
public void retrieveIncrementalTargetData()
Copyright © 2016 Internet2. All rights reserved.