| 1 | Redis = require 'ioredis'
|
| 2 | RedisNS = require '@octoblu/redis-ns'
|
| 3 | HydrantManager = require '..'
|
| 4 |
|
| 5 | class HydrantManagerFactory
|
| 6 | constructor: ({@uuidAliasResolver, @namespace, @redisUri}) ->
|
| 7 | throw new Error('HydrantManagerFactory: redisUri is required') unless @redisUri?
|
| 8 | throw new Error('HydrantManagerFactory: namespace is required') unless @namespace?
|
| 9 | throw new Error('HydrantManagerFactory: uuidAliasResolver is required') unless @uuidAliasResolver?
|
| 10 |
|
| 11 | build: =>
|
| 12 | client = new RedisNS @namespace, new Redis @redisUri, dropBufferSupport: true
|
| 13 | new HydrantManager {client, @uuidAliasResolver}
|
| 14 |
|
| 15 | module.exports = HydrantManagerFactory
|