Uses of Class
org.infinispan.reactive.publisher.impl.DeliveryGuarantee

Packages that use DeliveryGuarantee

Package	Description
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.reactive.publisher.impl
org.infinispan.reactive.publisher.impl.commands.batch
org.infinispan.reactive.publisher.impl.commands.reduction

Uses of DeliveryGuarantee in org.infinispan.commands

Methods in org.infinispan.commands with parameters of type DeliveryGuarantee

Modifier and Type	Method and Description
<K,V,R> ReductionPublisherRequestCommand<K>	CommandsFactory.buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<K,V,R> ReductionPublisherRequestCommand<K>	CommandsFactoryImpl.buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<K,I,R> InitialPublisherCommand<K,I,R>	CommandsFactory.buildInitialPublisherCommand(String requestId, DeliveryGuarantee deliveryGuarantee, int batchSize, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, boolean trackKeys, Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)
<K,I,R> InitialPublisherCommand<K,I,R>	CommandsFactoryImpl.buildInitialPublisherCommand(String requestId, DeliveryGuarantee deliveryGuarantee, int batchSize, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, boolean trackKeys, Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)
<K,R> ReductionPublisherRequestCommand<K>	CommandsFactory.buildKeyReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<K,R> ReductionPublisherRequestCommand<K>	CommandsFactoryImpl.buildKeyReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Uses of DeliveryGuarantee in org.infinispan.reactive.publisher.impl

Methods in org.infinispan.reactive.publisher.impl that return DeliveryGuarantee

Modifier and Type	Method and Description
static DeliveryGuarantee	DeliveryGuarantee.valueOf(int index)
static DeliveryGuarantee	DeliveryGuarantee.valueOf(String name) Returns the enum constant of this type with the specified name.
static DeliveryGuarantee[]	DeliveryGuarantee.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.infinispan.reactive.publisher.impl with parameters of type DeliveryGuarantee

Modifier and Type	Method and Description
<R> SegmentCompletionPublisher<R>	ClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer) Performs the given transformer on data in the cache, resulting in multiple values.
<R> SegmentCompletionPublisher<R>	ClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentCompletionPublisher<R>	LocalClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentCompletionPublisher<R>	PartitionAwareClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentAwarePublisher<R>	LocalPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer) Performs the given transformer on data in the cache that is local, resulting in a stream of values of possibly varying size.
<R> SegmentAwarePublisher<R>	LocalPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	ClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) Performs the given transformer and finalizer on data in the cache, resulting in a single value.
<R> CompletionStage<R>	ClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	LocalClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	PartitionAwareClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) Performs the given transformer and finalizer on data in the cache that is local, resulting in a single value.
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> collator, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> SegmentCompletionPublisher<R>	ClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer) Same as ClusterPublisherManager.entryPublisher(IntSet, Set, InvocationContext, boolean, DeliveryGuarantee, int, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> SegmentCompletionPublisher<R>	ClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentCompletionPublisher<R>	LocalClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentCompletionPublisher<R>	PartitionAwareClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentAwarePublisher<R>	LocalPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer) Same as LocalPublisherManager.entryPublisher(IntSet, Set, Set, boolean, DeliveryGuarantee, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> SegmentAwarePublisher<R>	LocalPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	ClusterPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) Same as ClusterPublisherManager.entryReduction(boolean, IntSet, Set, InvocationContext, boolean, DeliveryGuarantee, Function, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> CompletionStage<R>	ClusterPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	LocalClusterPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	PartitionAwareClusterPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) Same as LocalPublisherManager.entryReduction(boolean, IntSet, Set, Set, boolean, DeliveryGuarantee, Function, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> collator, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Uses of DeliveryGuarantee in org.infinispan.reactive.publisher.impl.commands.batch

Methods in org.infinispan.reactive.publisher.impl.commands.batch that return DeliveryGuarantee

Modifier and Type	Method and Description
DeliveryGuarantee	InitialPublisherCommand.getDeliveryGuarantee()

Constructors in org.infinispan.reactive.publisher.impl.commands.batch with parameters of type DeliveryGuarantee

Constructor and Description
InitialPublisherCommand(ByteString cacheName, String requestId, DeliveryGuarantee deliveryGuarantee, int batchSize, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, boolean trackKeys, Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)

Uses of DeliveryGuarantee in org.infinispan.reactive.publisher.impl.commands.reduction

Constructors in org.infinispan.reactive.publisher.impl.commands.reduction with parameters of type DeliveryGuarantee

Constructor and Description
ReductionPublisherRequestCommand(ByteString cacheName, boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Function transformer, Function finalizer)