internal

type BackoffPolicy interface {
	Reset()

	// Returns the next delay
	Next() time.Duration
}

type BrokerStatusInfo struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type ClientOptions struct {
	Logger                      Logger
	TopologyPollInterval        time.Duration
	FixedReconnectionDelay      time.Duration
	ProducerInitialize          bool
	ProducerFlushThresholdBytes int
	ProducerConnectionsPerHost  int
}

type Topology struct {
	BaseName           string   `json:"baseName,omitempty"` // When defined, it represents the base name to build the broker names, e.g. "polar-"
	Length             int      `json:"length"`             // The ring size
	BrokerNames        []string `json:"names,omitempty"`
	ProducerPort       int      `json:"producerPort"`
	ProducerBinaryPort int      `json:"producerBinaryPort"`
	ConsumerPort       int      `json:"consumerPort"`
}