 Antoine Grondin
|
07ce59b43f
Revert `go vet` incompatible changes (go1.0). More magic numbers.
|
11 years ago |
|
Antoine Grondin
|
41e849837f
Fix `go vet` errors.
|
11 years ago |
|
Antoine Grondin
|
893044d278
Fix Golint errors, except for all the missing comments.
|
11 years ago |
 Evan Huus
|
0f7b431bdf
Remove Broker.Equals()
|
11 years ago |
|
Evan Huus
|
d4d176a7cd
missing period
|
11 years ago |
|
Evan Huus
|
efb24f7c1c
Add accessor for broker's address
|
11 years ago |
|
Evan Huus
|
dae9785f7e
Replace broker's host/port with just addr
|
11 years ago |
|
Evan Huus
|
934c5688a1
Match the golang database pattern
|
11 years ago |
|
Evan Huus
|
46629e3169
No need for a separate err variable, thanks Burke
|
11 years ago |
 Evan Huus
|
a0e96da4d1
Rework how the client connects to brokers.
|
11 years ago |
|
Evan Huus
|
e4ff187a56
go 1.0 compatibility; all we lose is ipv6 zones
|
11 years ago |
|
Evan Huus
|
4969d24fa1
kafka->sarama
|
11 years ago |
|
Evan Huus
|
be4d7628e5
wip remove namespacing
|
11 years ago |
|
Evan Huus
|
9047579808
Split into two packages, one low-level, one high
|
11 years ago |
|
Evan Huus
|
cce9ff38a6
Broker.FetchOffset, Broker.CommitOffset
|
11 years ago |
|
Evan Huus
|
7284dce946
Error handling, documentation
|
11 years ago |
|
Evan Huus
|
d53fb36f6a
Offset request/response
|
11 years ago |
|
Evan Huus
|
da4ea44315
Improve metadata cache's updateTopics
|
11 years ago |
|
Evan Huus
|
c1b36d1a4f
Fetch Request/Response pair updated
|
11 years ago |
|
Evan Huus
|
860c34ae11
Broker bugfix and misc docs
|
11 years ago |
|
Evan Huus
|
23ba8a91f3
Fix broker asyncness
|
11 years ago |
|
Evan Huus
|
66d253ebae
Broker bug fix
|
11 years ago |
|
Evan Huus
|
fd2d940dbf
Broker cleanup, make it really concurrency-safe
|
11 years ago |
|
Evan Huus
|
6976f0b8b5
Remove unused code
|
11 years ago |
|
Evan Huus
|
ac861788b4
Make brokers request/response-type aware.
|
11 years ago |
|
Evan Huus
|
d26d2f1b52
Publish and document RequestEncoder interface type
|
11 years ago |
|
Evan Huus
|
087b16cf8b
Publish Broker.Connect() but don't connect automatically when decoding.
|
11 years ago |
|
Evan Huus
|
ba2bf0685c
Consistent encode and decode helper functions.
|
11 years ago |
|
Evan Huus
|
0c69a97459
Slices can already be nil
|
11 years ago |
|
Evan Huus
|
b0f42ffdf3
go vet
|
11 years ago |
