| 393 | |
| 394 | |
| 395 | class StartupMessage(_MessageType): |
| 396 | opcode = 0x01 |
| 397 | name = 'STARTUP' |
| 398 | |
| 399 | KNOWN_OPTION_KEYS = set(( |
| 400 | 'CQL_VERSION', |
| 401 | 'COMPRESSION', |
| 402 | 'NO_COMPACT' |
| 403 | )) |
| 404 | |
| 405 | def __init__(self, cqlversion, options): |
| 406 | self.cqlversion = cqlversion |
| 407 | self.options = options |
| 408 | |
| 409 | def send_body(self, f, protocol_version): |
| 410 | optmap = self.options.copy() |
| 411 | optmap['CQL_VERSION'] = self.cqlversion |
| 412 | write_stringmap(f, optmap) |
| 413 | |
| 414 | |
| 415 | class ReadyMessage(_MessageType): |
no test coverage detected