Documentation ¶
Index ¶
- Constants
- Variables
- func BufferWriter(b *Buffer) io.Writer
- func CopyBuffer(b *Buffer, w io.Writer) (n int64, err error)
- type BatchQueryKind
- type BatchTypeFlag
- type Buffer
- func (b *Buffer) Bytes() []byte
- func (b *Buffer) BytesBuffer() *bytes.Buffer
- func (b *Buffer) Error() error
- func (b *Buffer) ReadByte() Byte
- func (b *Buffer) ReadBytes() Bytes
- func (b *Buffer) ReadBytesMap() BytesMap
- func (b *Buffer) ReadColumnSpec(f ResultFlags) ColumnSpec
- func (b *Buffer) ReadConsistency() Consistency
- func (b *Buffer) ReadCustomOption() *CustomOption
- func (b *Buffer) ReadErrorCode() ErrorCode
- func (b *Buffer) ReadHeaderFlags() QueryFlags
- func (b *Buffer) ReadInet() Inet
- func (b *Buffer) ReadInt() Int
- func (b *Buffer) ReadListOption() *ListOption
- func (b *Buffer) ReadLong() Long
- func (b *Buffer) ReadLongString() string
- func (b *Buffer) ReadMapOption() *MapOption
- func (b *Buffer) ReadOpCode() OpCode
- func (b *Buffer) ReadOption() Option
- func (b *Buffer) ReadOptionList() OptionList
- func (b *Buffer) ReadPreparedFlags() PreparedFlags
- func (b *Buffer) ReadPreparedMetadata() PreparedMetadata
- func (b *Buffer) ReadQueryFlags() QueryFlags
- func (b *Buffer) ReadResultFlags() ResultFlags
- func (b *Buffer) ReadResultMetadata() ResultMetadata
- func (b *Buffer) ReadSchemaChangeTarget() SchemaChangeTarget
- func (b *Buffer) ReadSchemaChangeType() SchemaChangeType
- func (b *Buffer) ReadSetOption() *SetOption
- func (b *Buffer) ReadShort() Short
- func (b *Buffer) ReadShortBytes() ShortBytes
- func (b *Buffer) ReadStartupOptions() StartupOptions
- func (b *Buffer) ReadStatusChangeType() StatusChangeType
- func (b *Buffer) ReadStreamID() StreamID
- func (b *Buffer) ReadString() string
- func (b *Buffer) ReadStringList() StringList
- func (b *Buffer) ReadStringMap() StringMap
- func (b *Buffer) ReadStringMultiMap() StringMultiMap
- func (b *Buffer) ReadTopologyChangeType() TopologyChangeType
- func (b *Buffer) ReadTupleOption() *TupleOption
- func (b *Buffer) ReadUDTOption() *UDTOption
- func (b *Buffer) ReadUUID() UUID
- func (b *Buffer) ReadValue() Value
- func (b *Buffer) ReadWriteType() WriteType
- func (b *Buffer) Reset()
- func (b *Buffer) Write(v Bytes)
- func (b *Buffer) WriteBatchTypeFlag(v BatchTypeFlag)
- func (b *Buffer) WriteByte(v Byte)
- func (b *Buffer) WriteBytes(v Bytes)
- func (b *Buffer) WriteBytesMap(m BytesMap)
- func (b *Buffer) WriteConsistency(v Consistency)
- func (b *Buffer) WriteEventTypes(e []EventType)
- func (b *Buffer) WriteHeaderFlags(v HeaderFlags)
- func (b *Buffer) WriteInet(v Inet)
- func (b *Buffer) WriteInt(v Int)
- func (b *Buffer) WriteLong(v Long)
- func (b *Buffer) WriteLongString(s string)
- func (b *Buffer) WriteOpCode(v OpCode)
- func (b *Buffer) WritePreparedFlags(v PreparedFlags)
- func (b *Buffer) WriteQueryFlags(v QueryFlags)
- func (b *Buffer) WriteQueryOptions(q QueryOptions)
- func (b *Buffer) WriteResultFlags(v ResultFlags)
- func (b *Buffer) WriteShort(v Short)
- func (b *Buffer) WriteShortBytes(v Bytes)
- func (b *Buffer) WriteStartupOptions(m StartupOptions)
- func (b *Buffer) WriteStreamID(v StreamID)
- func (b *Buffer) WriteString(s string)
- func (b *Buffer) WriteStringList(l StringList)
- func (b *Buffer) WriteStringMap(m StringMap)
- func (b *Buffer) WriteStringMultiMap(m StringMultiMap)
- func (b *Buffer) WriteUUID(v UUID)
- func (b *Buffer) WriteValue(v Value)
- type Byte
- type Bytes
- type BytesMap
- type ColumnSpec
- type Compression
- type Consistency
- type CqlValue
- func CqlFromASCII(s string) (CqlValue, error)
- func CqlFromBlob(b []byte) CqlValue
- func CqlFromBoolean(b bool) CqlValue
- func CqlFromFloat32(v float32) CqlValue
- func CqlFromFloat64(v float64) CqlValue
- func CqlFromIP(ip net.IP) (CqlValue, error)
- func CqlFromInt16(v int16) CqlValue
- func CqlFromInt32(v int32) CqlValue
- func CqlFromInt64(v int64) CqlValue
- func CqlFromInt8(v int8) CqlValue
- func CqlFromText(s string) (CqlValue, error)
- func CqlFromTimeUUID(b [16]byte) (CqlValue, error)
- func CqlFromUUID(b [16]byte) CqlValue
- func (c CqlValue) AsASCII() (string, error)
- func (c CqlValue) AsBlob() ([]byte, error)
- func (c CqlValue) AsBoolean() (bool, error)
- func (c CqlValue) AsFloat32() (float32, error)
- func (c CqlValue) AsFloat64() (float64, error)
- func (c CqlValue) AsIP() (net.IP, error)
- func (c CqlValue) AsInt16() (int16, error)
- func (c CqlValue) AsInt32() (int32, error)
- func (c CqlValue) AsInt64() (int64, error)
- func (c CqlValue) AsInt8() (int8, error)
- func (c CqlValue) AsStringMap() (map[string]string, error)
- func (c CqlValue) AsStringSlice() ([]string, error)
- func (c CqlValue) AsText() (string, error)
- func (c CqlValue) AsTimeUUID() ([16]byte, error)
- func (c CqlValue) AsUUID() ([16]byte, error)
- type CustomOption
- type ErrorCode
- type EventType
- type Header
- type HeaderFlags
- type Inet
- type Int
- type ListOption
- type Long
- type MapOption
- type MsgOptionalFields
- type OpCode
- type Option
- type OptionID
- type OptionList
- type PreparedFlags
- type PreparedMetadata
- type QueryFlags
- type QueryOptions
- type Request
- type Response
- type ResultFlags
- type ResultMetadata
- type Row
- type SchemaChangeTarget
- type SchemaChangeType
- type SetOption
- type Short
- type ShortBytes
- type StartupOptions
- type StatusChangeType
- type StreamID
- type StringList
- type StringMap
- type StringMultiMap
- type TopologyChangeType
- type TupleOption
- type UDTOption
- type UUID
- type Value
- type WriteType
Constants ¶
const HeaderSize = 9
HeaderSize specifies number of header bytes.
Variables ¶
var Debug = true
Functions ¶
func BufferWriter ¶
BufferWriter returns Buffer as io.Writer.
Types ¶
type BatchQueryKind ¶
type BatchQueryKind = byte
type BatchTypeFlag ¶
type BatchTypeFlag = byte
const ( LoggedBatchFlag BatchTypeFlag = 0 UnloggedBatchFlag BatchTypeFlag = 1 CounterBatchFlag BatchTypeFlag = 2 )
type Buffer ¶
type Buffer struct {
// contains filtered or unexported fields
}
func (*Buffer) BytesBuffer ¶
func (*Buffer) ReadBytesMap ¶
func (*Buffer) ReadColumnSpec ¶
func (b *Buffer) ReadColumnSpec(f ResultFlags) ColumnSpec
func (*Buffer) ReadConsistency ¶
func (b *Buffer) ReadConsistency() Consistency
func (*Buffer) ReadCustomOption ¶
func (b *Buffer) ReadCustomOption() *CustomOption
func (*Buffer) ReadErrorCode ¶
func (*Buffer) ReadHeaderFlags ¶
func (b *Buffer) ReadHeaderFlags() QueryFlags
func (*Buffer) ReadListOption ¶
func (b *Buffer) ReadListOption() *ListOption
func (*Buffer) ReadLongString ¶
func (*Buffer) ReadMapOption ¶
func (*Buffer) ReadOpCode ¶
func (*Buffer) ReadOption ¶
func (*Buffer) ReadOptionList ¶
func (b *Buffer) ReadOptionList() OptionList
func (*Buffer) ReadPreparedFlags ¶
func (b *Buffer) ReadPreparedFlags() PreparedFlags
func (*Buffer) ReadPreparedMetadata ¶
func (b *Buffer) ReadPreparedMetadata() PreparedMetadata
func (*Buffer) ReadQueryFlags ¶
func (b *Buffer) ReadQueryFlags() QueryFlags
func (*Buffer) ReadResultFlags ¶
func (b *Buffer) ReadResultFlags() ResultFlags
func (*Buffer) ReadResultMetadata ¶
func (b *Buffer) ReadResultMetadata() ResultMetadata
func (*Buffer) ReadSchemaChangeTarget ¶
func (b *Buffer) ReadSchemaChangeTarget() SchemaChangeTarget
allation is not required. It is done inside SchemaChange event.
func (*Buffer) ReadSchemaChangeType ¶
func (b *Buffer) ReadSchemaChangeType() SchemaChangeType
func (*Buffer) ReadSetOption ¶
func (*Buffer) ReadShortBytes ¶
func (b *Buffer) ReadShortBytes() ShortBytes
func (*Buffer) ReadStartupOptions ¶
func (b *Buffer) ReadStartupOptions() StartupOptions
func (*Buffer) ReadStatusChangeType ¶
func (b *Buffer) ReadStatusChangeType() StatusChangeType
func (*Buffer) ReadStreamID ¶
func (*Buffer) ReadString ¶
func (*Buffer) ReadStringList ¶
func (b *Buffer) ReadStringList() StringList
func (*Buffer) ReadStringMap ¶
func (*Buffer) ReadStringMultiMap ¶
func (b *Buffer) ReadStringMultiMap() StringMultiMap
func (*Buffer) ReadTopologyChangeType ¶
func (b *Buffer) ReadTopologyChangeType() TopologyChangeType
func (*Buffer) ReadTupleOption ¶
func (b *Buffer) ReadTupleOption() *TupleOption
func (*Buffer) ReadUDTOption ¶
func (*Buffer) ReadValue ¶
Length equal to -1 represents null. Length equal to -2 represents not set.
func (*Buffer) ReadWriteType ¶
func (*Buffer) WriteBatchTypeFlag ¶
func (b *Buffer) WriteBatchTypeFlag(v BatchTypeFlag)
func (*Buffer) WriteBytes ¶
func (*Buffer) WriteBytesMap ¶
func (*Buffer) WriteConsistency ¶
func (b *Buffer) WriteConsistency(v Consistency)
func (*Buffer) WriteEventTypes ¶
func (*Buffer) WriteHeaderFlags ¶
func (b *Buffer) WriteHeaderFlags(v HeaderFlags)
func (*Buffer) WriteLongString ¶
func (*Buffer) WriteOpCode ¶
func (*Buffer) WritePreparedFlags ¶
func (b *Buffer) WritePreparedFlags(v PreparedFlags)
func (*Buffer) WriteQueryFlags ¶
func (b *Buffer) WriteQueryFlags(v QueryFlags)
func (*Buffer) WriteQueryOptions ¶
func (b *Buffer) WriteQueryOptions(q QueryOptions)
func (*Buffer) WriteResultFlags ¶
func (b *Buffer) WriteResultFlags(v ResultFlags)
func (*Buffer) WriteShort ¶
func (*Buffer) WriteShortBytes ¶
func (*Buffer) WriteStartupOptions ¶
func (b *Buffer) WriteStartupOptions(m StartupOptions)
func (*Buffer) WriteStreamID ¶
func (*Buffer) WriteString ¶
func (*Buffer) WriteStringList ¶
func (b *Buffer) WriteStringList(l StringList)
func (*Buffer) WriteStringMap ¶
func (*Buffer) WriteStringMultiMap ¶
func (b *Buffer) WriteStringMultiMap(m StringMultiMap)
func (*Buffer) WriteValue ¶
type Byte ¶
type Byte = byte
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
const CQLv4 Byte = 0x4
CQLv4 is the only protocol version currently supported.
type Bytes ¶
type Bytes = []byte
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type BytesMap ¶
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type ColumnSpec ¶
type Compression ¶
type Compression string
const ( Lz4 Compression = "lz4" Snappy Compression = "snappy" )
type Consistency ¶
type Consistency = Short
const ( ANY Consistency = 0x0000 ONE Consistency = 0x0001 TWO Consistency = 0x0002 THREE Consistency = 0x0003 QUORUM Consistency = 0x0004 ALL Consistency = 0x0005 LOCALQUORUM Consistency = 0x0006 EACHQUORUM Consistency = 0x0007 SERIAL Consistency = 0x0008 LOCALSERIAL Consistency = 0x0009 LOCALONE Consistency = 0x000A )
type CqlValue ¶
func CqlFromASCII ¶
func CqlFromBlob ¶
func CqlFromBoolean ¶
func CqlFromFloat32 ¶
func CqlFromFloat64 ¶
func CqlFromInt16 ¶
func CqlFromInt32 ¶
func CqlFromInt64 ¶
func CqlFromInt8 ¶
func CqlFromText ¶
func CqlFromTimeUUID ¶
func CqlFromUUID ¶
func (CqlValue) AsStringSlice ¶
func (CqlValue) AsTimeUUID ¶
type CustomOption ¶
type CustomOption struct {
Name string
}
type ErrorCode ¶
type ErrorCode = Int
const ( // ErrCodeServer indicates unexpected error on server-side. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1051-L1052 ErrCodeServer ErrorCode = 0x0000 // ErrCodeProtocol indicates a protocol violation by some client message. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1053-L1055 ErrCodeProtocol ErrorCode = 0x000A // ErrCodeCredentials indicates missing required authentication. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1056-L1059 ErrCodeCredentials ErrorCode = 0x0100 // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1060-L1070 ErrCodeUnavailable ErrorCode = 0x1000 // ErrCodeOverloaded returned in case of request on overloaded node coordinator. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1071-L1072 ErrCodeOverloaded ErrorCode = 0x1001 // ErrCodeBootstrapping returned from the coordinator node in bootstrapping phase. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1073-L1074 ErrCodeBootstrapping ErrorCode = 0x1002 // ErrCodeTruncate indicates truncation exception. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1075 ErrCodeTruncate ErrorCode = 0x1003 // ErrCodeWriteTimeout returned in case of timeout during the request write. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1076-L1107 ErrCodeWriteTimeout ErrorCode = 0x1100 // ErrCodeReadTimeout returned in case of timeout during the request read. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1108-L1124 ErrCodeReadTimeout ErrorCode = 0x1200 // ErrCodeReadFailure indicates request read error which is not covered by ErrCodeReadTimeout. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1125-L1139 ErrCodeReadFailure ErrorCode = 0x1300 // ErrCodeFunctionFailure indicates an error in user-defined function. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1140-L1146 ErrCodeFunctionFailure ErrorCode = 0x1400 // ErrCodeWriteFailure indicates request write error which is not covered by ErrCodeWriteTimeout. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1147-L1180 ErrCodeWriteFailure ErrorCode = 0x1500 // ErrCodeSyntax indicates the syntax error in the query. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1182 ErrCodeSyntax ErrorCode = 0x2000 // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1183-L1184 ErrCodeUnauthorized ErrorCode = 0x2100 // ErrCodeInvalid indicates invalid query error which is not covered by ErrCodeSyntax. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1185 ErrCodeInvalid ErrorCode = 0x2200 // ErrCodeConfig indicates the configuration error. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1186 ErrCodeConfig ErrorCode = 0x2300 // ErrCodeAlreadyExists is returned for the requests creating the existing keyspace/table. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1187-L1196 ErrCodeAlreadyExists ErrorCode = 0x2400 // ErrCodeUnprepared returned from the host for prepared statement which is unknown. // See https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1197-L1200 ErrCodeUnprepared ErrorCode = 0x2500 )
See CQL Binary Protocol v4, section 9 for more details. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1046-L1200
type Header ¶
type Header struct { Version Byte Flags HeaderFlags StreamID StreamID OpCode OpCode Length Int }
Header spec https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L101.
func ParseHeader ¶
type HeaderFlags ¶
type HeaderFlags = Byte
const ( Compress HeaderFlags = 0x01 Tracing HeaderFlags = 0x02 CustomPayload HeaderFlags = 0x04 Warning HeaderFlags = 0x08 )
type Int ¶
type Int = int32
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type ListOption ¶
type ListOption struct {
Element Option
}
type Long ¶
type Long = int64
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type MsgOptionalFields ¶
type MsgOptionalFields struct { TracingID UUID Warnings StringList CustomPayload BytesMap }
func ParseMsgOptionalFields ¶
func ParseMsgOptionalFields(b *Buffer, f HeaderFlags) MsgOptionalFields
func (MsgOptionalFields) WriteTo ¶
func (m MsgOptionalFields) WriteTo(b *Buffer)
type OpCode ¶
type OpCode = Byte
const ( OpError OpCode = 0x00 OpStartup OpCode = 0x01 OpReady OpCode = 0x02 OpAuthenticate OpCode = 0x03 OpOptions OpCode = 0x05 OpSupported OpCode = 0x06 OpQuery OpCode = 0x07 OpResult OpCode = 0x08 OpPrepare OpCode = 0x09 OpExecute OpCode = 0x0A OpRegister OpCode = 0x0B OpEvent OpCode = 0x0C OpBatch OpCode = 0x0D OpAuthChallenge OpCode = 0x0E OpAuthResponse OpCode = 0x0F OpAuthSuccess OpCode = 0x10 )
type Option ¶
type Option struct { ID OptionID CustomOption *CustomOption List *ListOption Map *MapOption Set *SetOption UDT *UDTOption Tuple *TupleOption }
type OptionID ¶
type OptionID Short
const ( CustomID OptionID = 0x0000 ASCIIID OptionID = 0x0001 BigIntID OptionID = 0x0002 BlobID OptionID = 0x0003 BooleanID OptionID = 0x0004 CounterID OptionID = 0x0005 DecimalID OptionID = 0x0006 DoubleID OptionID = 0x0007 FloatID OptionID = 0x0008 IntID OptionID = 0x0009 TimestampID OptionID = 0x000B UUIDID OptionID = 0x000C VarcharID OptionID = 0x000D VarintID OptionID = 0x000E TimeUUIDID OptionID = 0x000F InetID OptionID = 0x0010 DateID OptionID = 0x0011 TimeID OptionID = 0x0012 SmallIntID OptionID = 0x0013 TinyIntID OptionID = 0x0014 DurationID OptionID = 0x0015 ListID OptionID = 0x0020 MapID OptionID = 0x0021 SetID OptionID = 0x0022 UDTID OptionID = 0x0030 TupleID OptionID = 0x0031 )
type OptionList ¶
type OptionList []Option
type PreparedFlags ¶
type PreparedFlags = Int
type PreparedMetadata ¶
type PreparedMetadata struct { Flags PreparedFlags ColumnsCnt Int PkCnt Int PkIndexes []Short GlobalKeyspace string GlobalTable string Columns []ColumnSpec }
type QueryFlags ¶
type QueryFlags = Byte
const ( Values QueryFlags = 0x01 SkipMetadata QueryFlags = 0x02 PageSize QueryFlags = 0x04 WithPagingState QueryFlags = 0x08 WithSerialConsistency QueryFlags = 0x10 WithDefaultTimestamp QueryFlags = 0x20 WithNamesForValues QueryFlags = 0x40 )
type QueryOptions ¶
type QueryOptions struct { Flags QueryFlags Values []Value Names StringList PageSize Int PagingState Bytes SerialConsistency Consistency Timestamp Long }
QueryOptions represent optional Values defined by flags. Consists of Values required for all flags. Values for unset flags are uninitialized. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L350-L385
func (*QueryOptions) SetFlags ¶
func (q *QueryOptions) SetFlags()
type Response ¶
type Response interface{}
Response specifies interface for all frame/response types.
type ResultFlags ¶
type ResultFlags = Int
const ( GlobalTablesSpec ResultFlags = 0x0001 HasMorePages ResultFlags = 0x0002 NoMetadata ResultFlags = 0x0004 )
type ResultMetadata ¶
type ResultMetadata struct { Flags ResultFlags ColumnsCnt Int // nil if flagPagingState is not set. PagingState Bytes GlobalKeyspace string GlobalTable string Columns []ColumnSpec }
type SchemaChangeTarget ¶
type SchemaChangeTarget string
const ( Keyspace SchemaChangeTarget = "KEYSPACE" Table SchemaChangeTarget = "TABLE" UserType SchemaChangeTarget = "TYPE" Function SchemaChangeTarget = "FUNCTION" Aggregate SchemaChangeTarget = "AGGREGATE" )
type SchemaChangeType ¶
type SchemaChangeType string
const ( Created SchemaChangeType = "CREATED" Updated SchemaChangeType = "UPDATED" Dropped SchemaChangeType = "DROPPED" )
type Short ¶
type Short = uint16
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type ShortBytes ¶
type ShortBytes = []byte
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type StartupOptions ¶
type StartupOptions StringMap
type StatusChangeType ¶
type StatusChangeType string
const ( Up StatusChangeType = "UP" Down StatusChangeType = "DOWN" )
type StringList ¶
type StringList = []string
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type StringMap ¶
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type StringMultiMap ¶
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266
type TopologyChangeType ¶
type TopologyChangeType string
const ( NewNode TopologyChangeType = "NEW_NODE" RemovedNode TopologyChangeType = "REMOVED_NODE" )
type TupleOption ¶
type TupleOption struct {
ValueTypes []Option
}
type UUID ¶
type UUID = [16]byte
Generic types from CQL binary protocol. https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L214-L266