Examples of com.fasterxml.storemate.store.Storable

com.fasterxml.storemate.store.Storable
Class that represents a single metadata entry read from the local database. It is a relatively thin wrapper around raw {@link ByteContainer} value,and its associated {@link StorableKey} key.

        List<StorableKey> ids = requestEntity.entries;
        ArrayList<E> entries = new ArrayList<E>(ids.size());
        StorableStore store = _stores.getEntryStore();
        
        for (StorableKey key : ids) {
            Storable raw = store.findEntry(key);
            // note: this may give null as well; caller needs to check (converter passes null as-is)
            E entry = (E) _entryConverter.entryFromStorable(raw);
            entries.add(entry);
        }
        return (OUT) response.ok(new SyncPullResponse<E>(_fileManager, _syncPullSmileWriter, entries));

View Full Code Here

        ArrayList<E> entries = new ArrayList<E>(ids.size());
        StorableStore store = _stores.getEntryStore();


        try {
            for (StorableKey key : ids) {
                Storable raw = store.findEntry(key);
                // note: this may give null as well; caller needs to check (converter passes null as-is)
                E entry = (E) _entryConverter.entryFromStorable(raw);
                entries.add(entry);
            }
        } catch (StoreException e) {

View Full Code Here

        StorableStore store = _stores.getEntryStore();


        try {
            for (StorableKey key : ids) {
                // null -> let's not pass 'metadata' yet since we don't use timings?
                Storable raw = store.findEntry(StoreOperationSource.SYNC, null, key);
                // note: this may give null as well; caller needs to check (converter passes null as-is)
                E entry = (E) _entryConverter.entryFromStorable(raw);
                entries.add(entry);
            }
        } catch (StoreException e) {

View Full Code Here

        List<StorableKey> ids = requestEntity.entries;
        ArrayList<E> entries = new ArrayList<E>(ids.size());
        StorableStore store = _stores.getEntryStore();
        
        for (StorableKey key : ids) {
            Storable raw = store.findEntry(key);
            // note: this may give null as well; caller needs to check (converter passes null as-is)
            E entry = (E) _entryConverter.entryFromStorable(raw);
            entries.add(entry);
        }
        if (metadata != null) {

View Full Code Here


    public SyncPullEntry() { }


    SyncPullEntry(StoredEntry<?> src)
    {
        final Storable raw = src.getRaw();
        key = src.getKey().asStorableKey();
        creationTime = src.getCreationTime();
        checksum = raw.getContentHash();
        checksumForCompressed = raw.getCompressedHash();
        
        if (src.isDeleted()) {
            storageSize = -1L;
            size = -1L;
        } else {
            storageSize = raw.getStorageLength();
            size = raw.getOriginalLength();
        }
        compression = raw.getCompression();
        lastAccessMethod = src.getLastAccessUpdateMethod();
        minTTLSecs = src.getMinTTLSinceAccessSecs();
        maxTTLSecs = src.getMaxTTLSecs();
        
        isDeleted = src.isDeleted();

View Full Code Here

        List<StorableKey> ids = requestEntity.entries;
        ArrayList<E> entries = new ArrayList<E>(ids.size());
        StorableStore store = _stores.getEntryStore();
        
        for (StorableKey key : ids) {
            Storable raw = store.findEntry(key);
            // note: this may give null as well; caller needs to check (converter passes null as-is)
            E entry = (E) _entryConverter.entryFromStorable(raw);
            entries.add(entry);
        }
        return (OUT) response.ok(new SyncPullResponse<E>(_fileManager, _syncPullSmileWriter, entries));

View Full Code Here


    protected ServletServiceResponse _handleGet(ServletServiceRequest request, ServletServiceResponse response,
            OperationDiagnostics stats, K key)
        throws IOException
    {
        Storable entry = _storeHandler.findRawEntryForInfo(key, stats);
        if (entry == null) {
            return response.notFound();
        }
        response = response.setContentTypeJson()
                .ok(_entryConverter.itemInfoFromStorable(entry));

View Full Code Here


    protected ServletServiceResponse _handleHead(ServletServiceRequest request, ServletServiceResponse response,
            OperationDiagnostics stats, K key)
        throws IOException
    {
        Storable entry = _storeHandler.findRawEntryForInfo(key, stats);
        if (entry == null) {
            return response.notFound();
        }
        // What kind of info, if any, should we return? Content-length would be possible,
        // but misleading/inaccurate, since our payload is JSON, not stored entry

View Full Code Here

        List<StorableKey> ids = requestEntity.entries;
        ArrayList<E> entries = new ArrayList<E>(ids.size());
        StorableStore store = _stores.getEntryStore();
        
        for (StorableKey key : ids) {
            Storable raw = store.findEntry(key);
            // note: this may give null as well; caller needs to check (converter passes null as-is)
            E entry = (E) _entryConverter.entryFromStorable(raw);
            entries.add(entry);
        }
        if (metadata != null) {

View Full Code Here

    
    public SyncPullEntry() { }


    SyncPullEntry(StoredEntry<?> src)
    {
        final Storable raw = src.getRaw();
        key = src.getKey().asStorableKey();
        creationTime = src.getCreationTime();
        checksum = raw.getContentHash();
        checksumForCompressed = raw.getCompressedHash();
        
        if (src.isDeleted()) {
            storageSize = -1L;
            size = -1L;
        } else {
            storageSize = raw.getStorageLength();
            size = raw.getOriginalLength();
        }
        compression = raw.getCompression();
        lastAccessMethod = src.getLastAccessUpdateMethod();
        minTTLSecs = src.getMinTTLSinceAccessSecs();
        maxTTLSecs = src.getMaxTTLSecs();
        
        isDeleted = src.isDeleted();

View Full Code Here

0 1 2 3

TOP

Related Classes of com.fasterxml.storemate.store.Storable

com.fasterxml.clustermate.service.metrics.OperationMetrics

com.fasterxml.clustermate.service.sync.SyncHandler

com.fasterxml.clustermate.service.sync.SyncListResponseEntry

com.fasterxml.clustermate.service.sync.SyncPullEntry

com.fasterxml.clustermate.servlet.StoreEntryInfoServlet

com.fasterxml.storemate.shared.ByteContainer

com.fasterxml.storemate.store.backend.OverwriteTestBase

com.fasterxml.storemate.store.impl.StorableConverter

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.