ActivityProgressInformation |
ActivityProgressInformation.find(ActivityPath activityPath) |
|
static @Nullable ActivityStateOverviewType |
ActivityStateOverviewUtil.findEntry(@NotNull ActivityStateOverviewType current,
@NotNull ActivityPath path) |
|
static @NotNull ActivityStateOverviewType |
ActivityStateOverviewUtil.findOrCreateEntry(@NotNull ActivityStateOverviewType current,
@NotNull ActivityPath path) |
|
static @NotNull ActivityPerformanceInformation |
ActivityPerformanceInformation.forCoordinator(@NotNull ActivityPath path,
@NotNull Collection<ActivityStateType> workerStates) |
|
static @NotNull ActivityPerformanceInformation |
ActivityPerformanceInformation.forRegularActivity(@NotNull ActivityPath path,
@Nullable ActivityItemProcessingStatisticsType itemStats,
@Nullable ActivityProgressType activityProgress) |
|
static @NotNull ActivityPerformanceInformation |
ActivityPerformanceInformation.forRegularActivity(@NotNull ActivityPath path,
@Nullable ActivityStateType state) |
|
static @NotNull ActivityProgressInformation |
ActivityProgressInformationBuilder.fromTask(@NotNull TaskType task,
@NotNull ActivityPath activityPath,
@NotNull TaskResolver resolver,
@NotNull ActivityProgressInformationBuilder.InformationSource informationSource) |
|
static ActivityStateType |
ActivityStateUtil.getActivityState(@NotNull TaskType task,
@NotNull ActivityPath activityPath) |
Finds a state of an activity, given the activity path.
|
static ActivityStateType |
ActivityStateUtil.getActivityState(@Nullable TaskActivityStateType taskState,
@NotNull ActivityPath activityPath) |
Finds a state of an activity, given the activity path.
|
static @NotNull ActivityStateType |
ActivityStateUtil.getActivityStateRequired(@NotNull TaskActivityStateType taskState,
@NotNull ActivityPath activityPath) |
Finds a state of an activity, given the activity path.
|
static @NotNull List<WorkBucketType> |
BucketingUtil.getBuckets(@NotNull TaskActivityStateType taskState,
@NotNull ActivityPath activityPath) |
|
static int |
ActivityProgressUtil.getCurrentErrors(TaskType localTask,
ActivityPath activityPath) |
|
static int |
ActivityProgressUtil.getCurrentProgress(TaskType localTask,
ActivityPath activityPath) |
|
static @NotNull ItemPath |
ActivityStateUtil.getStateItemPath(@NotNull TaskActivityStateType workState,
@NotNull ActivityPath activityPath) |
Determines state item path for a given activity path.
|
static @NotNull List<TaskType> |
ActivityTreeUtil.getSubtasksForPath(TaskType task,
ActivityPath activityPath,
TaskResolver taskResolver) |
|
static @Nullable Object |
ActivityStateUtil.getSyncTokenRealValue(@NotNull TaskType task,
@NotNull ActivityPath path) |
|
static boolean |
BucketingUtil.isInScavengingPhase(TaskActivityStateType taskState,
ActivityPath activityPath) |
|
static boolean |
ActivityStateUtil.isLocal(@NotNull ActivityPath activityPath,
@NotNull TaskActivityStateType taskActivityState) |
|
static boolean |
BucketingUtil.isScavenger(TaskActivityStateType taskState,
ActivityPath activityPath) |
|
static ActivityPerformanceInformation |
ActivityPerformanceInformation.notApplicable(@NotNull ActivityPath path) |
|
void |
ActivityTreeUtil.ActivityStateProcessor.process(@NotNull ActivityPath path,
@Nullable ActivityStateType state,
@Nullable List<ActivityStateType> workerStates,
@NotNull TaskType task) |
Called when relevant state is found.
|
void |
ActivityTreeUtil.LocalActivityStateProcessor.process(@NotNull ActivityPath path,
@NotNull ActivityStateType state) |
|
boolean |
ActivityPath.startsWith(ActivityPath otherPath) |
|
X |
ActivityTreeUtil.ActivityStateTransformer.transform(@NotNull ActivityPath path,
@Nullable ActivityStateType state,
@Nullable List<ActivityStateType> workerStates,
@NotNull TaskType task) |
Worker states are present in the case of distributed coordinator-workers scenario.
|
X |
ActivityTreeUtil.LocalActivityStateTransformer.transform(@NotNull ActivityPath path,
@NotNull ActivityStateType state) |
|