| .. |
|
consumer.go
|
abfb8a5a6f
Add tests for channel draining expectations.
|
пре 11 година |
|
consumer_test.go
|
abfb8a5a6f
Add tests for channel draining expectations.
|
пре 11 година |
|
mocks.go
|
532c0656d3
OnPartition -> ExpectConsumePartition.
|
пре 11 година |
|
producer.go
|
5411ec3676
Rename Ack* configuration names to Return*, make ReturnErrors default to false for the Consumer, update good and examples
|
пре 11 година |
|
producer_test.go
|
5411ec3676
Rename Ack* configuration names to Return*, make ReturnErrors default to false for the Consumer, update good and examples
|
пре 11 година |
|
sync_producer.go
|
e4ee98f586
Add package level godoc, fix some typos.
|
пре 11 година |
|
sync_producer_test.go
|
25161444de
Enable errcheck on subpackages, and address error handling that was missed before.
|
пре 11 година |
Willem van Bergen
5411ec3676
Rename Ack* configuration names to Return*, make ReturnErrors default to false for the Consumer, update good and examples