 Evan Huus
|
2594b8edd6
Fix and simplify message decoding
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
66411d8222
Cleanup a bunch more error formats
|
%!s(int64=9) %!d(string=hai) anos |
 Kostiantyn Stepaniuk
|
0aeb8f0f95
Update snappy repo path and encoding interface
|
%!s(int64=9) %!d(string=hai) anos |
 Willem van Bergen
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
2018fd405e
Prefix error variables with Err
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
0a9f80b431
Merge pull request #171 from Shopify/hide-snappy-funcs
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
39823e3af9
Check some errors
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
b5df04ed3e
Make snappy functions private
|
%!s(int64=10) %!d(string=hai) anos |
 Dimitrij Denissenko
|
9675a91962
Added Gzip test. Simplified a little.
|
%!s(int64=11) %!d(string=hai) anos |
|
Dimitrij Denissenko
|
c087d7fc53
Allow Gzip bulk consumption
|
%!s(int64=11) %!d(string=hai) anos |
|
Dimitrij Denissenko
|
b1a73257c4
Allow to decode snappy streams
|
%!s(int64=11) %!d(string=hai) anos |
|
Dimitrij Denissenko
|
7664076559
Added support for snappy stream decoding
|
%!s(int64=11) %!d(string=hai) anos |
 Burke Libbey
|
34956b2be3
More informative logging around DecodingError, and bumped max msg size
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
fe223908f6
Compression codec is only two bits, not three.
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
487570b284
Get rid of a magic value of the compression codec mask
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
901b907636
Revert "Compression codec is high three bits, not low"
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
7d6070c06e
Compression codec is high three bits, not low
|
%!s(int64=11) %!d(string=hai) anos |
 Antoine Grondin
|
893044d278
Fix Golint errors, except for all the missing comments.
|
%!s(int64=11) %!d(string=hai) anos |
 Evan Huus
|
013a53b381
Fix message compression flag.
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
4797fe2e57
Only compress a message once
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
9885afee0c
Snappy encoding support
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
4969d24fa1
kafka->sarama
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
4957421f9e
Just return the messageblock, rather than smooshing the offset into the message
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
799b00cdad
Finish refactor to remove namespacing
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
be4d7628e5
wip remove namespacing
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
9047579808
Split into two packages, one low-level, one high
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
8db695793d
A bit of docs
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
cc60a82a48
publish CompressionCodec type
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
2fa436eb05
Publish the Message type. Separate encoders.
|
%!s(int64=11) %!d(string=hai) anos |
|
Evan Huus
|
ba2bf0685c
Consistent encode and decode helper functions.
|
%!s(int64=11) %!d(string=hai) anos |
