Package | Description |
---|---|
org.infinispan.persistence.async | |
org.infinispan.persistence.spi |
The Persistence SPI.
|
org.infinispan.persistence.support |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
AsyncNonBlockingStore.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
AsyncNonBlockingStore.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
Modifier and Type | Method and Description |
---|---|
default CompletionStage<Void> |
NonBlockingStore.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
Writes and removes the entries provided by the Publishers into the store.
|
default CompletionStage<Void> |
NonBlockingStore.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
Writes and removes the entries provided by the Publishers into the store.
|
default CompletionStage<Void> |
NonBlockingStore.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
Write remove and put modifications to the store in the prepare phase, which should not yet persisted until the
same transaction is committed via
NonBlockingStore.commit(Transaction) or they are discarded if the transaction is rolled back via
NonBlockingStore.rollback(Transaction) . |
default CompletionStage<Void> |
NonBlockingStore.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
Write remove and put modifications to the store in the prepare phase, which should not yet persisted until the
same transaction is committed via
NonBlockingStore.commit(Transaction) or they are discarded if the transaction is rolled back via
NonBlockingStore.rollback(Transaction) . |
Modifier and Type | Class and Description |
---|---|
class |
SegmentPublisherWrapper<Type> |
class |
SingleSegmentPublisher<E> |
Modifier and Type | Method and Description |
---|---|
static <E> NonBlockingStore.SegmentedPublisher<E> |
SingleSegmentPublisher.singleSegment(int segment,
org.reactivestreams.Publisher<? extends E> publisher) |
static <E> NonBlockingStore.SegmentedPublisher<E> |
SingleSegmentPublisher.singleSegment(org.reactivestreams.Publisher<? extends E> publisher) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
DelegatingNonBlockingStore.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
DelegatingNonBlockingStore.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
NonBlockingStoreAdapter.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
NonBlockingStoreAdapter.batch(int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
DelegatingNonBlockingStore.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
DelegatingNonBlockingStore.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
NonBlockingStoreAdapter.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
NonBlockingStoreAdapter.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.