Write a CQL protocol frame header.
(f, version, flags, stream_id, opcode, length)
| 1146 | |
| 1147 | @staticmethod |
| 1148 | def _write_header(f, version, flags, stream_id, opcode, length): |
| 1149 | """ |
| 1150 | Write a CQL protocol frame header. |
| 1151 | """ |
| 1152 | pack = v3_header_pack if version >= 3 else header_pack |
| 1153 | f.write(pack(version, flags, stream_id, opcode)) |
| 1154 | write_int(f, length) |
| 1155 | |
| 1156 | @classmethod |
| 1157 | def decode_message(cls, protocol_version, user_type_map, stream_id, flags, opcode, body, |
no test coverage detected