func (c *Consumer) SetMaxRetryCount(count int) {
	atomic.StoreInt64(&c.maxRetryCount, int64(count))
}
SetMaxRetryCount sets the maximum number of reconnnection attemps that
methods on c (e.g. Firehose, Stream, TailingLogs) will make before failing.

Defaults to DefaultMaxRetryCount.
package consumer
import (
	"errors"
	"fmt"
	"io/ioutil"
	"net/http"
	"net/url"
	"strings"
	"sync"
	"sync/atomic"
	"time"
	noaa_errors "github.com/cloudfoundry/noaa/errors"
	"github.com/cloudfoundry/sonde-go/events"
	"github.com/gogo/protobuf/proto"
	"github.com/gorilla/websocket"
)
const (
	DefaultMinRetryDelay = 500 * time.Millisecond
	DefaultMaxRetryDelay = time.Minute
	DefaultMaxRetryCount = 1000
)
func (c *Consumer) SetMinRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.minRetryDelay, int64(d))
}
func (c *Consumer) SetMaxRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.maxRetryDelay, int64(d))
}