Package org.yamcs.yarch.rocksdb

Class RdbTagDb

java.lang.Object

org.yamcs.yarch.rocksdb.RdbTagDb

All Implemented Interfaces:

TagDb

public class RdbTagDb
extends Object
implements TagDb

Method Summary

Modifier and Type	Method	Description
void	close()	close the database and release resources the object is unusable after this call.
Yamcs.ArchiveTag	deleteTag(long tagTime, int tagId)	Deletes the specified tag
Yamcs.ArchiveTag	getTag(long tagTime, int tagId)	Returns a specific tag, or null if the requested tag does not exist
void	getTags(TimeInterval intv, TagReceiver receiver)	Synchonously gets tags, passing every separate one to the provided TagReceiver.
Yamcs.ArchiveTag	insertTag(Yamcs.ArchiveTag tag)	Inserts a new Tag.
Yamcs.ArchiveTag	updateTag(long tagTime, int tagId, Yamcs.ArchiveTag tag)	Updates an existing tag.

Methods inherited from class java.lang.Object

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

Method Details

getTags

public void getTags(TimeInterval intv,
 TagReceiver receiver)
             throws IOException

Synchonously gets tags, passing every separate one to the provided TagReceiver.

Specified by:

getTags in interface TagDb

Throws:

IOException

getTag

public Yamcs.ArchiveTag getTag(long tagTime,
 int tagId)
                        throws IOException

Returns a specific tag, or null if the requested tag does not exist

Specified by:

getTag in interface TagDb

Throws:

IOException

insertTag

public Yamcs.ArchiveTag insertTag(Yamcs.ArchiveTag tag)
                           throws IOException

Inserts a new Tag. No id should be specified. If it is, it will silently be overwritten, and the new tag will be returned.

Specified by:

insertTag in interface TagDb

Throws:

IOException

updateTag

public Yamcs.ArchiveTag updateTag(long tagTime,
 int tagId,
 Yamcs.ArchiveTag tag)
                           throws YamcsException,
IOException

Updates an existing tag. The tag is fetched by the specified id throws YamcsException if the tag could not be found.

Note that both tagId and oldTagStart need to be specified so that a direct lookup in the internal data structure can be made.

Specified by:

updateTag in interface TagDb

Returns:

the updated tag

Throws:

YamcsException

IOException

deleteTag

public Yamcs.ArchiveTag deleteTag(long tagTime,
 int tagId)
                           throws IOException,
YamcsException

Deletes the specified tag

Specified by:

deleteTag in interface TagDb

Throws:

YamcsException - if the id was invalid, or if the tag could not be found

IOException

close

public void close()

Description copied from interface: TagDb

close the database and release resources the object is unusable after this call.

Specified by:

close in interface TagDb