Package org.infinispan.persistence.sifs

Class LogAppender

java.lang.Object

org.infinispan.persistence.sifs.LogAppender

All Implemented Interfaces:

io.reactivex.rxjava3.functions.Consumer<org.infinispan.persistence.sifs.LogAppender.WriteOperation>

public class LogAppender
extends Object
implements io.reactivex.rxjava3.functions.Consumer<org.infinispan.persistence.sifs.LogAppender.WriteOperation>

Constructor Summary

Constructors

Constructor	Description
LogAppender(NonBlockingManager nonBlockingManager, org.infinispan.persistence.sifs.Index index, TemporaryTable temporaryTable, org.infinispan.persistence.sifs.Compactor compactor, FileProvider fileProvider, boolean syncWrites, int maxFileSize)

Method Summary

Modifier and Type	Method	Description
void	accept(org.infinispan.persistence.sifs.LogAppender.WriteOperation writeOperation)
CompletionStage<Void>	clearAndPause()	Clears all the log entries returning a stage when the completion is done.
void	complete(io.reactivex.rxjava3.functions.Consumer<LogAppender> consumer)
CompletionStage<Boolean>	deleteRequest(int segment, Object key, ByteBuffer serializedKey)
CompletionStage<Void>	pause()
CompletionStage<Void>	resume()
void	setSeqId(long seqId)
void	start(Executor executor)
void	stop()
<K, V> CompletionStage<Void>	storeRequest(int segment, MarshallableEntry<K,V> entry)

Methods inherited from class java.lang.Object

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

Constructor Details

LogAppender

public LogAppender(NonBlockingManager nonBlockingManager,
 org.infinispan.persistence.sifs.Index index,
 TemporaryTable temporaryTable,
 org.infinispan.persistence.sifs.Compactor compactor,
 FileProvider fileProvider,
 boolean syncWrites,
 int maxFileSize)

Method Details

start

public void start(Executor executor)

stop

public void stop()

clearAndPause

public CompletionStage<Void> clearAndPause()

Clears all the log entries returning a stage when the completion is done. Note that after the clear is complete this appender will also be paused. To resume it callers must ensure they invoke resume() to restart the appender

Returns:

a stage that when complete the log will be cleared and this appender is paused

pause

public CompletionStage<Void> pause()

resume

public CompletionStage<Void> resume()

storeRequest

public <K,
V> CompletionStage<Void> storeRequest(int segment,
 MarshallableEntry<K,V> entry)

deleteRequest

public CompletionStage<Boolean> deleteRequest(int segment,
 Object key,
 ByteBuffer serializedKey)

accept

public void accept(org.infinispan.persistence.sifs.LogAppender.WriteOperation writeOperation)

Specified by:

accept in interface io.reactivex.rxjava3.functions.Consumer<org.infinispan.persistence.sifs.LogAppender.WriteOperation>

complete

public void complete(io.reactivex.rxjava3.functions.Consumer<LogAppender> consumer)
              throws Throwable

Throws:

Throwable

setSeqId

public void setSeqId(long seqId)