|
.gitignore
|
78d686d98d
Initial commit
|
12 gadi atpakaļ |
|
README.md
|
2de9a2dc0b
README tweak
|
12 gadi atpakaļ |
|
broker.go
|
021105945c
Use range over channel to handle channel closing properly
|
12 gadi atpakaļ |
|
brokerManager.go
|
e9be1161e9
More error case fixes
|
12 gadi atpakaļ |
|
client.go
|
eb4d0a37fb
Correctly send client ID
|
12 gadi atpakaļ |
|
consumer.go
|
ec1f0c8ea0
Initial checkpoint
|
12 gadi atpakaļ |
|
encoderDecoder.go
|
9eaf799481
Last bits of the framework seem to be in place
|
12 gadi atpakaļ |
|
errors.go
|
e9be1161e9
More error case fixes
|
12 gadi atpakaļ |
|
metadata.go
|
d47b9a1312
Potentially useful state of broker communication
|
12 gadi atpakaļ |
|
metadataRequest.go
|
5ab53c6457
wip checkpoint
|
12 gadi atpakaļ |
|
packetDecoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 gadi atpakaļ |
|
packetEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 gadi atpakaļ |
|
partitionMetadata.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 gadi atpakaļ |
|
prepEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 gadi atpakaļ |
|
producer.go
|
ec1f0c8ea0
Initial checkpoint
|
12 gadi atpakaļ |
|
realDecoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 gadi atpakaļ |
|
realEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 gadi atpakaļ |
|
request.go
|
44d5d67f64
Move API defs to right file, fix error condition
|
12 gadi atpakaļ |
|
topicMetadata.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 gadi atpakaļ |
Evan Huus
e9be1161e9
More error case fixes