Uses of Interface
org.infinispan.persistence.spi.NonBlockingStore.SegmentedPublisher
-
Packages that use NonBlockingStore.SegmentedPublisher Package Description org.infinispan.persistence.rocksdb RocksDB-basedAdvancedLoadWriteStore
.org.infinispan.persistence.spi The Persistence SPI. -
-
Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.rocksdb
Method parameters in org.infinispan.persistence.rocksdb with type arguments of type NonBlockingStore.SegmentedPublisher Modifier and Type Method Description CompletionStage<Void>
RocksDBStore. batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
-
Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.spi
Method parameters in org.infinispan.persistence.spi with type arguments of type NonBlockingStore.SegmentedPublisher Modifier and Type Method 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. 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 viaNonBlockingStore.commit(Transaction)
or they are discarded if the transaction is rolled back viaNonBlockingStore.rollback(Transaction)
.
-