Create pool if there is atleast one valid server (#10)

Author: wenkat

consumer_pool.go

@@ -2,6 +2,7 @@ package beanstalk
 
 import (
 	"context"
+	"errors"
 	"sync"
 )
 
@@ -25,13 +26,15 @@ func NewConsumerPool(uris []string, tubes []string, config Config) (*ConsumerPoo
 
 	pool := &ConsumerPool{C: config.jobC, config: config, stop: make(chan struct{})}
 	for _, uri := range multiply(uris, config.Multiply) {
+		// Silently ignoring unsuccessful connections
 		consumer, err := NewConsumer(uri, tubes, config)
-		if err != nil {
-			pool.Stop()
-			return nil, err
+		if err == nil {
+			pool.consumers = append(pool.consumers, consumer)
 		}
-
-		pool.consumers = append(pool.consumers, consumer)
+	}
+	if len(pool.consumers) == 0 {
+		pool.Stop()
+		return nil, errors.New("no valid consumers")
 	}
 
 	return pool, nil

producer_pool.go

@@ -2,6 +2,7 @@ package beanstalk
 
 import (
 	"context"
+	"errors"
 	"math/rand"
 	"sync"
 
@@ -24,13 +25,15 @@ func NewProducerPool(uris []string, config Config) (*ProducerPool, error) {
 
 	pool := &ProducerPool{config: config}
 	for _, URI := range multiply(uris, config.Multiply) {
+		// Silently ignoring unsuccessful connections
 		producer, err := NewProducer(URI, config)
-		if err != nil {
-			pool.Stop()
-			return nil, err
+		if err == nil {
+			pool.producers = append(pool.producers, producer)
 		}
-
-		pool.producers = append(pool.producers, producer)
+	}
+	if len(pool.producers) == 0 {
+		pool.Stop()
+		return nil, errors.New("no available servers")
 	}
 
 	return pool, nil