Package com.evolveum.midpoint.schema.util.task

Class TaskWorkStateUtil

java.lang.Object

com.evolveum.midpoint.schema.util.task.TaskWorkStateUtil

public class TaskWorkStateUtil
extends Object

Utility methods related to task work state and work state management.

Constructor Summary

Constructors

Constructor	Description
TaskWorkStateUtil()

Method Summary

Modifier and Type	Method	Description
static WorkBucketType	findBucketByNumber(List<WorkBucketType> buckets, int sequentialNumber)
static int	getCompleteBucketsNumber(TaskType taskType)
static int	getCompleteBucketsNumber(TaskWorkStateType workState)
static @Nullable Integer	getExpectedBuckets(TaskType task)
static @NotNull TaskKindType	getKind(TaskType task)
static @Nullable WorkBucketType	getLastBucket(List<WorkBucketType> buckets)
static @Nullable Integer	getPartitionSequentialNumber(@NotNull TaskType taskType)
static AbstractWorkSegmentationType	getWorkSegmentationConfiguration(TaskWorkManagementType cfg)
static boolean	hasLimitations(WorkBucketType bucket)
static boolean	isAllWorkComplete(TaskType task)
static boolean	isCoordinator(TaskType task)
static boolean	isManageableTreeRoot(TaskType taskType)
static boolean	isPartitionedMaster(TaskType task)
static boolean	isWorker(TaskType task)
static boolean	isWorkStateHolder(TaskType taskType)
static void	sortBucketsBySequentialNumber(List<WorkBucketType> buckets)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskWorkStateUtil

public TaskWorkStateUtil()

Method Detail

findBucketByNumber

public static WorkBucketType findBucketByNumber(List<WorkBucketType> buckets,
                                                int sequentialNumber)

sortBucketsBySequentialNumber

public static void sortBucketsBySequentialNumber(List<WorkBucketType> buckets)

getWorkSegmentationConfiguration

public static AbstractWorkSegmentationType getWorkSegmentationConfiguration(TaskWorkManagementType cfg)

getCompleteBucketsNumber

public static int getCompleteBucketsNumber(TaskType taskType)

getCompleteBucketsNumber

public static int getCompleteBucketsNumber(TaskWorkStateType workState)

getExpectedBuckets

@Nullable
public static @Nullable Integer getExpectedBuckets(TaskType task)

getLastBucket

@Nullable
public static @Nullable WorkBucketType getLastBucket(List<WorkBucketType> buckets)

hasLimitations

public static boolean hasLimitations(WorkBucketType bucket)

getPartitionSequentialNumber

@Nullable
public static @Nullable Integer getPartitionSequentialNumber(@NotNull
                                                             @NotNull TaskType taskType)

isCoordinator

public static boolean isCoordinator(TaskType task)

Returns:

True if the task is a coordinator (in the bucketing sense).

isWorker

public static boolean isWorker(TaskType task)

Returns:

True if the task is a worker (in the bucketing sense).

isPartitionedMaster

public static boolean isPartitionedMaster(TaskType task)

Returns:

True if the task is a partitioned master.

getKind

@NotNull
public static @NotNull TaskKindType getKind(TaskType task)

Returns:

Task kind: standalone, coordinator, worker, partitioned master.

isManageableTreeRoot

public static boolean isManageableTreeRoot(TaskType taskType)

isWorkStateHolder

public static boolean isWorkStateHolder(TaskType taskType)

isAllWorkComplete

public static boolean isAllWorkComplete(TaskType task)