|
.gitignore
|
78d686d98d
Initial commit
|
il y a 12 ans |
|
README.md
|
2de9a2dc0b
README tweak
|
il y a 12 ans |
|
broker.go
|
d300ecbabe
Clean up better on connection error
|
il y a 12 ans |
|
brokerManager.go
|
ddf95c5718
Infer API type from encoder type, rather than passing it separately
|
il y a 12 ans |
|
client.go
|
eb4d0a37fb
Correctly send client ID
|
il y a 12 ans |
|
consumer.go
|
ec1f0c8ea0
Initial checkpoint
|
il y a 12 ans |
|
encoderDecoder.go
|
9eaf799481
Last bits of the framework seem to be in place
|
il y a 12 ans |
|
errors.go
|
e9be1161e9
More error case fixes
|
il y a 12 ans |
|
metadata.go
|
d47b9a1312
Potentially useful state of broker communication
|
il y a 12 ans |
|
metadataRequest.go
|
5ab53c6457
wip checkpoint
|
il y a 12 ans |
|
packetDecoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
il y a 12 ans |
|
packetEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
il y a 12 ans |
|
partitionMetadata.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
il y a 12 ans |
|
prepEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
il y a 12 ans |
|
producer.go
|
ec1f0c8ea0
Initial checkpoint
|
il y a 12 ans |
|
realDecoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
il y a 12 ans |
|
realEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
il y a 12 ans |
|
request.go
|
44d5d67f64
Move API defs to right file, fix error condition
|
il y a 12 ans |
|
topicMetadata.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
il y a 12 ans |
Evan Huus
d300ecbabe
Clean up better on connection error