com.artipie.asto.blocking

Class BlockingStorage

java.lang.Object

com.artipie.asto.blocking.BlockingStorage

public class BlockingStorage
extends Object

More primitive and easy to use wrapper to use Storage.

Since:

0.1

Constructor Summary

Constructors

Constructor and Description
BlockingStorage(Storage storage) Wrap a Storage in order get a blocking version of it.

Method Summary

Modifier and Type	Method and Description
void	delete(Key key) Removes value from storage.
boolean	exists(Key key) This file exists?
Collection<Key>	list(Key prefix) Return the list of keys that start with this prefix, for example "foo/bar/".
void	move(Key source, Key destination) Moves value from one location to another.
void	save(Key key, byte[] content) Save the content.
long	size(Key key) Get value size.
byte[]	value(Key key) Obtain value for the specified key.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingStorage

public BlockingStorage(Storage storage)

Wrap a Storage in order get a blocking version of it.

Parameters:

storage - Storage to wrap

Method Detail

exists

public boolean exists(Key key)
               throws InterruptedException

This file exists?

Parameters:

key - The key (file name)

Returns:

TRUE if exists, FALSE otherwise

Throws:

InterruptedException - If thread was interrupted

list

public Collection<Key> list(Key prefix)
                     throws InterruptedException

Return the list of keys that start with this prefix, for example "foo/bar/".

Parameters:

prefix - The prefix.

Returns:

Collection of relative keys.

Throws:

InterruptedException - If thread was interrupted

save

public void save(Key key,
                 byte[] content)
          throws InterruptedException

Save the content.

Parameters:

key - The key

content - The content

Throws:

InterruptedException - If thread was interrupted

move

public void move(Key source,
                 Key destination)
          throws InterruptedException

Moves value from one location to another.

Parameters:

source - Source key.

destination - Destination key.

Throws:

InterruptedException - If thread was interrupted

size

public long size(Key key)
          throws InterruptedException

Get value size.

Parameters:

key - The key of value.

Returns:

Size of value in bytes.

Throws:

InterruptedException - If thread was interrupted

value

public byte[] value(Key key)
             throws InterruptedException

Obtain value for the specified key.

Parameters:

key - The key

Returns:

Value associated with the key

Throws:

InterruptedException - If thread was interrupted

delete

public void delete(Key key)
            throws InterruptedException

Removes value from storage. Fails if value does not exist.

Parameters:

key - Key for value to be deleted.

Throws:

InterruptedException - If thread was interrupted