Connection

Members

Aliases

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

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 = Consistency.one)

*4.1.4. QUERY

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

Meta