Function zstd_encode

kafka/codec.py:315–318 · view source on GitHub ↗

(payload)

Source from the content-addressed store, hash-verified

313
314
315	def zstd_encode(payload):
316	if not zstd:
317	raise NotImplementedError("Zstd codec is not available")
318	return zstd.ZstdCompressor().compress(payload)
319
320
321	def zstd_decode(payload):

test_zstdFunction · 0.90

test_zstd_multi_frameFunction · 0.90

_maybe_compressMethod · 0.90

no outgoing calls

test_zstdFunction · 0.72

test_zstd_multi_frameFunction · 0.72

searching dependent graphs…