|
.gitignore
|
78d686d98d
Initial commit
|
12 years ago |
|
README.md
|
2de9a2dc0b
README tweak
|
12 years ago |
|
broker.go
|
4707652d5f
checkpoint wip broker recovery
|
12 years ago |
|
brokerManager.go
|
4707652d5f
checkpoint wip broker recovery
|
12 years ago |
|
client.go
|
eb4d0a37fb
Correctly send client ID
|
12 years ago |
|
consumer.go
|
ec1f0c8ea0
Initial checkpoint
|
12 years ago |
|
encoderDecoder.go
|
4707652d5f
checkpoint wip broker recovery
|
12 years ago |
|
errors.go
|
e9be1161e9
More error case fixes
|
12 years ago |
|
metadata.go
|
4707652d5f
checkpoint wip broker recovery
|
12 years ago |
|
metadataRequest.go
|
5ab53c6457
wip checkpoint
|
12 years ago |
|
packetDecoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 years ago |
|
packetEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 years ago |
|
partitionMetadata.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 years ago |
|
prepEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 years ago |
|
producer.go
|
ec1f0c8ea0
Initial checkpoint
|
12 years ago |
|
realDecoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 years ago |
|
realEncoder.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 years ago |
|
request.go
|
44d5d67f64
Move API defs to right file, fix error condition
|
12 years ago |
|
topicMetadata.go
|
f29a5551d6
Make error codes public so callers can see specifically what went wrong
|
12 years ago |
Evan Huus
4707652d5f
checkpoint wip broker recovery