 Evan Huus
|
b97ce78d42
Check for errors in test code
|
10 anos atrás |
 Willem van Bergen
|
91a706483c
Unexport mockbroker.
|
10 anos atrás |
 Willem van Bergen
|
cc01cb4093
Merge pull request #303 from Shopify/split_consumer_events_channel
|
10 anos atrás |
|
Willem van Bergen
|
87c89f868c
Also prefix KError instances with Err.
|
10 anos atrás |
|
Willem van Bergen
|
ed24dc91a8
Code review fixes.
|
10 anos atrás |
|
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.
|
10 anos atrás |
|
Willem van Bergen
|
2432b5fcf7
Split consumer’s Events() channel into Messages() and Errors()
|
10 anos atrás |
|
Evan Huus
|
309e92f7ee
Rename all the things in consumer tests
|
10 anos atrás |
|
Evan Huus
|
00b87fe357
Rewrite consumer to support multiple partitions
|
11 anos atrás |
|
Evan Huus
|
d33e005ce0
Implement Client.WritablePartitions
|
11 anos atrás |
|
Evan Huus
|
b15933a415
add test
|
11 anos atrás |
|
Evan Huus
|
430eaee5b4
Actually check the return from Close in our tests
|
11 anos atrás |
|
Evan Huus
|
39a066ae3d
consumer: add unit test
|
11 anos atrás |
|
Evan Huus
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
11 anos atrás |
|
Willem van Bergen
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
11 anos atrás |
|
Willem van Bergen
|
6910a5531c
Add NewClientConfig
|
11 anos atrás |
|
Willem van Bergen
|
8c789b7d01
Add NewConsumerConfig()
|
11 anos atrás |
|
Evan Huus
|
be6f649828
Drop pretense of support for Go 1.0
|
11 anos atrás |
 John VC_LAST_NAME
|
334af0e75e
Fixed examples.
|
12 anos atrás |
 Burke Libbey
|
12297f18bd
Fixed tests
|
12 anos atrás |
|
Burke Libbey
|
1103e8c970
Fix consumer tests
|
12 anos atrás |
|
Burke Libbey
|
8f7144a7ed
wip
|
12 anos atrás |
|
Burke Libbey
|
5509b4a29c
wip
|
12 anos atrás |
|
Burke Libbey
|
b7c236d53a
wip
|
12 anos atrás |
|
Burke Libbey
|
7a9ae540f0
WIP Moving to encoder-based expecations
|
12 anos atrás |
|
Burke Libbey
|
fca2325bf4
wip
|
12 anos atrás |
|
Burke Libbey
|
86e0c02890
Translated more tests to new mockbroker format
|
12 anos atrás |
|
Burke Libbey
|
6c8a7dd28d
wip
|
12 anos atrás |
|
Burke Libbey
|
96d86eca56
wip
|
12 anos atrás |
 Antoine Grondin
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 anos atrás |
