org.infinispan.rest

Class Server

java.lang.Object

org.infinispan.rest.Server

public class Server
extends Object

Integration server linking REST requests with Infinispan calls.

Since:

4.0

Author:

Michael Neale, Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
Server(javax.ws.rs.core.Request request, ServletContext servletContext, boolean useAsync)

Method Summary

Methods

Modifier and Type	Method and Description
String	ApplicationXJavaSerializedObject()
javax.ws.rs.core.MediaType	ApplicationXJavaSerializedObjectType()
javax.ws.rs.core.Response	asyncPutInCache(AdvancedCache<String,byte[]> cache, String key, byte[] data, String dataType, long ttl, long idleTime)
List<javax.ws.rs.core.Variant>	collectionVariantList()
RestServerConfiguration	configuration()
Metadata	createMetadata(Configuration cfg, String dataType, long ttl, long idleTime)
SimpleDateFormat	datePatternRfc1123LocaleUS()
javax.ws.rs.core.Response	getEntry(String cacheName, String key, String extended, String cacheControl)
javax.ws.rs.core.Response	getKeys(String cacheName, String globalKeySet)
MurmurHash3	hashFunc()
javax.ws.rs.core.Response	headEntry(String cacheName, String key, String extended, String cacheControl)
org.codehaus.jackson.map.ObjectMapper	jsonMapper()
javax.ws.rs.core.Response	killCache(String cacheName, String ifMatch, String ifNoneMatch, String ifModifiedSince, String ifUnmodifiedSince)
ManagerInstance	manager()
String	MAX_IDLE_TIME_HEADER()
Object	printIt(scala.Function1<PrintWriter,scala.runtime.BoxedUnit> action)
javax.ws.rs.core.Response	putEntry(String cacheName, String key, String mediaType, byte[] data, long ttl, long idleTime)
javax.ws.rs.core.Response	removeEntry(String cacheName, String key)
Object	streamIt(scala.Function1<OutputStream,scala.runtime.BoxedUnit> action) create a JAX-RS streaming output
String	TIME_TO_LIVE_HEADER()
List<javax.ws.rs.core.Variant>	variantList() For dealing with binary entries in the cache
com.thoughtworks.xstream.XStream	xstream()

Methods inherited from class java.lang.Object

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

Constructor Detail

Server

public Server(javax.ws.rs.core.Request request,
      ServletContext servletContext,
      boolean useAsync)

Method Detail

ApplicationXJavaSerializedObjectType

public javax.ws.rs.core.MediaType ApplicationXJavaSerializedObjectType()

ApplicationXJavaSerializedObject

public String ApplicationXJavaSerializedObject()

TIME_TO_LIVE_HEADER

public String TIME_TO_LIVE_HEADER()

MAX_IDLE_TIME_HEADER

public String MAX_IDLE_TIME_HEADER()

variantList

public List<javax.ws.rs.core.Variant> variantList()

For dealing with binary entries in the cache

collectionVariantList

public List<javax.ws.rs.core.Variant> collectionVariantList()

jsonMapper

public org.codehaus.jackson.map.ObjectMapper jsonMapper()

xstream

public com.thoughtworks.xstream.XStream xstream()

manager

public ManagerInstance manager()

configuration

public RestServerConfiguration configuration()

datePatternRfc1123LocaleUS

public SimpleDateFormat datePatternRfc1123LocaleUS()

getKeys

public javax.ws.rs.core.Response getKeys(String cacheName,
                                String globalKeySet)

getEntry

public javax.ws.rs.core.Response getEntry(String cacheName,
                                 String key,
                                 String extended,
                                 String cacheControl)

streamIt

public Object streamIt(scala.Function1<OutputStream,scala.runtime.BoxedUnit> action)

create a JAX-RS streaming output

printIt

public Object printIt(scala.Function1<PrintWriter,scala.runtime.BoxedUnit> action)

headEntry

public javax.ws.rs.core.Response headEntry(String cacheName,
                                  String key,
                                  String extended,
                                  String cacheControl)

putEntry

public javax.ws.rs.core.Response putEntry(String cacheName,
                                 String key,
                                 String mediaType,
                                 byte[] data,
                                 long ttl,
                                 long idleTime)

asyncPutInCache

public javax.ws.rs.core.Response asyncPutInCache(AdvancedCache<String,byte[]> cache,
                                        String key,
                                        byte[] data,
                                        String dataType,
                                        long ttl,
                                        long idleTime)

createMetadata

public Metadata createMetadata(Configuration cfg,
                      String dataType,
                      long ttl,
                      long idleTime)

removeEntry

public javax.ws.rs.core.Response removeEntry(String cacheName,
                                    String key)

killCache

public javax.ws.rs.core.Response killCache(String cacheName,
                                  String ifMatch,
                                  String ifNoneMatch,
                                  String ifModifiedSince,
                                  String ifUnmodifiedSince)

hashFunc

public MurmurHash3 hashFunc()