|
.gitignore
|
78d686d98d
Initial commit
|
13 anos atrás |
|
README.md
|
2de9a2dc0b
README tweak
|
13 anos atrás |
|
broker.go
|
d53fb36f6a
Offset request/response
|
13 anos atrás |
|
client.go
|
e34ddd043d
Publish broker
|
13 anos atrás |
|
consumer.go
|
0d4e4a2ea0
go fmt
|
13 anos atrás |
|
encoder_decoder.go
|
2fa436eb05
Publish the Message type. Separate encoders.
|
13 anos atrás |
|
errors.go
|
8db695793d
A bit of docs
|
13 anos atrás |
|
fetch_request.go
|
fa67958ba3
Consistent naming
|
13 anos atrás |
|
fetch_response.go
|
c8a7da6540
Publish some necessary properties and types
|
13 anos atrás |
|
message.go
|
8db695793d
A bit of docs
|
13 anos atrás |
|
message_set.go
|
c8a7da6540
Publish some necessary properties and types
|
13 anos atrás |
|
metadata_cache.go
|
d53fb36f6a
Offset request/response
|
13 anos atrás |
|
metadata_request.go
|
2694df2f96
Remove unused code
|
13 anos atrás |
|
metadata_response.go
|
da4ea44315
Improve metadata cache's updateTopics
|
13 anos atrás |
|
offset_commit_request.go
|
c5f7eb4e02
OffsetCommit request/response
|
13 anos atrás |
|
offset_commit_response.go
|
c5f7eb4e02
OffsetCommit request/response
|
13 anos atrás |
|
offset_fetch_request.go
|
9f01db622b
OffsetFetch request/response
|
13 anos atrás |
|
offset_fetch_response.go
|
9f01db622b
OffsetFetch request/response
|
13 anos atrás |
|
offset_request.go
|
eb8e374888
Update some constants and document.
|
13 anos atrás |
|
offset_response.go
|
d53fb36f6a
Offset request/response
|
13 anos atrás |
|
packet_crcs.go
|
84d5cfc734
Finish improving errors
|
13 anos atrás |
|
packet_decoder.go
|
d53fb36f6a
Offset request/response
|
13 anos atrás |
|
packet_encoder.go
|
ba2bf0685c
Consistent encode and decode helper functions.
|
13 anos atrás |
|
packet_lengths.go
|
84d5cfc734
Finish improving errors
|
13 anos atrás |
|
partitioner.go
|
4aaecc7b0a
s/PartitionChooser/Partitioner/
|
13 anos atrás |
|
prep_encoder.go
|
0c69a97459
Slices can already be nil
|
13 anos atrás |
|
produce_request.go
|
c8a7da6540
Publish some necessary properties and types
|
13 anos atrás |
|
produce_response.go
|
c1b36d1a4f
Fetch Request/Response pair updated
|
13 anos atrás |
|
producer.go
|
805772fbb8
Hide the fact that ProduceRequests use messageSets
|
13 anos atrás |
|
real_decoder.go
|
d53fb36f6a
Offset request/response
|
13 anos atrás |
|
real_encoder.go
|
0c69a97459
Slices can already be nil
|
13 anos atrás |
|
request.go
|
ac861788b4
Make brokers request/response-type aware.
|
13 anos atrás |
|
response_header.go
|
ba2bf0685c
Consistent encode and decode helper functions.
|
13 anos atrás |
|
utils.go
|
2fa436eb05
Publish the Message type. Separate encoders.
|
13 anos atrás |
Evan Huus
c8a7da6540
Publish some necessary properties and types