diff --git a/src/connection.js b/src/connection.js index 2937fc5..6d70493 100644 --- a/src/connection.js +++ b/src/connection.js @@ -41,7 +41,7 @@ export default class Connection { this.normalizedNodes.push(Connection.normalizeNode(nodes, this.headers)) } - this.transport = new Transport(this.normalizedNodes, this.headers, timeout) + this.transport = new Transport(this.normalizedNodes, timeout) // TODO } static normalizeNode(node, headers) { diff --git a/src/request.js b/src/request.js index 5dc8d66..33e0f36 100644 --- a/src/request.js +++ b/src/request.js @@ -21,9 +21,8 @@ const BACKOFF_DELAY = 0.5 // seconds export default class Request { - constructor(node, requestConfig) { + constructor(node) { this.node = node - this.requestConfig = requestConfig this.backoffTime = null this.retries = 0 this.connectionError = null diff --git a/src/transport.js b/src/transport.js index f0c72be..7a6500c 100644 --- a/src/transport.js +++ b/src/transport.js @@ -15,13 +15,13 @@ import Request from './request' export default class Transport { - constructor(nodes, headers, timeout) { + constructor(nodes, timeout) { this.connectionPool = [] this.timeout = timeout // the maximum backoff time is 10 seconds this.maxBackoffTime = timeout ? timeout / 10 : 10000 nodes.forEach(node => { - this.connectionPool.push(new Request(node, headers)) + this.connectionPool.push(new Request(node)) }) }