net.bluemind.core.backup.continuous.impl

Class BackupStore<T>

java.lang.Object

net.bluemind.core.backup.continuous.impl.BackupStore<T>

All Implemented Interfaces:

IBackupStore<T>

public class BackupStore<T>
extends java.lang.Object
implements IBackupStore<T>

Constructor Summary

Constructors

Constructor and Description
BackupStore(TopicPublisher publisher, ITopicStore.TopicDescriptor descriptor, TopicSerializer<RecordKey,ItemValue<T>> serializer)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	delete(ItemValue<T> data)
java.util.concurrent.CompletableFuture<java.lang.Void>	store(ItemValue<T> data)
java.util.concurrent.CompletableFuture<java.lang.Void>	storeRaw(java.lang.String partitionKey, byte[] key, byte[] raw)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

BackupStore

public BackupStore(TopicPublisher publisher,
                   ITopicStore.TopicDescriptor descriptor,
                   TopicSerializer<RecordKey,ItemValue<T>> serializer)

Method Detail

storeRaw

public java.util.concurrent.CompletableFuture<java.lang.Void> storeRaw(java.lang.String partitionKey,
                                                                       byte[] key,
                                                                       byte[] raw)

Specified by:

storeRaw in interface IBackupStore<T>

store

public java.util.concurrent.CompletableFuture<java.lang.Void> store(ItemValue<T> data)

Specified by:

store in interface IBackupStore<T>

delete

public java.util.concurrent.CompletableFuture<java.lang.Void> delete(ItemValue<T> data)

Specified by:

delete in interface IBackupStore<T>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object