 Willem van Bergen
|
4189e55a44
Return{Errors,Successes} -> Return.{Errors,Successes}
|
9 years ago |
|
Willem van Bergen
|
251a2dbf7e
Update consumer example comments.
|
9 years ago |
|
Willem van Bergen
|
5411ec3676
Rename Ack* configuration names to Return*, make ReturnErrors default to false for the Consumer, update good and examples
|
9 years ago |
 Evan Huus
|
01eada75a8
Simplify dispatcher loop
|
9 years ago |
|
Willem van Bergen
|
0d6a34032f
Make Consumer and PartitionConsumer interfaces.
|
9 years ago |
|
Evan Huus
|
ea09ec0652
Add a test for bug #325
|
9 years ago |
|
Willem van Bergen
|
4a62390a8f
Clean up and document examples.
|
9 years ago |
|
Willem van Bergen
|
2862e55085
Tweaks to consumer_test.rb
|
9 years ago |
|
Willem van Bergen
|
910beded38
Fix Consumer example function names to follow convention
|
9 years ago |
|
Evan Huus
|
6e7ef3c572
Permit constructing producers/consumers without clients
|
9 years ago |
|
Evan Huus
|
bce6b9ae7e
Combine the OffsetMethod and Offset parameters
|
9 years ago |
|
Evan Huus
|
0abdf8c4f0
Move the clientID into the config object
|
9 years ago |
|
Evan Huus
|
616ac5daa4
Unify configuration structures into config.go
|
9 years ago |
|
Evan Huus
|
b97ce78d42
Check for errors in test code
|
9 years ago |
|
Willem van Bergen
|
91a706483c
Unexport mockbroker.
|
9 years ago |
 Willem van Bergen
|
cc01cb4093
Merge pull request #303 from Shopify/split_consumer_events_channel
|
9 years ago |
|
Willem van Bergen
|
87c89f868c
Also prefix KError instances with Err.
|
9 years ago |
|
Willem van Bergen
|
ed24dc91a8
Code review fixes.
|
9 years ago |
|
Willem van Bergen
|
f573a91a1a
Properly consume the Errors() channel in the consumer tests, and add an consumer example that works with goroutines instead of a select statement.
|
9 years ago |
|
Willem van Bergen
|
2432b5fcf7
Split consumer’s Events() channel into Messages() and Errors()
|
9 years ago |
|
Evan Huus
|
309e92f7ee
Rename all the things in consumer tests
|
9 years ago |
|
Evan Huus
|
00b87fe357
Rewrite consumer to support multiple partitions
|
10 years ago |
|
Evan Huus
|
d33e005ce0
Implement Client.WritablePartitions
|
10 years ago |
|
Evan Huus
|
b15933a415
add test
|
10 years ago |
|
Evan Huus
|
430eaee5b4
Actually check the return from Close in our tests
|
10 years ago |
|
Evan Huus
|
39a066ae3d
consumer: add unit test
|
10 years ago |
|
Evan Huus
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
10 years ago |
|
Willem van Bergen
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
10 years ago |
|
Willem van Bergen
|
6910a5531c
Add NewClientConfig
|
10 years ago |
|
Willem van Bergen
|
8c789b7d01
Add NewConsumerConfig()
|
10 years ago |
