org.infinispan.server.memcached

Class TextProtocolUtil$

java.lang.Object

org.infinispan.server.memcached.TextProtocolUtil$

public class TextProtocolUtil$
extends Object

Memcached text protocol utilities.

Since:

4.1

Author:

Galder Zamarreño

Field Summary

Fields

Modifier and Type	Field and Description
static TextProtocolUtil$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
TextProtocolUtil$()

Method Summary

Methods

Modifier and Type	Method and Description
String	CHARSET()
String	CLIENT_ERROR_BAD_FORMAT()
byte[]	concat(byte[] a, byte[] b)
int	CR()
String	CRLF()
byte[]	CRLFBytes()
byte[]	DELETED()
int	END_SIZE()
byte[]	END()
byte[]	ERROR()
byte[]	EXISTS()
String	extractString(ByteArrayOutputStream byteBuffer)
int	LF()
scala.math.BigInt	MAX_UNSIGNED_LONG()
scala.math.BigInt	MIN_UNSIGNED()
byte[]	NOT_FOUND()
byte[]	NOT_STORED()
byte[]	OK()
int	readableBytes(org.jboss.netty.buffer.ChannelBuffer buffer)
String	readDiscardedLine(org.jboss.netty.buffer.ChannelBuffer buffer)
boolean	readElement(org.jboss.netty.buffer.ChannelBuffer buffer, OutputStream byteBuffer) In the particular case of Memcached, the end of operation/command is signaled by "\r\n" characters.
scala.collection.Seq<String>	readSplitLine(org.jboss.netty.buffer.ChannelBuffer buffer)
String	SERVER_ERROR()
void	skipLine(org.jboss.netty.buffer.ChannelBuffer buffer)
int	SP()
byte[]	STORED()
int	VALUE_SIZE()
byte[]	VALUE()
byte[]	ZERO()

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final TextProtocolUtil$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

TextProtocolUtil$

public TextProtocolUtil$()

Method Detail

CRLF

public String CRLF()

CRLFBytes

public byte[] CRLFBytes()

END

public byte[] END()

END_SIZE

public int END_SIZE()

DELETED

public byte[] DELETED()

NOT_FOUND

public byte[] NOT_FOUND()

EXISTS

public byte[] EXISTS()

STORED

public byte[] STORED()

NOT_STORED

public byte[] NOT_STORED()

OK

public byte[] OK()

ERROR

public byte[] ERROR()

CLIENT_ERROR_BAD_FORMAT

public String CLIENT_ERROR_BAD_FORMAT()

SERVER_ERROR

public String SERVER_ERROR()

VALUE

public byte[] VALUE()

VALUE_SIZE

public int VALUE_SIZE()

ZERO

public byte[] ZERO()

SP

public int SP()

CR

public int CR()

LF

public int LF()

MAX_UNSIGNED_LONG

public scala.math.BigInt MAX_UNSIGNED_LONG()

MIN_UNSIGNED

public scala.math.BigInt MIN_UNSIGNED()

CHARSET

public String CHARSET()

readElement

public boolean readElement(org.jboss.netty.buffer.ChannelBuffer buffer,
                  OutputStream byteBuffer)

In the particular case of Memcached, the end of operation/command is signaled by "\r\n" characters. So, if end of operation is found, this method would return true. On the contrary, if space was found instead of end of operation character, then it'd return the element and false.

extractString

public String extractString(ByteArrayOutputStream byteBuffer)

readDiscardedLine

public String readDiscardedLine(org.jboss.netty.buffer.ChannelBuffer buffer)

readableBytes

public int readableBytes(org.jboss.netty.buffer.ChannelBuffer buffer)

skipLine

public void skipLine(org.jboss.netty.buffer.ChannelBuffer buffer)

concat

public byte[] concat(byte[] a,
            byte[] b)

readSplitLine

public scala.collection.Seq<String> readSplitLine(org.jboss.netty.buffer.ChannelBuffer buffer)