|
.gitignore
|
11f0f9f698
better test
|
12 лет назад |
|
.travis.yml
|
e44cb688da
Add basic Travis config file
|
12 лет назад |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
12 лет назад |
|
README.md
|
8423f8cfeb
Tweak README
|
12 лет назад |
|
broker.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
broker_test.go
|
fca2325bf4
wip
|
12 лет назад |
|
client.go
|
ba9974ffb1
Add PanicHandler
|
12 лет назад |
|
client_test.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
consumer.go
|
ba9974ffb1
Add PanicHandler
|
12 лет назад |
|
consumer_test.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
crc32_field.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
encoder_decoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
errors.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
fetch_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
fetch_response.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
fetch_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 лет назад |
|
length_field.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
message.go
|
fe223908f6
Compression codec is only two bits, not three.
|
12 лет назад |
|
message_set.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
message_test.go
|
901b907636
Revert "Compression codec is high three bits, not low"
|
12 лет назад |
|
metadata_request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
metadata_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
metadata_response.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
metadata_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 лет назад |
|
mockbroker.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
offset_commit_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
offset_commit_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_commit_response.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_commit_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 лет назад |
|
offset_fetch_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
offset_fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_fetch_response.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
offset_fetch_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 лет назад |
|
offset_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
offset_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_response.go
|
2565bc81b7
Add an OffsetMethod that permits specifying other methods of determining the offset, such as querying the broker
|
12 лет назад |
|
offset_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 лет назад |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
packet_encoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
partitioner.go
|
aa9f8942f6
concurrency fixes
|
12 лет назад |
|
partitioner_test.go
|
f8f6c2a832
Fix HashPartitioner returning negative partitions.
|
12 лет назад |
|
prep_encoder.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
produce_message.go
|
5c9e5571ff
fix compression
|
12 лет назад |
|
produce_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
produce_request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
produce_response.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
produce_response_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
producer.go
|
5c9e5571ff
fix compression
|
12 лет назад |
|
producer_test.go
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 лет назад |
|
real_decoder.go
|
0f5cff6a9a
Return a decoding error for negative array lengths
|
12 лет назад |
|
real_encoder.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
response_header.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
response_header_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 лет назад |
|
sarama.go
|
ba9974ffb1
Add PanicHandler
|
12 лет назад |
|
utils.go
|
8db429b9dd
Fix panic handler bug (#52)
|
12 лет назад |
Burke Libbey