| .. |
|
broker.go
|
1d5ed76c40
Rename one broker call to distinguish it from the other offset calls.
|
%!s(int64=12) %!d(string=hai) anos |
|
encoder_decoder.go
|
9047579808
Split into two packages, one low-level, one high
|
%!s(int64=12) %!d(string=hai) anos |
|
errors.go
|
9ee24646f9
Follow-up re-org after split
|
%!s(int64=12) %!d(string=hai) anos |
|
fetch_request.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
fetch_response.go
|
362314c5bc
Really basic, hacky consumer implementation
|
%!s(int64=12) %!d(string=hai) anos |
|
message.go
|
9047579808
Split into two packages, one low-level, one high
|
%!s(int64=12) %!d(string=hai) anos |
|
message_set.go
|
7fd3c6a543
Correctly deal with partial messages ending message sets
|
%!s(int64=12) %!d(string=hai) anos |
|
metadata_request.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
metadata_response.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
offset_commit_request.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
offset_commit_response.go
|
8971a250f3
Add missing field to offset fetch/commit responses
|
%!s(int64=12) %!d(string=hai) anos |
|
offset_fetch_request.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
offset_fetch_response.go
|
8971a250f3
Add missing field to offset fetch/commit responses
|
%!s(int64=12) %!d(string=hai) anos |
|
offset_request.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
offset_response.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
packet_crcs.go
|
9047579808
Split into two packages, one low-level, one high
|
%!s(int64=12) %!d(string=hai) anos |
|
packet_decoder.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
packet_encoder.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
packet_lengths.go
|
9047579808
Split into two packages, one low-level, one high
|
%!s(int64=12) %!d(string=hai) anos |
|
prep_encoder.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
produce_request.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
produce_response.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
protocol.go
|
9047579808
Split into two packages, one low-level, one high
|
%!s(int64=12) %!d(string=hai) anos |
|
real_decoder.go
|
97a5e22c04
Fix egregious bug in decoder.push
|
%!s(int64=12) %!d(string=hai) anos |
|
real_encoder.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
request.go
|
e0ba03b9b7
XXXXXX Don't use string pointers XXXXXX
|
%!s(int64=12) %!d(string=hai) anos |
|
response_header.go
|
9047579808
Split into two packages, one low-level, one high
|
%!s(int64=12) %!d(string=hai) anos |
Evan Huus
362314c5bc
Really basic, hacky consumer implementation