Module org.yamcs.core

Package org.yamcs.yarch.rocksdb

Class RdbBucket

java.lang.Object

org.yamcs.yarch.rocksdb.RdbBucket

All Implemented Interfaces:

Bucket

public class RdbBucket
extends Object
implements Bucket

Constructor Summary

Constructors

Constructor	Description
RdbBucket(String yamcsInstance, Tablespace tablespace, int tbsIndex, Tablespace.BucketProperties bucketProps)

Method Summary

Modifier and Type	Method	Description
void	deleteObject(String objectName)
CompletableFuture<Void>	deleteObjectAsync(String objectName)
ObjectProperties	findObject(String objectName)
CompletableFuture<ObjectProperties>	findObjectAsync(String objectName)	Retrieve the object properties or null if not such an object exist
BucketLocation	getLocation()	Bucket location
String	getName()	This bucket's name
byte[]	getObject(String objectName)
CompletableFuture<byte[]>	getObjectAsync(String objectName)	Retrieve object from the bucket.
BucketProperties	getProperties()
CompletableFuture<BucketProperties>	getPropertiesAsync()
Tablespace	getTablespace()
int	getTbsIndex()
List<ObjectProperties>	listObjects(String prefix, Predicate<ObjectProperties> p)
CompletableFuture<List<ObjectProperties>>	listObjectsAsync(String prefix, Predicate<ObjectProperties> p)	retrieve objects whose name start with prefix and that match the condition Note that searching by prefix is cheap, the condition will be evaluated for all objects that match the prefix
void	putObject(String objectName, String contentType, Map<String,String> metadata, byte[] objectData)
CompletableFuture<Void>	putObjectAsync(String objectName, String contentType, Map<String,String> metadata, byte[] objectData)
void	setMaxObjects(int maxObjects)	Update the object count limit for this bucket.
void	setMaxSize(long maxSize)	Update the size limit for this bucket.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.buckets.Bucket

listObjectsAsync, listObjectsAsync, listObjectsAsync

Constructor Details

RdbBucket

public RdbBucket(String yamcsInstance,
 Tablespace tablespace,
 int tbsIndex,
 Tablespace.BucketProperties bucketProps)

Method Details

getLocation

public BucketLocation getLocation()

Description copied from interface: Bucket

Bucket location

Specified by:

getLocation in interface Bucket

getPropertiesAsync

public CompletableFuture<BucketProperties> getPropertiesAsync()

Specified by:

getPropertiesAsync in interface Bucket

getProperties

public BucketProperties getProperties()

setMaxSize

public void setMaxSize(long maxSize)
                throws IOException

Description copied from interface: Bucket

Update the size limit for this bucket.

If the specified size is smaller than the current size, the bucket will no longer accept new files.

Specified by:

setMaxSize in interface Bucket

Throws:

IOException

setMaxObjects

public void setMaxObjects(int maxObjects)
                   throws IOException

Description copied from interface: Bucket

Update the object count limit for this bucket.

If the specified count is smaller than the current count, the bucket will no longer accept new files.

Specified by:

setMaxObjects in interface Bucket

Throws:

IOException

listObjectsAsync

public CompletableFuture<List<ObjectProperties>> listObjectsAsync(String prefix,
 Predicate<ObjectProperties> p)

Description copied from interface: Bucket

retrieve objects whose name start with prefix and that match the condition Note that searching by prefix is cheap, the condition will be evaluated for all objects that match the prefix

Specified by:

listObjectsAsync in interface Bucket

p - predicate to be matched by the returned objects

Returns:

list of objects

listObjects

public List<ObjectProperties> listObjects(String prefix,
 Predicate<ObjectProperties> p)
                                   throws IOException

Throws:

IOException

putObjectAsync

public CompletableFuture<Void> putObjectAsync(String objectName,
 String contentType,
 Map<String,String> metadata,
 byte[] objectData)

Specified by:

putObjectAsync in interface Bucket

putObject

public void putObject(String objectName,
 String contentType,
 Map<String,String> metadata,
 byte[] objectData)
               throws IOException

Throws:

IOException

findObjectAsync

public CompletableFuture<ObjectProperties> findObjectAsync(String objectName)

Description copied from interface: Bucket

Retrieve the object properties or null if not such an object exist

Specified by:

findObjectAsync in interface Bucket

findObject

public ObjectProperties findObject(String objectName)
                            throws IOException

Throws:

IOException

getObjectAsync

public CompletableFuture<byte[]> getObjectAsync(String objectName)

Description copied from interface: Bucket

Retrieve object from the bucket. Returns null if object does not exist.

Specified by:

getObjectAsync in interface Bucket

getObject

public byte[] getObject(String objectName)
                 throws IOException

Throws:

IOException

deleteObjectAsync

public CompletableFuture<Void> deleteObjectAsync(String objectName)

Specified by:

deleteObjectAsync in interface Bucket

deleteObject

public void deleteObject(String objectName)
                  throws IOException

Throws:

IOException

getName

public String getName()

Description copied from interface: Bucket

This bucket's name

Specified by:

getName in interface Bucket

getTablespace

public Tablespace getTablespace()

getTbsIndex

public int getTbsIndex()