|
.gitignore
|
78d686d98d
Initial commit
|
12 years ago |
|
README.md
|
2de9a2dc0b
README tweak
|
12 years ago |
|
broker.go
|
fd2d940dbf
Broker cleanup, make it really concurrency-safe
|
12 years ago |
|
client.go
|
e34ddd043d
Publish broker
|
12 years ago |
|
consumer.go
|
0d4e4a2ea0
go fmt
|
12 years ago |
|
encoder_decoder.go
|
2fa436eb05
Publish the Message type. Separate encoders.
|
12 years ago |
|
errors.go
|
cbc1273e08
checkpoint wip simplify errors slightly
|
12 years ago |
|
fetch_request.go
|
19099f5e88
Implement fetch requests
|
12 years ago |
|
fetch_response.go
|
e5a0f9bc72
Remove unused code
|
12 years ago |
|
message.go
|
cc60a82a48
publish CompressionCodec type
|
12 years ago |
|
message_set.go
|
2fa436eb05
Publish the Message type. Separate encoders.
|
12 years ago |
|
metadata_cache.go
|
fd2d940dbf
Broker cleanup, make it really concurrency-safe
|
12 years ago |
|
metadata_request.go
|
1e7b3a06da
Publish metadata request/response structures, remove dead code
|
12 years ago |
|
metadata_response.go
|
b70312a188
Group metadata response structures together
|
12 years ago |
|
offset_commit_request.go
|
77be473961
Add package declarations to stub files
|
12 years ago |
|
offset_commit_response.go
|
77be473961
Add package declarations to stub files
|
12 years ago |
|
offset_fetch_request.go
|
77be473961
Add package declarations to stub files
|
12 years ago |
|
offset_fetch_response.go
|
77be473961
Add package declarations to stub files
|
12 years ago |
|
offset_request.go
|
77be473961
Add package declarations to stub files
|
12 years ago |
|
offset_response.go
|
77be473961
Add package declarations to stub files
|
12 years ago |
|
packet_crcs.go
|
84d5cfc734
Finish improving errors
|
12 years ago |
|
packet_decoder.go
|
0c69a97459
Slices can already be nil
|
12 years ago |
|
packet_encoder.go
|
ba2bf0685c
Consistent encode and decode helper functions.
|
12 years ago |
|
packet_lengths.go
|
84d5cfc734
Finish improving errors
|
12 years ago |
|
partition_chooser.go
|
2fa436eb05
Publish the Message type. Separate encoders.
|
12 years ago |
|
prep_encoder.go
|
0c69a97459
Slices can already be nil
|
12 years ago |
|
produce_request.go
|
ac861788b4
Make brokers request/response-type aware.
|
12 years ago |
|
produce_response.go
|
babe87c20f
Simplify ProduceResponse structure with a map.
|
12 years ago |
|
producer.go
|
ac861788b4
Make brokers request/response-type aware.
|
12 years ago |
|
real_decoder.go
|
0c69a97459
Slices can already be nil
|
12 years ago |
|
real_encoder.go
|
0c69a97459
Slices can already be nil
|
12 years ago |
|
request.go
|
ac861788b4
Make brokers request/response-type aware.
|
12 years ago |
|
response_header.go
|
ba2bf0685c
Consistent encode and decode helper functions.
|
12 years ago |
|
utils.go
|
2fa436eb05
Publish the Message type. Separate encoders.
|
12 years ago |
Evan Huus
fd2d940dbf
Broker cleanup, make it really concurrency-safe