|
.gitignore
|
78d686d98d
Initial commit
|
12 gadi atpakaļ |
|
README.md
|
2de9a2dc0b
README tweak
|
12 gadi atpakaļ |
|
broker.go
|
0d5af9417d
refactor out common code
|
12 gadi atpakaļ |
|
broker_manager.go
|
5e41ad652f
Fix bug where old partitions weren't cleaned up
|
12 gadi atpakaļ |
|
client.go
|
eb4d0a37fb
Correctly send client ID
|
12 gadi atpakaļ |
|
consumer.go
|
0d4e4a2ea0
go fmt
|
12 gadi atpakaļ |
|
encoder_decoder.go
|
91b0ddffd1
go files use snake_case
|
12 gadi atpakaļ |
|
errors.go
|
fc4945fdf9
Allowing details on encode/decode errors
|
12 gadi atpakaļ |
|
fetch_request.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
fetch_response.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
message.go
|
4960166afb
SendSimpleMessage for producer, doesn't quite work yet
|
12 gadi atpakaļ |
|
message_set.go
|
4960166afb
SendSimpleMessage for producer, doesn't quite work yet
|
12 gadi atpakaļ |
|
metadata_request.go
|
91b0ddffd1
go files use snake_case
|
12 gadi atpakaļ |
|
metadata_response.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
offset_commit_request.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
offset_commit_response.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
offset_fetch_request.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
offset_fetch_response.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
offset_request.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
offset_response.go
|
77be473961
Add package declarations to stub files
|
12 gadi atpakaļ |
|
packet_crcs.go
|
2deb91d926
checkpoint wip message encoding/decoding
|
12 gadi atpakaļ |
|
packet_decoder.go
|
ca7a207750
finish basic message encoding/decoding
|
12 gadi atpakaļ |
|
packet_encoder.go
|
ca7a207750
finish basic message encoding/decoding
|
12 gadi atpakaļ |
|
packet_lengths.go
|
2deb91d926
checkpoint wip message encoding/decoding
|
12 gadi atpakaļ |
|
partitionChooser.go
|
4960166afb
SendSimpleMessage for producer, doesn't quite work yet
|
12 gadi atpakaļ |
|
partition_metadata.go
|
91b0ddffd1
go files use snake_case
|
12 gadi atpakaļ |
|
prep_encoder.go
|
4fd1ecc22c
Clarify encoding errors, permit sending produceRequests
|
12 gadi atpakaļ |
|
produce_request.go
|
4960166afb
SendSimpleMessage for producer, doesn't quite work yet
|
12 gadi atpakaļ |
|
produce_response.go
|
4960166afb
SendSimpleMessage for producer, doesn't quite work yet
|
12 gadi atpakaļ |
|
producer.go
|
863b58681b
Infrastructure for not expecting a response.
|
12 gadi atpakaļ |
|
real_decoder.go
|
1c4240b9cf
Fix some offset calculation bugs
|
12 gadi atpakaļ |
|
real_encoder.go
|
1c4240b9cf
Fix some offset calculation bugs
|
12 gadi atpakaļ |
|
request.go
|
44d5d67f64
Move API defs to right file, fix error condition
|
12 gadi atpakaļ |
|
topic_metadata.go
|
91b0ddffd1
go files use snake_case
|
12 gadi atpakaļ |
Evan Huus
5e41ad652f
Fix bug where old partitions weren't cleaned up