net.spy.memcached.protocol.ascii
Class AsciiOperationFactory

java.lang.Object
  net.spy.memcached.protocol.ascii.AsciiOperationFactory

All Implemented Interfaces:

OperationFactory

public final class AsciiOperationFactory
extends java.lang.Object
implements OperationFactory

Operation factory for the ascii protocol.

Constructor Summary

AsciiOperationFactory()

Method Summary

CASOperation	cas(java.lang.String key, long casId, int flags, byte[] data, OperationCallback cb) Create a CAS operation.
ConcatenationOperation	cat(ConcatenationType catType, long casId, java.lang.String key, byte[] data, OperationCallback cb) Get a concatenation operation.
DeleteOperation	delete(java.lang.String key, OperationCallback cb) Create a deletion operation.
FlushOperation	flush(int delay, OperationCallback cb) Create a flush operation.
GetOperation	get(java.util.Collection<java.lang.String> keys, GetOperation.Callback cb) Create a get operation.
GetOperation	get(java.lang.String key, GetOperation.Callback cb) Create a get operation.
GetsOperation	gets(java.lang.String key, GetsOperation.Callback cb) Create a gets operation.
MutatatorOperation	mutate(Mutator m, java.lang.String key, int by, long exp, int def, OperationCallback cb) Create a mutator operation.
NoopOperation	noop(OperationCallback cb) Create a NOOP operation.
StatsOperation	stats(java.lang.String arg, StatsOperation.Callback cb) Get a new StatsOperation.
StoreOperation	store(StoreType storeType, java.lang.String key, int flags, int exp, byte[] data, OperationCallback cb) Create a store operation.
VersionOperation	version(OperationCallback cb) Create a new version operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsciiOperationFactory

public AsciiOperationFactory()

Method Detail

delete

public DeleteOperation delete(java.lang.String key,
                              OperationCallback cb)

Description copied from interface: OperationFactory

Create a deletion operation.

Specified by:

delete in interface OperationFactory

Parameters:

key - the key to delete

cb - the status callback

Returns:

the new DeleteOperation

flush

public FlushOperation flush(int delay,
                            OperationCallback cb)

Description copied from interface: OperationFactory

Create a flush operation.

Specified by:

flush in interface OperationFactory

Parameters:

delay - delay until flush.

cb - the status callback

Returns:

the new FlushOperation

get

public GetOperation get(java.lang.String key,
                        GetOperation.Callback cb)

Description copied from interface: OperationFactory

Create a get operation.

Specified by:

get in interface OperationFactory

Parameters:

key - the key to get

cb - the callback that will contain the results

Returns:

a new GetOperation

get

public GetOperation get(java.util.Collection<java.lang.String> keys,
                        GetOperation.Callback cb)

Description copied from interface: OperationFactory

Create a get operation.

Specified by:

get in interface OperationFactory

Returns:

a new GetOperation

gets

public GetsOperation gets(java.lang.String key,
                          GetsOperation.Callback cb)

Description copied from interface: OperationFactory

Create a gets operation.

Specified by:

gets in interface OperationFactory

Parameters:

key - the key to get

cb - the callback that will contain the results

Returns:

a new GetsOperation

mutate

public MutatatorOperation mutate(Mutator m,
                                 java.lang.String key,
                                 int by,
                                 long exp,
                                 int def,
                                 OperationCallback cb)

Description copied from interface: OperationFactory

Create a mutator operation.

Specified by:

mutate in interface OperationFactory

Parameters:

m - the mutator type

key - the mutatee key

by - the amount to increment or decrement

exp - the default value

def - expiration in case we need to default (0 if no default)

cb - the status callback

Returns:

the new mutator operation

stats

public StatsOperation stats(java.lang.String arg,
                            StatsOperation.Callback cb)

Description copied from interface: OperationFactory

Get a new StatsOperation.

Specified by:

stats in interface OperationFactory

Parameters:

arg - the stat parameter (see protocol docs)

cb - the stats callback

Returns:

the new StatsOperation

store

public StoreOperation store(StoreType storeType,
                            java.lang.String key,
                            int flags,
                            int exp,
                            byte[] data,
                            OperationCallback cb)

Description copied from interface: OperationFactory

Create a store operation.

Specified by:

store in interface OperationFactory

Parameters:

storeType - the type of store operation

key - the key to store

flags - the storage flags

exp - the expiration time

data - the data

cb - the status callback

Returns:

the new store operation

version

public VersionOperation version(OperationCallback cb)

Description copied from interface: OperationFactory

Create a new version operation.

Specified by:

version in interface OperationFactory

noop

public NoopOperation noop(OperationCallback cb)

Description copied from interface: OperationFactory

Create a NOOP operation.

Specified by:

noop in interface OperationFactory

Parameters:

cb - the operation callback

Returns:

the new NoopOperation

cas

public CASOperation cas(java.lang.String key,
                        long casId,
                        int flags,
                        byte[] data,
                        OperationCallback cb)

Description copied from interface: OperationFactory

Create a CAS operation.

Specified by:

cas in interface OperationFactory

Parameters:

key - the key to store

casId - the CAS identifier value (from a gets operation)

flags - the storage flags

data - the data

cb - the status callback

Returns:

the new store operation

cat

public ConcatenationOperation cat(ConcatenationType catType,
                                  long casId,
                                  java.lang.String key,
                                  byte[] data,
                                  OperationCallback cb)

Description copied from interface: OperationFactory

Get a concatenation operation.

Specified by:

cat in interface OperationFactory

Parameters:

catType - the type of concatenation to perform.

casId - the CAS value for an atomic compare-and-cat

key - the key

data - the data to store

cb - a callback for reporting the status

Returns:

thew new ConcatenationOperation