| package gocql |
| |
| import "fmt" |
| |
| // See CQL Binary Protocol v5, section 8 for more details. |
| // https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec |
| const ( |
| // ErrCodeServer indicates unexpected error on server-side. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1246-L1247 |
| ErrCodeServer = 0x0000 |
| // ErrCodeProtocol indicates a protocol violation by some client message. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1248-L1250 |
| ErrCodeProtocol = 0x000A |
| // ErrCodeCredentials indicates missing required authentication. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1251-L1254 |
| ErrCodeCredentials = 0x0100 |
| // ErrCodeUnavailable indicates unavailable error. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1255-L1265 |
| ErrCodeUnavailable = 0x1000 |
| // ErrCodeOverloaded returned in case of request on overloaded node coordinator. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1266-L1267 |
| ErrCodeOverloaded = 0x1001 |
| // ErrCodeBootstrapping returned from the coordinator node in bootstrapping phase. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1268-L1269 |
| ErrCodeBootstrapping = 0x1002 |
| // ErrCodeTruncate indicates truncation exception. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1270 |
| ErrCodeTruncate = 0x1003 |
| // ErrCodeWriteTimeout returned in case of timeout during the request write. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1271-L1304 |
| ErrCodeWriteTimeout = 0x1100 |
| // ErrCodeReadTimeout returned in case of timeout during the request read. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1305-L1321 |
| ErrCodeReadTimeout = 0x1200 |
| // ErrCodeReadFailure indicates request read error which is not covered by ErrCodeReadTimeout. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1322-L1340 |
| ErrCodeReadFailure = 0x1300 |
| // ErrCodeFunctionFailure indicates an error in user-defined function. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1341-L1347 |
| ErrCodeFunctionFailure = 0x1400 |
| // ErrCodeWriteFailure indicates request write error which is not covered by ErrCodeWriteTimeout. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1348-L1385 |
| ErrCodeWriteFailure = 0x1500 |
| // ErrCodeCDCWriteFailure is defined, but not yet documented in CQLv5 protocol. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1386 |
| ErrCodeCDCWriteFailure = 0x1600 |
| // ErrCodeCASWriteUnknown indicates only partially completed CAS operation. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1387-L1397 |
| ErrCodeCASWriteUnknown = 0x1700 |
| // ErrCodeSyntax indicates the syntax error in the query. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1399 |
| ErrCodeSyntax = 0x2000 |
| // ErrCodeUnauthorized indicates access rights violation by user on performed operation. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1400-L1401 |
| ErrCodeUnauthorized = 0x2100 |
| // ErrCodeInvalid indicates invalid query error which is not covered by ErrCodeSyntax. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1402 |
| ErrCodeInvalid = 0x2200 |
| // ErrCodeConfig indicates the configuration error. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1403 |
| ErrCodeConfig = 0x2300 |
| // ErrCodeAlreadyExists is returned for the requests creating the existing keyspace/table. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1404-L1413 |
| ErrCodeAlreadyExists = 0x2400 |
| // ErrCodeUnprepared returned from the host for prepared statement which is unknown. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1414-L1417 |
| ErrCodeUnprepared = 0x2500 |
| ) |
| |
| type RequestError interface { |
| Code() int |
| Message() string |
| Error() string |
| } |
| |
| type errorFrame struct { |
| frameHeader |
| |
| code int |
| message string |
| } |
| |
| func (e errorFrame) Code() int { |
| return e.code |
| } |
| |
| func (e errorFrame) Message() string { |
| return e.message |
| } |
| |
| func (e errorFrame) Error() string { |
| return e.Message() |
| } |
| |
| func (e errorFrame) String() string { |
| return fmt.Sprintf("[error code=%x message=%q]", e.code, e.message) |
| } |
| |
| type RequestErrUnavailable struct { |
| errorFrame |
| Consistency Consistency |
| Required int |
| Alive int |
| } |
| |
| func (e *RequestErrUnavailable) String() string { |
| return fmt.Sprintf("[request_error_unavailable consistency=%s required=%d alive=%d]", e.Consistency, e.Required, e.Alive) |
| } |
| |
| type ErrorMap map[string]uint16 |
| |
| type RequestErrWriteTimeout struct { |
| errorFrame |
| Consistency Consistency |
| Received int |
| BlockFor int |
| WriteType string |
| } |
| |
| type RequestErrWriteFailure struct { |
| errorFrame |
| Consistency Consistency |
| Received int |
| BlockFor int |
| NumFailures int |
| WriteType string |
| ErrorMap ErrorMap |
| } |
| |
| type RequestErrCDCWriteFailure struct { |
| errorFrame |
| } |
| |
| type RequestErrReadTimeout struct { |
| errorFrame |
| Consistency Consistency |
| Received int |
| BlockFor int |
| DataPresent byte |
| } |
| |
| type RequestErrAlreadyExists struct { |
| errorFrame |
| Keyspace string |
| Table string |
| } |
| |
| type RequestErrUnprepared struct { |
| errorFrame |
| StatementId []byte |
| } |
| |
| type RequestErrReadFailure struct { |
| errorFrame |
| Consistency Consistency |
| Received int |
| BlockFor int |
| NumFailures int |
| DataPresent bool |
| ErrorMap ErrorMap |
| } |
| |
| type RequestErrFunctionFailure struct { |
| errorFrame |
| Keyspace string |
| Function string |
| ArgTypes []string |
| } |
| |
| // RequestErrCASWriteUnknown is distinct error for ErrCodeCasWriteUnknown. |
| // |
| // See https://github.com/apache/cassandra/blob/7337fc0/doc/native_protocol_v5.spec#L1387-L1397 |
| type RequestErrCASWriteUnknown struct { |
| errorFrame |
| Consistency Consistency |
| Received int |
| BlockFor int |
| } |
