Connection

Undocumented in source.

class Connection {

import vibe.core.connectionpool : LockedConnection;;

alias Lock = LockedConnection!Connection;

version(!Have_vibe_d)

Connection m_connection;

alias Lock = Connection;

enum defaultPort;

this(string host, ushort port);

void connect();

void close();

void useKeyspace(string name);

FrameHeader makeHeader(FrameHeader.OpCode opcode);

StringMultiMap requestOptions();

CassandraResult query(Connection.Lock lock, string q, Consistency consistency);

PreparedStatement prepare(string q);

auto execute(Connection.Lock lock, PreparedStatement stmt, Args args);

void listen(Event[] events);

void throwOnError(FrameHeader fh);

string readAuthenticate(FrameHeader fh);

StringMultiMap readSupported(FrameHeader fh);

void readEvent(FrameHeader fh);

auto readList(FrameHeader fh);

auto readMap(FrameHeader fh);

auto readSet(FrameHeader fh);

alias WriteType = string;

string toString(WriteType wt);

static string toString(Error err);

}

Constructors

this this(string host, ushort port): Undocumented in source.

Members

Aliases

Lock alias Lock = LockedConnection!Connection: Undocumented in source.
Lock alias Lock = Connection: Undocumented in source.
WriteType alias WriteType = string: 7. Error codes

Enums

Error enum Error: 0x1200 Read_timeout: Timeout exception during a read request. The rest of the ERROR message body will be <cl><received><blockfor><data_present> where: <cl> is the consistency level of the query having triggered the exception. <received> is an int representing the number of nodes having answered the request. <blockfor> is the number of replica whose response is required to achieve <cl>. Please note that it is possible to have <received> >= <blockfor> if <data_present> is false. And also in the (unlikely) case were <cl> is achieved but the coordinator node timeout while waiting for read-repair acknowledgement. <data_present> is a single byte. If its value is 0, it means the replica that was asked for data has not responded. Otherwise, the value is != 0.
Event enum Event: 4.2.6. EVENT

Functions

close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
connect void connect(): Undocumented in source. Be warned that the author may not have intended to support it.
execute auto execute(Connection.Lock lock, PreparedStatement stmt, Args args): 4.1.6. EXECUTE
listen void listen(Event[] events): 4.1.7. REGISTER
makeHeader FrameHeader makeHeader(FrameHeader.OpCode opcode): Make a FrameHeader corresponding to this Stream
prepare PreparedStatement prepare(string q): 4.1.5. PREPARE
query CassandraResult query(Connection.Lock lock, string q, Consistency consistency): 4.1.4. QUERY
readAuthenticate string readAuthenticate(FrameHeader fh): Undocumented in source. Be warned that the author may not have intended to support it.
readEvent void readEvent(FrameHeader fh): Undocumented in source. Be warned that the author may not have intended to support it.
readList auto readList(FrameHeader fh): 6. Collection types
readMap auto readMap(FrameHeader fh): Map: a short n indicating the size of the map, followed by n entries. Each entry is composed of two [short bytes] representing the key and the value of the entry map.
readSet auto readSet(FrameHeader fh): Set: a short n indicating the size of the set, followed by n elements. Each element is [short bytes] representing the serialized element value.
readSupported StringMultiMap readSupported(FrameHeader fh): 4.2.4. SUPPORTED
requestOptions StringMultiMap requestOptions(): 4.1.3. OPTIONS
throwOnError void throwOnError(FrameHeader fh): 4.2. Responses
toString string toString(WriteType wt): Undocumented in source. Be warned that the author may not have intended to support it.
useKeyspace void useKeyspace(string name): Undocumented in source. Be warned that the author may not have intended to support it.

Manifest constants

defaultPort enum defaultPort;: Undocumented in source.

Static functions

toString string toString(Error err): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

m_connection Connection m_connection;: Undocumented in source.

Meta

Source

See Implementation

cassandra cql connection classes

Connection