Package | Description |
---|---|
com.basho.riak.client.http |
The legacy, low-level HTTP REST RiakClient and associated classes, consider using the high-level
IRiakClient |
com.basho.riak.client.http.plain |
A more OO wrapper to the legacy, low-level HTTP REST client map reduce key filters, consider using the high-level
IRiakClient |
com.basho.riak.client.http.request |
Riak request classes for the legacy HTTP REST client, consider using the high-level
IRiakClient |
com.basho.riak.client.http.util |
Supporting utility classes for the legacy HTTP REST client, consider using the high-level
IRiakClient |
Modifier and Type | Method and Description |
---|---|
HttpResponse |
RiakObject.delete(RequestMeta meta) |
HttpResponse |
RiakClient.delete(String bucket,
String key,
RequestMeta meta) |
FetchResponse |
RiakObject.fetch(RequestMeta meta) |
FetchResponse |
RiakClient.fetch(String bucket,
String key,
RequestMeta meta) |
Long |
RiakClient.fetchCounter(String bucket,
String counter,
RequestMeta meta) |
FetchResponse |
RiakObject.fetchMeta(RequestMeta meta) |
FetchResponse |
RiakClient.fetchMeta(String bucket,
String key,
RequestMeta meta)
Fetch metadata (e.g.
|
BucketResponse |
RiakClient.getBucketSchema(String bucket,
RequestMeta meta) |
Long |
RiakClient.incrementCounter(String bucket,
String counter,
long increment,
RequestMeta meta) |
BucketResponse |
RiakClient.listBucket(String bucket,
RequestMeta meta) |
MapReduceResponse |
RiakClient.mapReduce(String job,
RequestMeta meta) |
WalkResponse |
RiakObject.LinkBuilder.run(RequestMeta meta)
Execute the link walking query by calling
RiakClient.walk(String, String, String, RequestMeta) . |
HttpResponse |
RiakClient.setBucketSchema(String bucket,
RiakBucketInfo bucketInfo,
RequestMeta meta) |
StoreResponse |
RiakObject.store(RequestMeta meta) |
StoreResponse |
RiakObject.store(RiakClient riak,
RequestMeta meta) |
StoreResponse |
RiakClient.store(RiakObject object,
RequestMeta meta) |
FetchResponse |
RiakClient.stream(String bucket,
String key,
RequestMeta meta)
Similar to fetch(), except the HTTP connection is left open for
successful responses, and the Riak response is provided as a stream.
|
boolean |
RiakClient.stream(String bucket,
String key,
StreamHandler handler,
RequestMeta meta) |
BucketResponse |
RiakClient.streamBucket(String bucket,
RequestMeta meta) |
WalkResponse |
RiakClient.walk(String bucket,
String key,
String walkSpec,
RequestMeta meta) |
Modifier and Type | Method and Description |
---|---|
void |
PlainClient.delete(String bucket,
String key,
RequestMeta meta)
Like
RiakClient.delete(String, String, RequestMeta) , except
throws on a non-200 or 404 response. |
RiakObject |
PlainClient.fetch(String bucket,
String key,
RequestMeta meta)
Like
RiakClient.fetch(String, String, RequestMeta) , except it
returns the fetched object directly or throws if the response is not a
200, 304 or 404. |
Collection<? extends RiakObject> |
PlainClient.fetchAll(String bucket,
String key,
RequestMeta meta)
Like
RiakClient.fetch(String, String, RequestMeta) , except it
returns the all the fetched objects directly or throws if the response is
not a 200, 304 or 404. |
RiakObject |
PlainClient.fetchMeta(String bucket,
String key,
RequestMeta meta)
Like
RiakClient.fetchMeta(String, String, RequestMeta) , except it
returns the fetched object metadata directly or throws if the response is
not a 200, 304 or 404. |
RiakBucketInfo |
PlainClient.listBucket(String bucket,
RequestMeta meta)
Like
RiakClient.listBucket(String, RequestMeta) , except throws on
a non-200 response |
void |
PlainClient.setBucketSchema(String bucket,
RiakBucketInfo bucketInfo,
RequestMeta meta)
Like
RiakClient.setBucketSchema(String, RiakBucketInfo, RequestMeta) ,
except throws on a non-204 response. |
void |
PlainClient.store(RiakObject object,
RequestMeta meta)
Like
RiakClient.store(RiakObject, RequestMeta) , except throws on
a non-200 or 204 response and updates the passed in RiakObject
with new metadata from Riak. |
boolean |
PlainClient.stream(String bucket,
String key,
StreamHandler handler,
RequestMeta meta)
|
List<? extends List<? extends RiakObject>> |
PlainClient.walk(String bucket,
String key,
String walkSpec,
RequestMeta meta)
Like
RiakClient.walk(String, String, String, RequestMeta) , except
throws on a non-200 or 404 response. |
Modifier and Type | Method and Description |
---|---|
static RequestMeta |
RequestMeta.deleteParams(int rw)
Use the given rw parameter for delete operations
|
static RequestMeta |
RequestMeta.readParams(int r)
Use the given r parameter for fetchMeta, fetch, or stream operations
|
RequestMeta |
RequestMeta.setAccept(String contentTypes) |
RequestMeta |
RequestMeta.setAsis(boolean asis) |
RequestMeta |
RequestMeta.setClientId(String clientId) |
RequestMeta |
RequestMeta.setHeader(String key,
String value)
Add the specified HTTP header
|
RequestMeta |
RequestMeta.setIfMatch(String etags) |
RequestMeta |
RequestMeta.setIfMatch(String[] etags) |
RequestMeta |
RequestMeta.setIfModifiedSince(Date lastmod) |
RequestMeta |
RequestMeta.setIfModifiedSince(String lastmod) |
RequestMeta |
RequestMeta.setIfNoneMatch(String etags) |
RequestMeta |
RequestMeta.setIfNoneMatch(String[] etags) |
RequestMeta |
RequestMeta.setIfUnmodifiedSince(Date lastmod) |
RequestMeta |
RequestMeta.setIfUnmodifiedSince(String lastmod) |
RequestMeta |
RequestMeta.setQueryParam(String param,
String value)
Add the given query parameter to the request
|
RequestMeta |
RequestMeta.setTimeout(int timeout) |
static RequestMeta |
RequestMeta.writeParams(Integer w,
Integer dw)
Use the given w and dw params for store or delete operations.
|
static RequestMeta |
RequestMeta.writeParams(Quorum w,
Quorum dw)
Use the given w and dw params for store or delete operations.
|
Modifier and Type | Method and Description |
---|---|
MapReduceResponse |
MapReduceBuilder.submit(RequestMeta meta)
Submits the job to the Riak server
|
Modifier and Type | Method and Description |
---|---|
HttpResponse |
ClientHelper.delete(String bucket,
String key,
RequestMeta meta)
Same as
RiakClient , except only returning the HTTP response |
HttpResponse |
ClientHelper.fetch(String bucket,
String key,
RequestMeta meta) |
HttpResponse |
ClientHelper.fetch(String bucket,
String key,
RequestMeta meta,
boolean streamResponse)
Same as
RiakClient , except only returning the HTTP response and
allows the response to be streamed. |
HttpResponse |
ClientHelper.fetchCounter(String bucket,
String counter,
RequestMeta meta) |
HttpResponse |
ClientHelper.fetchMeta(String bucket,
String key,
RequestMeta meta)
Same as
RiakClient , except only returning the HTTP response |
HttpResponse |
ClientHelper.getBucketSchema(String bucket,
RequestMeta meta)
Same as
RiakClient.getBucketSchema(String, RequestMeta) , except
only returning the HTTP response. |
HttpResponse |
ClientHelper.incrementCounter(String bucket,
String counter,
long increment,
RequestMeta meta) |
HttpResponse |
ClientHelper.listBucket(String bucket,
RequestMeta meta,
boolean streamResponse)
Same as
RiakClient , except only returning the HTTP response, and
if streamResponse==true, the response will be streamed back, so the user
is responsible for calling HttpResponseDecorator.close() |
HttpResponse |
ClientHelper.mapReduce(String job,
RequestMeta meta)
Same as
RiakClient , except only returning the HTTP response |
HttpResponse |
ClientHelper.setBucketSchema(String bucket,
org.json.JSONObject schema,
RequestMeta meta)
|
HttpResponse |
ClientHelper.store(RiakObject object,
RequestMeta meta)
Same as
RiakClient , except only returning the HTTP response |
boolean |
ClientHelper.stream(String bucket,
String key,
StreamHandler handler,
RequestMeta meta)
Same as
RiakClient , except only returning the HTTP response |
HttpResponse |
ClientHelper.walk(String bucket,
String key,
String walkSpec,
RequestMeta meta)
Same as
RiakClient , except only returning the HTTP response |
Copyright © 2014. All Rights Reserved.