Class NostrVStoreEventStore

java.lang.Object

org.ngengine.nostr4j.store.NostrVStoreEventStore

All Implemented Interfaces:

NostrEventStore

public final class NostrVStoreEventStore
extends Object
implements NostrEventStore

Saves events in a VStore and keeps recent reads in memory.

Nested Class Summary

Nested classes/interfaces inherited from interface NostrEventStore

NostrEventStore.Entry

Field Summary

Fields inherited from interface NostrEventStore

ORDER

Constructor Summary

Constructors

Constructor	Description
NostrVStoreEventStore(org.ngengine.platform.VStore store, int memoryCapacity)

Method Summary

Modifier and Type	Method	Description
org.ngengine.platform.AsyncTask<Iterator<org.ngengine.nostr4j.store.NostrEventIndex.Metadata>>	candidates(NostrFilter filter, Predicate<org.ngengine.nostr4j.store.NostrEventIndex.Metadata> eligible)	Returns filter candidates from newest to oldest.
org.ngengine.platform.AsyncTask<Void>	clear()	Removes events without deleting metadata or unrelated files.
org.ngengine.platform.AsyncTask<Void>	discardEntry(String id)	Removes an event when its contents are not needed.
org.ngengine.platform.AsyncTask<List<String>>	entryIds()
org.ngengine.platform.AsyncTask<List<org.ngengine.nostr4j.store.NostrEventIndex.Metadata>>	maintenanceBatch(String after, int count)	Returns at most count metadata entries after the previous ID, wrapping at the end.
org.ngengine.platform.AsyncTask<NostrEventStore.Entry>	readEntry(String id)
org.ngengine.platform.AsyncTask<byte[]>	readMetadata(String name)
org.ngengine.platform.AsyncTask<NostrEventStore.Entry>	removeEntry(String id)
org.ngengine.platform.AsyncTask<Void>	writeEntry(String id, NostrEventStore.Entry entry)	Saves a new event.
org.ngengine.platform.AsyncTask<Void>	writeMetadata(String name, byte[] value)

Methods inherited from class Object

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

Methods inherited from interface NostrEventStore

addEvent, get, getEvents, getEvents, query, size

Constructor Details

NostrVStoreEventStore

public NostrVStoreEventStore(org.ngengine.platform.VStore store,
 int memoryCapacity)

Method Details

readEntry

public org.ngengine.platform.AsyncTask<NostrEventStore.Entry> readEntry(String id)

Specified by:

readEntry in interface NostrEventStore

writeEntry

public org.ngengine.platform.AsyncTask<Void> writeEntry(String id,
 NostrEventStore.Entry entry)

Description copied from interface: NostrEventStore

Saves a new event. Duplicate IDs keep their original receipt time.

Specified by:

writeEntry in interface NostrEventStore

removeEntry

public org.ngengine.platform.AsyncTask<NostrEventStore.Entry> removeEntry(String id)

Specified by:

removeEntry in interface NostrEventStore

discardEntry

public org.ngengine.platform.AsyncTask<Void> discardEntry(String id)

Description copied from interface: NostrEventStore

Removes an event when its contents are not needed.

Specified by:

discardEntry in interface NostrEventStore

entryIds

public org.ngengine.platform.AsyncTask<List<String>> entryIds()

Specified by:

entryIds in interface NostrEventStore

clear

public org.ngengine.platform.AsyncTask<Void> clear()

Description copied from interface: NostrEventStore

Removes events without deleting metadata or unrelated files.

Specified by:

clear in interface NostrEventStore

candidates

public org.ngengine.platform.AsyncTask<Iterator<org.ngengine.nostr4j.store.NostrEventIndex.Metadata>> candidates(NostrFilter filter,
 Predicate<org.ngengine.nostr4j.store.NostrEventIndex.Metadata> eligible)

Description copied from interface: NostrEventStore

Returns filter candidates from newest to oldest.

Specified by:

candidates in interface NostrEventStore

maintenanceBatch

public org.ngengine.platform.AsyncTask<List<org.ngengine.nostr4j.store.NostrEventIndex.Metadata>> maintenanceBatch(String after,
 int count)

Description copied from interface: NostrEventStore

Returns at most count metadata entries after the previous ID, wrapping at the end.

Specified by:

maintenanceBatch in interface NostrEventStore

readMetadata

public org.ngengine.platform.AsyncTask<byte[]> readMetadata(String name)

Specified by:

readMetadata in interface NostrEventStore

writeMetadata

public org.ngengine.platform.AsyncTask<Void> writeMetadata(String name,
 byte[] value)

Specified by:

writeMetadata in interface NostrEventStore