|
@@ -1248,7 +1248,7 @@ func ExampleAsyncProducer_select() {
|
|
|
signals := make(chan os.Signal, 1)
|
|
|
signal.Notify(signals, os.Interrupt)
|
|
|
|
|
|
- var enqueued, producerError int
|
|
|
+ var enqueued, producerErrors int
|
|
|
ProducerLoop:
|
|
|
for {
|
|
|
select {
|
|
@@ -1256,13 +1256,13 @@ ProducerLoop:
|
|
|
enqueued++
|
|
|
case err := <-producer.Errors():
|
|
|
log.Println("Failed to produce message", err)
|
|
|
- producerError++
|
|
|
+ producerErrors++
|
|
|
case <-signals:
|
|
|
break ProducerLoop
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- log.Printf("Enqueued: %d; producerError: %d\n", enqueued, producerError)
|
|
|
+ log.Printf("Enqueued: %d; errors: %d\n", enqueued, producerErrors)
|
|
|
}
|
|
|
|
|
|
|
|
@@ -1283,7 +1283,7 @@ func ExampleAsyncProducer_goroutines() {
|
|
|
|
|
|
var (
|
|
|
wg sync.WaitGroup
|
|
|
- enqueued, successes, producerError int
|
|
|
+ enqueued, successes, producerErrors int
|
|
|
)
|
|
|
|
|
|
wg.Add(1)
|
|
@@ -1299,7 +1299,7 @@ func ExampleAsyncProducer_goroutines() {
|
|
|
defer wg.Done()
|
|
|
for err := range producer.Errors() {
|
|
|
log.Println(err)
|
|
|
- producerError++
|
|
|
+ producerErrors++
|
|
|
}
|
|
|
}()
|
|
|
|
|
@@ -1318,5 +1318,5 @@ ProducerLoop:
|
|
|
|
|
|
wg.Wait()
|
|
|
|
|
|
- log.Printf("Successfully produced: %d; producerError: %d\n", successes, producerError)
|
|
|
+ log.Printf("Successfully produced: %d; errors: %d\n", successes, producerErrors)
|
|
|
}
|