MCPcopy Create free account
hub / github.com/apache/cassandra-python-driver / encode

Method encode

cassandra/segment.py:170–185  ·  view source on GitHub ↗

Encode a message to one of more segments.

(self, buffer, msg)

Source from the content-addressed store, hash-verified

168 write_uint_le(buffer, payload_crc)
169
170 def encode(self, buffer, msg):
171 """
172 Encode a message to one of more segments.
173 """
174 msg_length = len(msg)
175
176 if msg_length > Segment.MAX_PAYLOAD_LENGTH:
177 payloads = []
178 for i in range(0, msg_length, Segment.MAX_PAYLOAD_LENGTH):
179 payloads.append(msg[i:i + Segment.MAX_PAYLOAD_LENGTH])
180 else:
181 payloads = [msg]
182
183 is_self_contained = len(payloads) == 1
184 for payload in payloads:
185 self._encode_segment(buffer, payload, is_self_contained)
186
187 def decode_header(self, buffer):
188 header_data = read_uint_le(buffer, self.header_length)

Callers

nothing calls this directly

Calls 1

_encode_segmentMethod · 0.95

Tested by

no test coverage detected