Package-level declarations
Types
Link copied to clipboard
Policy for routing entities in a fork node (one-to-many routing). Determines which destination channel receives each entity.
Link copied to clipboard
Adapter that wraps a GenericPolicy to implement the ForkPolicy interface. Allows generic policies to be used for fork node routing.
Link copied to clipboard
class LeastFullForkPolicy<T>(tags: Iterable<OutputTag<Container<*>>> = generateSequence { newDynamicOutputTag { it.walkDownstream().filterIsInstance<Container<*>>().first() } }
.asIterable()) : ForkPolicy<T>
Fork policy that routes each entity to the destination with the least occupancy. Helps balance load across multiple branches.
Link copied to clipboard
class MostFullJoinPolicy<T>(tags: Iterable<InputTag<Container<*>>> = generateSequence { newDynamicInputTag { it.walkUpstream().filterIsInstance<Container<*>>().first() } }
.asIterable()) : JoinPolicy<T>
Join policy that pulls from the source with the highest occupancy. Helps balance load by pulling from the busiest source.