{"_id":"@mgfx/connector-redis","_rev":"37-1c58c1d4a8c476d4251789fc07694c7d","name":"@mgfx/connector-redis","dist-tags":{"next":"0.1.16","latest":"0.1.20","beta":"0.1.39"},"versions":{"0.1.1":{"name":"@mgfx/connector-redis","version":"0.1.1","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.2.0","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.1.1","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"08479293eac7ee39ccb8eb34f3737d1ee941ee59","_id":"@mgfx/connector-redis@0.1.1","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-zxkLV6pwAmAXjR7V5xtD5HKrUoO19t3AuunV1q5cS9+G+bOrQJNds9liZDtcqTmr/AmLwL+wQ9KPv0DS+NvBaA==","shasum":"92721acfb036f7e74c561afacb701cf6c3a72065","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.1.tgz","fileCount":19,"unpackedSize":34802,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeYO9oCRA9TVsSAnZWagAAVBkQAJxQIbR8Dh3rboK/31xf\nXIz9O4dPOT7bF0YacXsDCchte4toulqKdqT9vPud9nbYydXCKR7ycU+EnDNi\nJ9TRn8li7ae19k09H/BzzHEhApEuLRp0qEm4BVX48CkQ80A+yOosIgOgL3U7\nOl5xUfl0H6DWDYvva/nBa6tTq12AmmDoyNURZ4pWSvelon8kOY8RNMUooKN0\n91tW6ido4uoN+zIcW2V2zlfWYfcfBAYMI7WVFIiSmLre/ZXletBDcEDTbUO/\nQSaZGBel89Dqj6Ce1+8OB/UYV0VoB4OxwBpkILfOuuczqIqyz7T1xzK6tAs8\nBNSRxvCeNXOOfzj9gIgs1ZCmUUPYtikZMe9j8BVib9bgnuEqzGAow6NkwnDK\n9aJRYWupXOwBSihViT7IefjJqZxkIm6S6lu4JtlaGPYk/TBkaAfcAHHqeHae\n8gLzaHdN9gOTkLj1Sjvb+AUFXyC2DfqLnBdNuUDolna6XEIX3+jmvvY4+/lb\noASz7ymrglt4uIBwgRjPhOU1ckGL+4Gq7Pb3CiOsBVR46fRNN3gCc2lb9vrd\ndrDFSrfccSPf8o18Y+87ze8Viis8addbe2V9LWH8wgNXFsevx7QduaVtZ2dX\nNPeTm8T4M5LxfbmaCdzjXUBU4NOAEyCrZ2g3qEYtNLF/JZBkp5nhiAEnw1qd\nhBvX\r\n=m4MD\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIA6Iu+YT6mu9d1cvHpP4SLPC8uzRkCvjkdWEyvIJsYAPAiBCNISRxdshK5uL8qda9/btaXMpzdI66ZGzxFTZn8MfpA=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.1_1583411048170_0.28997861162710614"},"_hasShrinkwrap":false},"0.1.2":{"name":"@mgfx/connector-redis","version":"0.1.2","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.2.0","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.1.2","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"e62814eb6602dcc3de619ad1f104244bbf904bb5","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.2","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-WVtUYW57v9fF0wBjvBC24EpPWoHzYm7ViKQVndeiuj9JsOTRhwLzhkA0lXQ9f9FvMjLcX7OaH/E/ke6kqxmJvA==","shasum":"0c69553de3ee086b8e851a2569237518dfecc39c","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.2.tgz","fileCount":19,"unpackedSize":34998,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeZhZ7CRA9TVsSAnZWagAAVHkP/i6aiKxG45FwjyGbbDul\nVy+FkYKWv3lpL59d/E7Bb1ia3Q/HmyOWYlYylQBp74BW7PRzkx9NfDVBTRKZ\n8ZeodhVpqbMPd4W/rWFXEOH0Vgo2/8k5B2Ja+lusoDYStTU68jaGozy8vbz7\nkHARZvGkDd8fR4edTR3KiyQyPKNkt2J0ovb0W0kubiSPTDc7/H3tMH2XY3iG\nfZ/PsIWATRbup93AoewHvFXmhN2asvoG88UdVJ6PjEs2ojFRxPGkmRUjptap\nOYdwY7u9m19WPgegl+r9nz9fcOhtzPR8EuCGxKTlNHCXgPY0viPgarSFtqsy\nLxWRrywHak2pu1XXGMpIDKEs8ydQfM7U946UvsS89MGbB8vnjMI7m9oQqUvV\nd/Y2Y2KqaCI+MO1MqaJOuj6C0mW6YBwst9aVNiuFJ9Ze3LaDlvFF/VadyJk9\n7S+NaxFbzDqPSr3ycU8H0PKBGQaa1F4bN3PiNFD7qzCC+KxKCx5MX2Tok6F2\nSe3ekHZqKgonhBkmKbhzfaTgeVZ3FBj4TBhHU08chaEGcbNDnAENt0tGcnH5\nl0oreri03H2Zo9AYA/fTBOG/KNRmX5N3GTk4hyXRvteEXYAAMMmy7wiUQrVc\nJOB8a7OApzJgct2wLTJqRB8GkyNSZSYSZJDQJaWBAfPLP9EsoWoAg/lG/k5C\ndAO7\r\n=CqQf\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD6rG2nIwCUPvaeZu3Wd5qySMlIzU3eg8+g7HqLqAsCLAIhALnhH5h9FeH7Fx0XpCmAvsdma1mnSweCXUT3Nx7C/bDv"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.2_1583748731033_0.4461385157468072"},"_hasShrinkwrap":false},"0.1.4":{"name":"@mgfx/connector-redis","version":"0.1.4","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.2.0","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.1.2","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"2ca6bc2b3edc24efdb594fef6c53b83374131de4","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.4","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-mDgRAaAUx9HfzwuPSvhYFoEnuRPWbJ3trtKhLwhhldis2PrlOJ06jsVYbACEi3xWiSAC+gtSm+yB3e5OWGqQKw==","shasum":"b5a3ff18ae15bad9c513d1b829b965d97cefd0fa","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.4.tgz","fileCount":3,"unpackedSize":3435,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeaK57CRA9TVsSAnZWagAAdA4P/2AqRJJfMsjz7ou0UAse\nvEhYcDS/p0HeJH2EpOynr2+ulOYusFspk5hW3i70t4IzXNm82rvzKnXjkczT\nXWqIRX5ktDsuSFcz2m7CDxynfUPZZuvAPaJDyQMr2IfM1yJuPkn7JoHkn6NL\nqJvolhn52GCN/zrbV72ETLv8/wakfpTo85b2wB/+O3ctkbXpiY6q62w/rU87\n/5N19caCD2FP+lfWD3WDpCpWFDcrH4umod535EMxgHw2AyYS6cBq9bU3PY/s\nu/CVbWetfnjREm2CATwgExvCDpbB6pi78out6xF5oBX5djRWmugzkal3kdNd\nXwC+HVyLptoaDfS3bDcqVXoU358Uvxf1OUUUxT3HSis0nr1u7vIPw4OsE6fc\nVl7x62qfQGafIHTap45K5vHYLKQB46Uq3rIRcg/SunVlpFetjPeol43xp0uD\nGBzXd+1yx4Wx4w6T9GZz3iGUPEysTs2lnoDz4j0vPEw8Zeb3IvDCV6IJiGVs\nLSlvMcprikGZ9EjBBsG+MO3U9Xj2VqFBH21x8KijcR3kFBJBzUojugCevgM3\nErxIBnYPfW77RgNUs2MdQ7/Ain/H/M0TgoPkQy37dvIOXE/7CNgFkbR/YdND\nNcXaG1TyMSVu2Tz0bHkvqoVd5NzDY3R8o64hHBUfsfAvKWd5mh0vVvcxJjli\n6mmV\r\n=v1ni\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC7w6JXMxRj/nGvpVhnQnUAaOLwd6jLZkaumhc8kfA3WgIhAKVf6ygyF6AaZJ/nEE+Mh3KxhbimkZPfQBD7eC8YUH4r"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.4_1583918714810_0.16011477129117968"},"_hasShrinkwrap":false},"0.1.6":{"name":"@mgfx/connector-redis","version":"0.1.6","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.2.2","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.1.4","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"c14507bc91efbe20c6c937b193452785f2662669","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.6","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-ur9EeRhwmMIjNWhCQiPNNnRegy4P2BwEYATO5pRbyOmDBmvcrf0lpeB7Wsa6S0CNeYMj6EKD+gPeCh3PoZxtnw==","shasum":"6b97fe98c1698b1ed32b91696f87fb5a23280769","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.6.tgz","fileCount":19,"unpackedSize":32782,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeb5fhCRA9TVsSAnZWagAAtxAP/0x3RIURTD2ecHHRRTud\nuL/x1v74VR0JueANLTn2fREqT/Yihy5gB2AYtWw398LqF+EZcR3EGUnmsK52\nnpH9WORAmem6RpwaRFw5N6QgfmxeBeXFLV4TV05/gZiqkCAZ5QFcA7+uSU/L\nZlCUDiyHFugUZQj6PwplJPKQ05wZU6mEWyXBrHSsbhNESodgGWGwxAVFQPfd\nu4KJK5/fh3hetE0ed8qq5XP7Eqn3r6wyQ6rgjDMOuM8lGoRNmYVYRbDA0GTg\nZXz4pAwbU7dH5LpFUcmkJKQGWp4UxN1y+OCsoGzqFkmS4qQm0LIWNXnBKc+C\nOyDYFlr5EpbWW8qaKbbPmjmzMh36Fs0F98AsfMR1NbVBUAp20dfEQSGbRwVq\n97EmY0p8eSVs5qTN0rpfmE+0e8GlgCgKLCgRj72e6RKRU+p5fDTzZQ+k5HrU\nkcAvqOo/tAzzZz8jhAtabuWal22B7GBe9q2uU/868BNbiM/fVMx0R3XisbwD\nlzHOPaONEit6ajHhECRXtCgzipHmyPI/QIiAherDGPp4WH8aXxowfEYq137X\n8InE9uZx2sUlNsd1wkU/eM995OKbGVEfrTyAiDVqh1W97H0/nvF/89CvjYZw\nVz7nM6T5dSOrpJUwUZW/Vesc5futanMRHq3Rs7IWoTs5zG+/AV+S80pfphYM\ntBa1\r\n=y5d+\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGt+J72qf+Syk3CXfKWuvODl2hr5bzNdeynv24CcmmLsAiEAto4oay3+d8Rv7lDf47n2OBcjwZyv9bb3mRP6UVfBq8E="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.6_1584371680994_0.47920089693383106"},"_hasShrinkwrap":false},"0.1.7":{"name":"@mgfx/connector-redis","version":"0.1.7","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.3.0","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.1.5","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"6227aa9c8ea4e676901d1760b4fd304228b50a44","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.7","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-ezjMNXWnhkYAeRKdTiXDomznPwVeizbStnRRWy5MXMFwS9c28vjfdARhQEB0jYkTczVrf5N0O2rh+JqR+6Ys4Q==","shasum":"2221c838b59d7a8de437cd15effa5d51238ac32f","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.7.tgz","fileCount":19,"unpackedSize":32978,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeb8dPCRA9TVsSAnZWagAAWzcP/2RVYF8kTdHsXLni8E1W\nhbnrMfU34wsfPyveknpgZfo1N6jWCTpoHFTqaWjcbSJgZuRzLbQsTclofm+L\nAdtKzc4KFUMjMIi1EvXgMAdPSSxnSnOkgITvdsPmSF0xZByTitDj6ZnHidi3\nioNHOAfWnZf/ruCxuI2jmP6F85tJxYH4Ju+lzIBvZBDeLhVPODKGXBYIIqSO\nMBU5zi0+tEg/G+6LsGRu/FdSyxAqmUMx5bocUZ09ZfzHdGtSXJN8e1v+iXOA\nTCR/Gk3c8ayOd/oMKdjDk/uxYHK949CsrBf14Hqx8IaS4FnJdV6iuytZmy00\nXHt4waP9Y3aewMgVssRMrSGTjUFAl6IyvhYPZX+ZVUwaG1O8TjJj/SzSpfPI\nRpMWISj0O0wadF8PrKvuyYrpnq0h9txhmBIwlgu4k2t1m5heA8+FhignXIOb\nt9/cuSlXe4WeiGHJSPC9rCYx3FgXWUI0r4AMcZmjOPCJLsG7F/Lb66Xr9cN/\njcSH5UmreT+RgB30rRT81Dut0Q4m9mstcrPFfbYU5M35TOhR/Z5xoNRj/Mma\nMbcgcizZeJ3s0SredUEX+79AKR7W8XugbmWvKC5xbwSWVuL9eu8NkrY/XpKR\nmGZdhzOqfG+9UkJh08iQ6bpgYw7nLZSk14RvlJGtmoWFaMncTgiiqQjDUCxj\nxHN4\r\n=0Fp9\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBKpbWLcutkLAgmNChwmw3Fzx5NVYUPWW3pRwYXV/zZjAiBBuv6sepwRJESqX2H0WQj1jmgIhOwxbK76/6d4SyFefg=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.7_1584383823009_0.13122643833662817"},"_hasShrinkwrap":false},"0.1.8":{"name":"@mgfx/connector-redis","version":"0.1.8","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.4.0","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.0","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"72a1d24dc0e65e2df4ece919f4ad0f4898452597","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.8","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-KSRIxv3+zspDhXSYPP0PXTr9BRmbh0c4C/jc7tYNQI0SuP3nh6z7tgZB8lp8AO/9lL7MQC+cfEHK66rmeLLuZg==","shasum":"f982bd0066bfbf3bde37803ba67cf3a1c6ee09a5","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.8.tgz","fileCount":19,"unpackedSize":33174,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJegyIkCRA9TVsSAnZWagAAq6YP/1FRUQMYJEhzyQ79orKt\nJpOapsxYORPMqYsV1Ks7sDp8MH1xYZ3m7tQtNkcKcKiiJk+skpx1fx5DLNV6\nlaTiqa88g3jJ7upNHdvMJokoCbcMguaQs9U7Otn0prifjRWIVz2/TI6r2Aub\nckTKqubCSlDgFgMzGlxgNZIqQgsC29gSwssheqT3HcO/kjHzAJBZA+E7l12Z\nAHMDYUGia7GDo7sCL4juEyBHR/PuAV79WyaA+yL45XSHKYl9cigfGWowB9s0\nYH7UvKV4j8T054XVmFucOF2Z4A+CHlzxd8/rZYFEUsSCdhF6ghH2KPkTqLCI\n1AXmWvbAQk3yMd9DPwuzDbnMILYToAIDYHF3qZ24WOd+XQIvoNGDGflgSLuN\nOGXJmsdoMhF88RpOzVfyEmguVDWHL1vayW18AlhpkRBGReMU1Vo/65F2/1j8\nf3wHjNP/uO9P4MztBpHKjpso2P2L433G3C61W2N2QVWAG7bSTwqtbtYX0sGR\nX97TkwUK2VG9x47SLG/bBcGdDjsniWA41e2L575FNZkB4as+z3bVeH21hFxR\nZsUhAO+/LECRT/4jW2M+XQnM9YFLzVEt4XKus9WPL9ueliOXWk/7t2jHDzxE\n+d2DuPI2PT1S825XUcw693kaNcxA2gzORpe4Te3gnL3dSMJvJ9GnXuVq8HQL\nGlBe\r\n=k/a/\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDeJn9H7UMIKNZV8qLZ1dpMN76g3ozQbyM6Hk6ipTWZygIgbDGCgDt933ZuOE6TIFlYXOtnAaFsIB5qyKU47gSJ7YE="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.8_1585652260132_0.4713418456886418"},"_hasShrinkwrap":false},"0.1.9":{"name":"@mgfx/connector-redis","version":"0.1.9","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.4.1","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.1","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"58e232ef3d2b7e0246e6424427cb6bd0bc3c60fa","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.9","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-Inf4pn89f3oY4f4AF2cnFcG2e2oD1SWUcdRj0j09xT2t/CjCXYthK4uWaLzhowaT9ocjcmk5w/hPUR7Sig5rxg==","shasum":"fa6f489f7d98824dac66150416e8ca3feaa46f23","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.9.tgz","fileCount":19,"unpackedSize":33370,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJegyd9CRA9TVsSAnZWagAAttkP/iD3XXw8m94snVnENvp/\ngYOSCuWCNgxlkugC9+KXaC3vOa++2FUHbHm31MrJK5qqtcka4Z8fDm64/Zpc\nvxDCNAKoINZxZtNuE52C7KTDEOAm2M95L/TB5y2Y3xFe92g6y/0oJhiIhtXs\n+T36k8PbYpHNdKyDZ11cggE4rmwEgTc5Wa4S2FR4Pz6J6QRB1RHS04Ar6dbC\n8ArppgPCh4r6tc5qOELSjwxKc08sbbUDHGStNM6g38kpUwKMyyYrs99PLzk0\n7AfA+SQJrspZGJYAOIQAEnK/tv7/rkJZcYooDTd+1KP98uo4geYtd4gDupB9\nMQgdv2/vVI/H2TFxDEmKSAXyXip+QYFqgsW9iRJuAVHmFM4MMULMKhkQW0zF\nLaMIaXIxNRTilwLtwbqvXHF303SLPHD5ZFEV4/59cVNmvj6UcSTpCnAA6SL5\nZNH1S/uUioZrbe5e74Ta6nKILYqgXkhH0vZCusHbjNXxZ1VPoAz49pMPF2v1\nfI3+/WCGrZoJYpTNz264ofFs863fgzBMvU5TaTkpUr8enT78T+AnIUL83V7c\nryM3RHO5NON/t92KuT+NiCxqNn9FWZ8CmLTLIfvzbHdVacAS5yNSA7toZApg\neJtUwvhOVHTV/4DzKYRXJyWJPLlv8O9uSwDKlrbtFwK3IaLXT1JR9hoqwt5j\n9M2+\r\n=tWCW\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCJZ3/uutzUghxyLMllPPqola1LvDLgo+ev88AA9wrgXQIgTHLCp2LO6mCOFKw1LS8d8T7HjSv6gxK/phEC7PhoXeI="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.9_1585653628622_0.7873537445137884"},"_hasShrinkwrap":false},"0.1.10":{"name":"@mgfx/connector-redis","version":"0.1.10","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.5.0","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.2","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"d2e981ff3b00192b3ee0ada78a848b1daf21973b","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.10","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-YpIagSowd1POXYNJwSzZ4+EBH0UqFL4r6hNVJmqXqNdNYDyaVaCrf6IpL80X2CBhHtj7rZiJ1fVFlm3WjaIymA==","shasum":"9a17d61b3570fc81a80d03d8503616fa80ee5f35","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.10.tgz","fileCount":19,"unpackedSize":33569,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehQY5CRA9TVsSAnZWagAAG8MP/1qcqKSikYibsFm3p4SC\nKUNWt3BKLwEd2I4bgncKuYXlRqFaWAaWAfn20SRywDtqEzVbDAk5l0SMX0qN\nVt47Dhxg8oBe5+VOhsIv5Ys4VP4CYuv5MrfbfhNNGF8rsAkQs3a2xWBA7doF\n5iHlWzPmz3EOrWjSxyTIYCQwno/QZqLyoXg+WMcrxYllqHG/zk/EVp2IVojq\nAeahg5tC4FKP31pMNd3RzrU6W6um61shJEco0tNSSEzO/1oLNXHELiIshgAl\nTMa3fXp951uLIfVTEme9kTCoWM6pYgcoEVCeZ+dMBVeoVW5AQfqvxvzZnKDi\n74Zok6jSDRW44wbu6qSH7J+hGiNT72d/Vs/RxQ0WyHozztEX3JzfMIkoszOy\nNZ6c3kFmWXMbGu7RCIj9BvKcCCGedeTOOSaad+4zpcClGulrpg3YIwlxpjnK\n0Y2D/q8zn06TgkrhgfSBQ+poOrqNEZnmEgJ+nxY/dcHWAG9GNjnoOTJi161f\nMJFC/BmZGfQpI1vwv/xz9fqq4bKy3JK1RodxHM7yfT0fmXORs6WQkwoVYYw6\nydVXIHVJPF4JrhxH4OiQK2GD8EA23Xl23NaJZJsA5DSdHpBdH4mSdPUd1XAI\nuFZMgGAkBOyUR1YkrikoL+OnKI5p2wnL0TrlYGQYWPnLNOQT0ysEjVofPw1F\n5QIR\r\n=4ngq\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDUEqx2x8qaSjG0KT0YHhWTp0XPQZjejj77C/8X5PqnHAiAHGnViGaWHS7EbsATKr54bY5kgnIbAmJqbybaGUMQpQg=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.10_1585776184847_0.09110277623188767"},"_hasShrinkwrap":false},"0.1.11":{"name":"@mgfx/connector-redis","version":"0.1.11","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.5.1","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.3","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"b8c5dca9ed8ee5b9fe0e1e62267d42f7dcb921b3","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.11","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-XvMJrAhQ529IaOuSVLdr+lcNKAXIyWuT3I16hbiTLd/LOhmp9XwbBHUXxXJIW0O/uUuo4kYhL65qPl9dfOSlrA==","shasum":"6b891fef0c77deeb1054c3ed227a8a8e472df75a","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.11.tgz","fileCount":19,"unpackedSize":33768,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehYTKCRA9TVsSAnZWagAA/SQP/jlXYaXkuyZwZByCNGpN\nF77UGiMyA9E/we3QqxYymv07RsvFCJF6OLRYFqZELiS4djvtONLiY+O6kCFm\numDjwYHVFvZW/rqx2nXFWy6UExLS+BZRogaxmRUypcfCfBIAMrKKf652nDqj\nbIWeYSF2qnkDEC4bfVLobWUqW7vL3vECTyf15Oc1HeZyUSVQeaQgmTej1NPp\nF89nb0kLBfGy8eeoFecpDVYBgK8OXZ0nikJxKphQqOQmdh2JdBFwQNYc9maO\nYTKHA8QZ20o2QjFPRvL6e4e0ZPMSVhrSwBmQhOFTifaJLMC1YEUIeXxkPrsm\nw9+m/rmhNRSj8djTDom+TGefRjvZNHgIQUaHTJ+ORNT6y9TDowcHR5sLdNVf\nAqD5Y+GiPmwTuHJGUteStBtYstC6P/keiWrp1HMm5iD5VPMRVRXfglkKduk4\nuA/a09M30Uaq2sMWu6L4M8mqynEAsS90wRk/bNRThTODAk93+2LYbBJXo84n\nnP8v5iS1URKh3xBLzcBsryzQ8Y9LYZQq5Poo4T1br3lPgGb6FnxGxybVvI6Z\nPp6QbJulzkLf2MB5IP7tsdnUMNxzF9aRBylIRLR/AY3jhVMl8e9LAfUwYbcp\njDH7Fcf76s6j7oZuiBjJWl4P9MOI2/fkl8xxGNvaH79ZZw+9Z1L2+/CaH9Lp\nnypt\r\n=y11N\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCBpxk4O22dLBe+xWVSrz95ELBGuPTObmbV1oS5wKQP9gIhAJglrVIYYX+o7WODN/mwIXKoesTr7mfVVwlM7JkZFhDm"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.11_1585808586194_0.5051740992710803"},"_hasShrinkwrap":false},"0.1.12":{"name":"@mgfx/connector-redis","version":"0.1.12","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.5.2","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.4","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"2d94c42affe84d4bf217e5989314bf38c0c8e94d","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.12","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-x2mraIazhWyKHSdz92tfT6z7gpGAZvZ2J+VaOSZNOf6JF+8kw4l1rXqF7ZGO8qb0nOkNinnDuPsSmN3PAmRiaQ==","shasum":"34a101d2da03974999fea97cb902c047d10df7f6","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.12.tgz","fileCount":19,"unpackedSize":33967,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehYuYCRA9TVsSAnZWagAAKEMQAJuKO+en8UPxmaDBtA52\nNAvsykmzcHCv9ALSniT+y2NzzW+puJwGtxwOChKtIwbIEr12sxR0dTAkaMws\nY22VCoFJeWcdsCtADVgbDX98e2NaCPedDvRbbd11UXzd+p0anV2nO6B9hGS+\nRBuXZ3osdyh0OxEQLRb7FVUm1yRioQkvJvjvGgvj0kt8dBPMuAkscQ7QbDsg\nFPQwB1qXSAbjZdDTC5SwM32UAzz4Cz3KjSOXs0DEGxwnoiz0frLniYtmwFab\nV5LAo4vSe7MKps4D5McE1d6lqM5OV39zy/IS04ZSZxf3OmJJLOw1dD3DU2vy\ncbU1oSOxDMw1sAL9xt2E+sa5pXPRhbIgBLnKtFpuJ5ugg8zIxTnPYywcxqTy\nVlTL6y0QG1jxfSdf7DvTvCcvX711B7wol8pFHAVP/BfOVScPbr36WFozyiYi\nsFsmsb54yGXOt59SslwZjjPiNZsU8mtVDjwwkybuVodHZCxFO2fpmtGntXt7\nZnCdCnTzwpscugdcrIhLouLQsFSIvauYtOQpFKVtK9vzI4nkL2/ctNaDLQ1F\nxcYt+h29nbH4VouNlxEgsKKoVVzuuLktkKsWxQKnkj2/rogpMDjThBReXEvX\nCqskleRDfWtT4bkN/vzUyN6HijX65WqccfBQY+z2P7dbPGGDbIeRTAOzDFzU\nqGRn\r\n=K3eP\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD77Si3Atbb2SWLGkH/V1xSohjaAUpZkzfqkT2oDXCSCwIgGNCTBB/tXbRnoW+yJ8+WmsnlxQ3U+o4CL7+UlBzSd/g="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.12_1585810328171_0.19905405055624947"},"_hasShrinkwrap":false},"0.1.13":{"name":"@mgfx/connector-redis","version":"0.1.13","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.5.3","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.5","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"24dcc2ca860ee0a3f7996d793318aac797968b5e","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.13","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-WnivjpvsXhmc7rsudU9kfZ2pgyU7gQfA58BDOcauc/q90OhdVHKFD60es6gvwQALkd0uH9MkfhNXYixBfwubFA==","shasum":"99f9aaee783e26d1c16757a75ee62bd983039b41","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.13.tgz","fileCount":19,"unpackedSize":34166,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehZj9CRA9TVsSAnZWagAAcQwP/0yn9DbGFIYnFRVyd2tI\nGeSBIKewETuE/HhNZJgTFikXI1UlhHN9xqwRgXuSq+k9oq4gEgvKf9sjeHOV\n1T2TpzWH/WLazqKAsTXE0AsXXPpMuYyNn9mTyfqq2iy99NeXeC9r1rsVRSnh\n/VSGNEANDmq9NvAD+TG+XFGezRwnZdsTfHE7Q1EDGRPCj3u2+oGmk34OUHEA\ncy6iOyjDMQ4n23VprEHHkiRUdWnZ15f233oDKNIhd6G5yLGtOmEQm9YaRxY4\ncKBoLeggtdEWMPNyBB+4iMp7e4bQf98JsEknGESPiyKDz7m5/YF2xNx2oMsF\n0clmlcDKF+Ms3K2O2sFdF/sISs9IdWXAfgLl+udnpJ6n2wkKz8fUU9Ox51OQ\ncMnnOVyKInG+XMSYOmPBNk26sUN7XJNwqt08fQb4kK0Z+qkNsQLrzM0tsQrR\niInjlkxZVhYm8H4qu/bFrZXqZ/lyIaWwMR2LzxGaKVlVKstTbcOwLVxCgorZ\n4GkBZJqZjDFcW2BuF9T5gKPtpReiLC/qeYHvFG+asQmCjcVY9/Zrel9W/6fH\nFWsSd5DYWxj46JhF09Nn9nbjmYOHy+SB1/cWrN9YFSIHc2s8nILtr+bsOCae\nJX35jtTX5f/naxmeMm1ltWXMg3cATvQDu7Heh3wRJLUjWHW4OvbxKCKZTNN7\nfb0K\r\n=6NLn\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICcZRRDNm7LG1ElCim7wC+7JGAe09AyD4FxgqXuGAO+xAiBuolX0sl8v/9GBSy2nYFaTsP6Du0wICGpRn3AlnYhHwA=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.13_1585813757556_0.5669729584545933"},"_hasShrinkwrap":false},"0.1.14":{"name":"@mgfx/connector-redis","version":"0.1.14","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.0","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.6","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"15ba4b6d699e5e9d7c88bf07ed4ae3ecf5eb373e","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.14","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-NX13oLHKGPUdbFNCl1eXYojmVpZblTr4YvCSSSd4KoxFbJ0eCmZxpLAxDjbdPMqolFo2ZtZ08u0d/HyNsTnfKw==","shasum":"9e70c7a9caa610778ed801ae009b1a8e21760a97","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.14.tgz","fileCount":19,"unpackedSize":34365,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehzpHCRA9TVsSAnZWagAAndIQAIIQuCMuL/PgWsN2Qb7z\n251kCagd5E8/Y3jJXTRZfyqe94U5iyUoWPBLf6iB+t5lTp04jSHtmhP6/7H+\nGF5m0cz7HIitLs9hGEYgs/PIPKlSVzcWz8iFS/z+SHFmcHNU+ITXyPlZFOBx\nuv5DhG/a71QuFfzenz/8sFmXqJP+7aTVWEKU6zXqkzfbKRqM2riTXs5q3ONa\nGSoqG7ft0CQJ1BAgFgyQyAUrL/5mtJPg6U82oxMjCj9cYNf1IW3dI/qDspYk\nhZ1TmzH4ALVhRhYrdsYrs3Pgwb7dwy4arm7/8ppgnYP3DHQpyq2n+XnHdGqV\nECmwPcz/PUVmif73C1mXEIoXGjucQVUbLvpRanDgrTksN/yzpG/sXynoQZD9\nPZ5MzXNibZD/i3XDVZ0Qm4xfID/Y+fZ4hSdai2OJDcZikIDpYWH2UeqWiyjk\n3ljuoA+zuevOcSKu1UAnmCb8mSPjBXLEj7RGuFdl+tthYUjtT8Z05eoHUvR4\nCpDRnOhHtZjs7h5towrActizebDuqE4u1ecHiEOzbHpkCAcTbynyNHww/9c7\nG490scsI8twETvIDUuUa9CETeK7+yDVUssr87lLNzIVRBEvOHqNLzZl/FhAa\nRZ+0SqcdmHOEhRIxxxUwtoBNHNcDf5+74vN82fHeJdrSQNw6BKd+SCTFOl1m\nldtp\r\n=K2ip\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEEFsO0s/D2lqmGqkyl08Z267oPpo1rsquvTPhL0f8lwAiASR5n4AsxaTwN+ncB2NCo3YTzOlAuMGGC4DIfo+bOsQA=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.14_1585920582528_0.3550548502871682"},"_hasShrinkwrap":false},"0.1.15":{"name":"@mgfx/connector-redis","version":"0.1.15","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.1","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.7","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"635d0d0d60c6b4cc2fffa46fd6161921ca4ade35","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.15","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-HM4iIh1P8Uwe4qqPUxur1q+EuQP07zyP9SNhuhalw0uXsfxbYg7sfqedHkRPyg9xmRfF1pWgXElad8xMZIENGw==","shasum":"c6cabf7ef6abb74a0626b5e30f2a7ea442e7200f","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.15.tgz","fileCount":19,"unpackedSize":34564,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJejaG0CRA9TVsSAnZWagAA0VUP/RcyOFmyTV9ORq7w/cRV\ncLFieAacxJ0nR43FqkjGt/8iDr42iJPmO/ioQ8lXL+re09sVqE3Y0QwhsT2J\nlsm/zO0HxR7RKgjmhggzQAD9xPQTBmKHUJzocvRLjCQy4yTKUZAOiulOa6Q4\ni8OQwCqSBnbSxWkYXWPPHwyyM/GH1gYHg9cJMYYhKV/gUX+LJM6TP/hAdnTu\nQoyHezGqWra7w6HznqrAP2ltEqMnI34z8S9CTQOOcy0fCaKKuRiDjOSw3/a/\nsHTtFNeABxZ0oTslnDRHggsJh5lVn9FvqkNQYI38VpFxVn6fzX2hxNl3kSz4\nOCxkwMQQaknw2fhii5OZKxvlYhFfa1blRe1eQeVsaYcEW8cWoeg2OoP+d1Op\nYgFHj0wpGA7swz58FgYpUho7y6ROdRbIVGjoC+Iex/IAr1SqB1riALy8XIlB\nmDbEOogoN5AnykmBJxIIP/b2vZjWlZO+X44eijuOE55dfPv37eXRpbWGLfRH\nH1tEJwNxdNZPLidOQklVBbQgxjwBm1NnOEGmALvkFLUNqpCwc46Hv2pBpMRj\n1SjvZQDUYhjx9useJOzf1kmWeSNoab2HoEwN8WtE6muZjv9zVdyhVHG5QPfw\nm7ti1KM/k/iG8k+ofVzJanou1o7WeTS9JO8WGloRM0PwnGO+By2Jm06x0C2B\nQfuY\r\n=8m6O\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFgSMtJQ1ZOlnNhyPdNyRVCpgoKosSslKIbvggktkCJzAiBZILI/JnQuCvwOh307y9wOs3vUBUdlAz1rUgwX98xS7w=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.15_1586340275877_0.1168168351724943"},"_hasShrinkwrap":false},"0.1.16":{"name":"@mgfx/connector-redis","version":"0.1.16","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.1","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.2","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.8","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"11172205ebb9da77017ad9a49749579efff4782e","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.16","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-zo2RJC+LxaA5KrZETz/L5BkCsFdlCzcVavS39QSsCJdP2Sl1KaZNB/ZLt42rjo6/nwqtfGgMwcquuQjp0jJbfw==","shasum":"8d2d2e01e66364d6eb3e0c32dc91598a816c4454","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.16.tgz","fileCount":19,"unpackedSize":34958,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJejh+CCRA9TVsSAnZWagAAgZ4P/jddG5E0cFULtGafbJ2Z\n0gAZjDevG6b61iDF8iDHBign0zotVV8ci1T8H4CyoArSYD7uZnnzqacWpwb/\nuPRrAnrixswDjXX9sRgx0PdybVBEqu/WeKg0d1Oxw1R+tI31zVTwdDlNZQAx\n6mLbnZMi/epBBVT0FTR/X6pyWQ8Gg3Nqyyhuodd+us58PILz4hrrQTG7v+h+\nMA0xuzFNAy2ubQJ0eKi6TkZJyqL+7pFfFopHecdwf8oeWkKZxctMw5lvC/BT\nn1fHOnhmH9wBO139aNR0SCbGFAK4nHhOUmPzf2f1AXKxb79Jb5ZKWCd+YvI5\nckN/UK3YFtTQePSDFpIdMKZgmPBXWjb6AnoaTmiJoTeVjZSUsaPU+PPpy+Pb\nemsw5jI2PK0YOLucmiNDX/+DVTf8Xd+F+C+fuL+agKrCQ50susCaHtusIkf6\nyqgoyX6mSRjXzKnBSfEVz+Eyqe2yHeq31YlCjPK2wnuruir6vRLRddJ5+4uH\nhS3I3nyCE4J+oLGt8DSzH79qtCM/t4vRFwQi27AVicaaIn3wEuZgXLgdeMkc\nfgN6Y4SKRuz7+OjOp4WqdzP3blL/qOuMWfr7pze6eaR/Fo2E7a/fYidzKhxU\ncZsh5qQoK9vTXtxChrgWp1EIDW7PZnQPgMqhP3MedCdK0nTk2Cl2X6SxH9fZ\nU7m+\r\n=RSIn\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCYrcjtJrw8n23pZkd2WjnTJLMcVK1R/owS3259EiZUewIge1pml8r/7rUYdNbwamJ9Cg1N2Drsiwa8bpej4gqcxZI="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.16_1586372482570_0.8402955339054061"},"_hasShrinkwrap":false},"0.1.17":{"name":"@mgfx/connector-redis","version":"0.1.17","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.2","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.3","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.9","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"f6520add9e4d9ec7abad887cdbaedcfc4a3b2030","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.17","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-NnTGxeyuHmpkofoumHuTS8ZvXncEtzCKQhDiVLB1Sp/VVVlBxLMvrsh3tq+9xs8Cg4FI9QFui1XR6u82h5QKqg==","shasum":"b7d83e8c8fba4f6d5bc389d6dccbf5083b41af1b","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.17.tgz","fileCount":19,"unpackedSize":35049,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJerEOlCRA9TVsSAnZWagAA0ikP/A4KWXO9Zt4uMDeJ5p+1\nJSZfG+AuQO0UvlTKG4ySLkvVsmWdZPXsQe2V+eQgPvulrErpqdLO3Cg7I9Ll\n3fqVLu8jFoiNBqbF790aJFprBb1fL8J/6AL7GMPL/iVArAYptD8fCTmHjrQe\ngZrjddcANA9gpocrKvaUD3WeuElYhDI81AJ8hdBzJAwP+faD/Fpp+bWnwGyL\njpbKxeigULYCdmRUuZjjRz0H1uzpP7qh4ZkNhk6CtgcTgJYBrHBLCEGsfN37\nLTlv44kma+QNkCL6c1kcHivnOq8uhCeLHE/pjP0Z8OTPH1STMskmC4RBiIf0\ne6Ep/jHDQ+1p+wn7RbM9EwwRXEgFroRxy/66z7S0SLK7r8wUSgW61YulIQtn\n2viPGwLBAnH03tlKbiXJy4i5jE7+rH7qhBVmiWBD/Cjp5fETev1uMeCKErqq\n1kGjWseqjDfS6IpCblqEVNBxj7lxFQZTX+ifU4uJ8DhbW+DGDjhtao8tsSFu\nbFf5m9wvPIKLNN6HOZbo1pkN1o/JzVvoJoBbZFXjhHsXFuRn0Z9JABgBsVLm\nO+VvvyJVu1uhuKWrNiSErVVrgRtbx7+zBkh6d6TwVDuKIW2DgHTk+eNCSAoa\nG+AipigZrqlmeTZAnZ9elodXwqN6Pv1FjgKDiT7IL4parxV2XVOrRzmZIfRt\nP/+M\r\n=DQPD\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDCswWpN1mrSF8ts1kasT6X2UThckKOYMWBdygvx5dTbgIgbg64X2YA8UZsHEE2yu/c0Myb3gvpdch4p52pGBkza/o="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.17_1588347812505_0.026594944562637668"},"_hasShrinkwrap":false},"0.1.18":{"name":"@mgfx/connector-redis","version":"0.1.18","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.3","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.4","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.10","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"126cc3d108107d365904499131d18ceb558ff99a","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.18","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-u5TzBzwtrlGwmLgcg0SXcx1/X7h6wWoVdcpLxoUQr06BBhJyqIfwkTISgFNN5P0lpg4bT4HRNG4kftVOymmXZA==","shasum":"454ea4de65c02999212b936c6e3dcb3d59058c09","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.18.tgz","fileCount":19,"unpackedSize":35141,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJerEnFCRA9TVsSAnZWagAAoHsP/j8CaaSzeeBUpj6BHwcY\nnkzpEBqLLDGHVzs8FC64UP90EIN1orlnuXyHVygPz2yUQoySYeCrTMWJtYoV\nnqJBfzF177K86Po9Z18UIlkv3TkK54uvqus4f/29lVAjeP2V5cfrv5ZPYih3\npAmctygWn4g4qSO4Dtq2UFjKnaMs54u85WFlCnAWBSeTOMoq+TJTuHoR/EDh\np1NRsTekVO+UhbncvnngQ+f1lRL4IcLgqfBzejKXRyV3IlSaxC1u/i2j8MG0\nr6JVi3llngB8rTogT+0/wYG2jINuWWYW4jnwy7v9qB3PPJWODxfmWE/Jcaz1\nVSFZrKO31Qv+trboCyYSvVLFdTLkTsKVIr2eQ/p6b3ebOc2Yl1qHc3Jn3mdH\nNuW6IHtH3BzBY/SBA+cU7PfDb/2Koix5J2bBi/nimBjYp2NswgT1RltUrbb5\nxHZtn+1Bg1qxA+mO5xTVd6apfI5OBn2DBZmNGs1s0/sY+OC3RhVsjoikEliv\nPczOTifOXt2mJO0jmlPypjdcb9WEgc0ZiY3Tm6YFx8XZs4sP9whixEaqrLNX\nNT1jzH3g2FzzCS07G2qXulsnIVBAKHswfHOveOupjnG+oosm2Tw8R/J/ITf+\nyISkmbHjWLXMGhjUzsxUv3wVFDxvXOwZknqDn3T1TMvwB37z0OST1VQGX9pj\nrju1\r\n=h+t5\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHt5P8EGz01AXhR6LlAOopVYHBAC6i6QxZHv8owlPga0AiBEzC5XbLAWq67A4WkR4VYZyXV3aZlsreW6Vt/LsDuZpw=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.18_1588349381443_0.4271860752788652"},"_hasShrinkwrap":false},"0.1.19":{"name":"@mgfx/connector-redis","version":"0.1.19","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.4","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.5","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.11","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"45d90110f854015a3024a73d0db9c0ec32185d27","_id":"@mgfx/connector-redis@0.1.19","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-20JNhJUm/giepZ1WawU2Wh3q6Eh1X342rDZbIqp/j1RLpAblyW9vjoXG60NPRk3YdcKlFQS/BEQRD10F7ZDViQ==","shasum":"5cb51d9d0e383d591e0ea5fdaa433adec845bb8e","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.19.tgz","fileCount":19,"unpackedSize":35232,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJerFD4CRA9TVsSAnZWagAAQxYP/iY/JfbjFOHoBUg8bAZw\nP461LIjz6HmzscdUqeS/N8DF639orL1uexUZW46Xyua1C1mOkw9RaeKziJMP\nY5ftZ2l2fvkjatJjziWnis4x88Vnk4ID0kkD2+eGX+4+rPUcQvG45AIPHosY\niW5IZLQMqFXjdQRYNMFd1Ue5JFCv3sUovUir5FGhnIK7/fUp/ThfExVfnYjT\nERDasz2mx+i0VAEe/QmCxa+36KkbbQwErcWWIIEneeWO8Gp/zetz8XL9HmPk\n8f1+zI5nc9NXefTuBbS+tH7hlzoIThUcVaubv/qo4vwmfgEie5I7qEVa8oDs\nUswe3MfLWefZyHFSdsiyCqpOMQy1XQ1gaZQZ8lPat3irV/Kglnd38eDQ6dAT\na9Z58CFp3M99J7hIq3xpJL4zU/ENQvWXwjOfXs09JrVKGJxVOgFr/UjTKPUT\n5/3D39HEgKuHmby/r1Xtv66GM8G2BtDhSw8+eCqaRKjSsGVr3tpbk/nUJdfl\n7MOUSdgBU6a2OPrz4MAk6Rc5M5njbuJIxWIZcPeXrXP5YIupLSJVy8fe1wbK\nzshYUf1JpG2y42AKUBls9jhPofUpAxNQptpo3y50hIK++Ylq6aKQXHNz5Lai\nX1da2HaxqnZ2wInyJWkJEIpQPimrJHdJ3vqnvvbFgQ2609uux4IXCUaFHgtY\nbpju\r\n=F7g7\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCLraS10wPomGqJ31rFukKKds+Vi+wmj+tdIuLWX2sLYAIgRTK2PxQIyw4bVBBwC7PHT642NyAfI/bH2O6kNJnZPrI="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.19_1588351224384_0.9582118552445709"},"_hasShrinkwrap":false},"0.1.20":{"name":"@mgfx/connector-redis","version":"0.1.20","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.5","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.6","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.12","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"df9fa5589e4c78a1e69000b2c9b294833287b320","_id":"@mgfx/connector-redis@0.1.20","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-CvDDfCMwR1yGuMWsismZT95gu5awp82ng6vfflCIDHsyDQKvPKdWXgTqM8rPx2d7ZEUzvzgH4ElJBBAedI1mxA==","shasum":"51a67c682b9fbfa10ee15269bc0ea020b1fe68b5","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.20.tgz","fileCount":19,"unpackedSize":35323,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJesYSVCRA9TVsSAnZWagAAz/sP/ApdRiJOLz+bP7DJf5yh\noG48OEkZvMKeIn8IoewtH45eMS5Fj8veo7LCow3LNMEWoX6PTT6Xnue0gjDJ\nTSUpTssKalYX4qFqM3NCymx77V8XKtmAOYg22+9naloYpiG9Iq/0R8mYAeCX\nQhYh2vtCUm2h3GdcdxgIVBXHRiek6GIsYcJO2gXjxIG5FQpFhY7ARZXCxVov\nDmbDD1DFvyw0YtcEAqvP7fetKSXdqBTrNCLTyAPbHVlfnkSNGFpcdtlv/74W\nyBeKpdzjjj06BitaxkCHZnzMg8nxHCOcfnuV/IoGG8BN26hRFvE1IGUwYntr\nXPOhA4vm4EKidlrY8h4oMlYy+8OdDV+bAoaOSeWxoI4194iYDN0lhKIe50Ye\nPT1logQqFONYfCwVBro8Rj0jY70GsehlrcHa2PQ/YXBsaqmfc5dt0D71YGo9\ng7aSQRMlcplrEpa/yY9fFjua5UUMy/+XD38jNb40cYr6bkwxv666ZQOxkJ84\nRQnDpghgl5lOFMyUxj4CVcshZM/v/Ccea8rG2CMS3TEljfmFCzivH1Khd219\nbDEVbifKyRcuqc+YHu8knjzD8UswwPvW0UW9qduCeQSoiKWu3QSZhfynGEbu\nWa+K7pXv8TtyoRar5+u+UsZFHTjYAWfwPmtXR1Vvr0NaW9iti87wAWZ5Cap6\n6UlT\r\n=L2Tb\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD9yeFKbuVOk32FTklCORaNDcoicUlQ8q0MOQekPokMZwIgQwuOZiGnfc1Yz2y2cSMec/KVHNDMOuxhOceiB/BDKo0="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.20_1588692117442_0.9700039639980558"},"_hasShrinkwrap":false},"0.1.21":{"name":"@mgfx/connector-redis","version":"0.1.21","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.6","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.7","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.13","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"727554a4f702a9c468e3fbb4b823ebc9ae45e633","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.21","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-PZwoNvG8BrLvrp8JpPFKwr0UQc3pBR0+cvI4C7jPC2AS/NsqHfAbpPTo6renIpyyp1hp18K1rcYPKQOtvylh+Q==","shasum":"b767f98e4d7c9a203b808dabe05b8c49eb3be24c","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.21.tgz","fileCount":19,"unpackedSize":35414,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJes9x4CRA9TVsSAnZWagAA12wP/jWbhe7LiyN3ljwAiSNt\nxSugz8SjrTrqrSyWlM4rYi+PouZwgenoTV9yAJoX4zEqy7e7howrq2KdjZd/\nAQbsBm8UUsg3lyJq5VrbTS5EG5qa1i9HcUMuMcvd0aY8nId7PYFBIqZl/Vrx\niuel6sAtRowY7IkEO6ouG2HY6a+nFJTwoxr3Wo9NtOd2IUmZq/L1U36B4psU\nupNz/U1orH5cYdHMVFBvFp6uRw0bfG9XwQhJ2clJIzL6IGTuuLDSeKHNVXdz\nV+D5JkwP6kWz6hcN0ii6pA1/4Dw0MN2WWW2xPtzFv/OmeQ30AmcGzmD9rMEp\n8ffNc/+paPvyDpiJtMUVHM9bkp8uLucfxdlliS4KTCUEzyDrB5l9WgABxY5x\njiArmWEkX16t5ayDyV4iK0XlpRYg0k6lLH0+Q0pCa9BDEXv5RdxcPRGPJH9W\nUrGHKmqUIf6MSzlWC1pxb34AlO4ZySqn396XD6dxWLDL+8TkJR0lLZQVByv4\n1hYGHkV6YSaBcaJNv57yec+V6iQEbc3/et8ZGRjaSt5fUFVIWhuAdjiSBTgr\ns+T5QwBeu7NKMZnkLW305hSgZB9zpaMnTT8vvjDUAdCbnl082NbT2ba3K1yi\nBxkuD0uQsmrPVNnXDhii6LFQcZUgZ1LBH8lISD7NG/v5mGl3edjJ7JrjRApa\nz3Hj\r\n=TXJh\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDNrxsfzXbB8r6qO+UPCtmae4tGuJEexOEIdr1P4deyjAIgUUKu43+i0mHUbF/c0l72qIPIL50jsbLDAt5FbQ662JM="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.21_1588845688198_0.008655276738489759"},"_hasShrinkwrap":false},"0.1.22":{"name":"@mgfx/connector-redis","version":"0.1.22","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.7","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.8","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.14","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"2ac179b7b5767c471c90d4c43dba5840313321e2","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.22","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-ae+BoRsGKqHedFpsLA1hm2OetRQ0TlSq4q45FVheTVMzbvrVTJsqMb3MqMYayde0a08xX9U5Bz/3v+laJpJD3g==","shasum":"1906af8120be41e71e4676b24211f77da9157a25","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.22.tgz","fileCount":19,"unpackedSize":35505,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeu9KmCRA9TVsSAnZWagAAmAkP/A9/jjMQIBW/eHc5Wv/A\n7TCq9bw7Dz/H7ipOljLZUK1jaiugK+m4/3A7a4zqnS23Q12IE7QvBobzath7\nSl7Gq5VcEsw+nS9FuNjDZSLh3ux7k8aq91Exc25QROxs6sZNBiRL/W9Guhyw\nS1FJH4HPl5qHNX6u5DV1YEQ3KUMOWvXSSlhfrtdWkwl721GKievRtPdQ8vWb\nluaOhgz4a2pfBiIJ0kBpAcyqcXOMMbBbtuJsuFf4c+WwDB865xpWUAuHZTKy\n9wDRRJWaY6Zg1m4Aw11K5cmVaZ+vt2AtwYtcDEgMWx6Qid9vAmpXiqT6EjjQ\nq6dfu3+sXZyUmJ3BW3/DnEM5xbPSDiEzR7S0TFSLHzAAimqqyQWDtLu1I9gE\ncYg81MeiN3lzqCSKvuGtS1J73ApjXcopTiRWK9eZYayVNIwgtz01h36gm1/T\ntn4Nvs/OFnw1kZzUZkkg5DVZL+IU7loryGA+6fb9r9ckwPnUYAtbnMISVlMm\npwl9+J0hS5odeDChlQ+Yg5jUDNrc/BYEjEVjVBNqTZ5ndUokvpqIYPembpPA\npjZDjBdb/VMueu0kvz9sJAmqPXUscXLBtUEooBPz6xRVLNGpzlq3gqbZt0fH\nu7zx9ewRwGK8HcbaTmFFncMBxtXzLaxN1VfON1fK9SD9UgMeKHw5gByuobEF\nPdHG\r\n=ITlB\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDqo/6ki4t/rgA0ljhmP1cXew7jFOuZTJbBWeLHMCspdQIhALV20dUxz3PtjBwRid95J5slzWIXnbSf9g4lpkmSPyAA"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.22_1589367461986_0.9931250935932641"},"_hasShrinkwrap":false},"0.1.23":{"name":"@mgfx/connector-redis","version":"0.1.23","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.8","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.9","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.15","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"ad1b585f3a201b4a8a2d3fdf97c7ae7a3e9c0a36","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.23","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-oAazWha4b9eMnahWYY3b9yMaMDXTximMHye6+KGDiDoF5wxC3QCEiSm7kcgnnZ/bYlzujvWPneurj6PabwrvhA==","shasum":"4312e76842770827c49f1ab43196f5ad7563fd5a","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.23.tgz","fileCount":19,"unpackedSize":35596,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJewl0GCRA9TVsSAnZWagAA1qMP/3O6FgLc/rCFMfdissE/\n7+8fjM+7rxhHIiMohAGj6MHrQri+f1HqhBaKy1XrLVfOLKH6JYJbhBeMxkdv\nwtS1EPyio4fB/S0YhKGy0vFQl028j42bW3fim52DmhWhSt5C3vCd4bZpv3Bc\nWNDY26Ciwe8ZitoXl213IhX9EV5kuAr4CvsBktFBs4jSjy88MHgslX/wIPX3\nDQ6OahwZ0JMnXlyLgzrqV8qkkdb2aPgIARQtsmk4t5etU6AixBgTesiW/s0E\n/Z57N4ILd9XYk+nP8hlBVwl8asdManuv1acoKv8UnByMhvk14lNfuJR3nA17\n0AxiKDg4mImDphG+Vcvwrlu2uvAuE0iMRucoBBaMJhOcoNkd7xxbMlgI4NaY\nF77u52t+ML2LTuvUhEniRCtrVf4Xky66yjmzc4oi5BLwY3NX1kj0oSKdTOWY\n0t4JwOqV8G+ZsTtIGRdhgtjYdsG5dfoek1cxVqA2pFgvq89LhAJ7hxSApwwb\nL5vhcCOOKMBG+fX4l5AqY+m/TPXRpCEHZOgtvB9qVptBUQ7kjEFiVq6d812s\nw4M+CNjO5F9HR8T44kbO7tIVbjNq3FVUXods791IgqTaMdUxbGZ/EPLu+x5W\ncv0bsQOio2efZ8zE4/rLMYYaJSzhDp+gU9DYKWdIRekZBzus7A0hSFcax4Bc\nt106\r\n=pdSq\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIA7g9vp5KrBDJXDcNeIUN1ixxV1OZ/ql25gENjQR7VY7AiEAvGtrA3Rt8t7qyLL0Zf7NnxC1Gdliaa4NinoGHZoYy/Y="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.23_1589796101843_0.5911225208551529"},"_hasShrinkwrap":false},"0.1.24":{"name":"@mgfx/connector-redis","version":"0.1.24","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.9","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.10","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.16","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"39e3c702b5c04c072c5e13056833c3e841d81706","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.24","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-TzH3Nusqg36A9NErWoeCjNMFl7LFt7ajrGDHxy60hDcWWb4bRO9kDjWL0/g1sr8hH4694GgUp8yIh09NJzdGkQ==","shasum":"e5bd16d4cd3ade567247094713c3d5c02e0cd479","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.24.tgz","fileCount":19,"unpackedSize":35688,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJew+MUCRA9TVsSAnZWagAA/SQP/RNYZpiu0L43sTmpt3Sz\n4/POahJ7FrlZQ065y3qV8XPDnTZLUb3U2TLhRneIo0ilcZhEBW6NzrTPDuKE\ne3YvVT85od51XU1tddxXvqCUNzYjuezWxwJw4UCAp2TaupKoRmJKLhA1PAd+\nir2kxwsbF9bZWQxf9ZLq0ruv4WN1NJNYLCpV1lB1RQyPXPApk9jG5lYXJL+T\nTGo6Yvw+0LhDcH5CY8N3u5FUYAJ+PLHsHqGzAlqh/mLqDuKlomqcKT7SoQf5\nCfN57r0fMJ+4fFfRrypuejd2nMvN+N6nuw7qquBUc+lDrpU/E+TS/UcIvWW4\nGHg/DAX1GlAtHQxI6VoxsIsTz8Tj6J/6btfFIEMVTQeC5V37c6ar81cugEvD\n4s8Pidm4ukQlKGJM2KC8lSXgn2yOVH/d/dzpXECnMNE0bLFCXMwbL+e63MD4\nMXDJ/YWEyVPAFmBKOxmaIhwv747h4H4GPggMmFOCKAK5mYAeb4/GNXTAMuZX\naORC3a1DzVCxBqP7098fee0YPSLUYop9BJim0lMwCrxE9YJZ3Rxf1TCe1IjO\np/zgplQkJvIj0joCDvrxFjXIfHs/p8mBIYmvsD7bs24eFRjCXqTGjhYAAwMY\nRj+HkamJwyEaPJ0qOZ8Z8n8dIG7cbxPrU3I9rvpMTT+o8SM++ynT9cMQrYaq\ndcNm\r\n=X0x1\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDLTGaLMtkfgZ8mQYQCWc5tMiF4c+1t2MIbslTNOCOdQAIgVLg126FaBodEx6d81l9IZPn4H/mm5d3xzT9fHKxRJC0="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.24_1589895956449_0.03358619087733783"},"_hasShrinkwrap":false},"0.1.25":{"name":"@mgfx/connector-redis","version":"0.1.25","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.10","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.11","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.17","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"580f4eec1e135c346013dd2338b2ed7cd876ad74","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.25","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-q61Umg3rGAonT0GR2kUoKjJdaqm5nwI7oNoi2ogieYSEptOTRD8QcRsKm8X+OFG01T26qCVFNahefT1GeJrXnw==","shasum":"a73212c6909c3721beaf8ce8483a79acbca54fba","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.25.tgz","fileCount":19,"unpackedSize":35780,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJexABdCRA9TVsSAnZWagAAs7oP/0nKm1qy+PjfGLPsyfZi\n+GjS8+zLqvFw0LODlRvEiKqwzCc7xiV/ZZzhzsTqoZUraswmFx2AbAgR1jtG\nnmHAHNOUohEGPrBWKpZa3jXkzDpeHeJ3+TAOF42lpIC4lcPsSxAXbmq0cee2\nsp04tNeyglRQFgQIg0xZTjEaIc787bE2vG3gX4E1Isc4uRTQE/7WwcIKQ+i1\nXr6ObjjV1lZmr0gH2wXtfNETnuvrgsbUuCQCvoDzAcSOFbewvK3fPGJpQKc8\nENvSPbOtfIvW/ZjHMDweJPV7MOw+7T//PClv4/rqhYlyKh03QDSpTdwHdsh5\nsvCpU+S9dohB5rteb0pjEFqqTV+t0RoozoS4QV6q7vKuyjMqdovE8SO+iyqU\nzITzb7ypes/GX6kQtF5Dyg15fvh1yx0hMWh2QplE7dfKGd1sBM5nLSAUnZNL\nfEKCIVWz0Z8LDD+2Mtwj8cgvFBmaOSKiaBxgws4yg0g/h9yNAeJ6CtEiYJM5\nI2k0/wbb6K3y2PjI4w160OLvaE+L08w1GGh94ExMa0Ub7vNDQXnGsOXLwvEN\nYfwh9V1z+nxQk7btsvx0nII7kbwtNCsbU2EFHmn5yqzQ/N9NfHgk6u1NHtmT\nrz1UCeNoS6kAbQiwZkRr6sxswhaOqKFmcBa9r5ehQeBiQLrE7If9TZB1bezX\nUe0l\r\n=UhiF\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDqCn3Mv5VcRfpWzZQRwlvQl8nZMc/tiEHv0I/feyGzoAIhANiDBnRRW2mC7ORm/WcDgGYl+mZlgZmci7EhEWkjh9b4"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.25_1589903452905_0.02630889802214398"},"_hasShrinkwrap":false},"0.1.26":{"name":"@mgfx/connector-redis","version":"0.1.26","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.11","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.12","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.18","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"20d5b8a8438c93289389b8c4e7914b7342e4e387","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.26","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-YbVnTHMamxBlrnY28O8d76gcVTNbJhen81tQ27+2cTM5q+JMkUrV8lEI/WrkpWYDIWOMC60kosV91Iy74vH9rA==","shasum":"7ceed483f7202ea231a05ef048f682e0358f7b78","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.26.tgz","fileCount":19,"unpackedSize":35871,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJexoNACRA9TVsSAnZWagAAN5cQAIHOihI+2IGJ0FRF+qrV\n7WsGuN/Co5OaC8HdpJYi02oTjv828PQjLqdez6WoXrQk88FXiPUxO3K4F1ws\nf65Xh/pTKpVcHz4+oARt13uAvcMi72CI8EBlHXxMK8+0gHsIFO+yyQr4mDEx\nHNBJs6y2qEfI7mdQDZXI6VA/FY5rxdmqBEeA+vzUno2lL34HmInt/SGgDWRn\nrdqgozmnKB+HWilRfD24pM5JH0BBd9i8VY6/uKX/PRMHGCw8fTMEPzsFREu4\nxDDlZZh9w7B4J8PHCmYHPKr2yJU5NyB7hdj7ImqQbakmXgcYBzJDfqUPXrgD\nayIP9MNxnO0xmzzzpEI/KhmI5RSXfLHNAyl9gnqfmrSJ09VDtCXp4eRDifG8\nqxollmmhFIFLfAMvecybGXCCWHhv/lCuQPQDiUM5D7wlglijQEvbt9cj6PGh\nyvg29aopQzY2+tgFvwgqxjRlETbjR0LOUEaELOterBLKQQBnMQlM75P/sNWw\nv4pt75S7UZ4Cu1cmdCdcASHCz0R5FwfU6yTEqS4Rj7sPHOIlGC46qumBR8+e\n1hewpkxaYJX8Kp0aWzBDCWqyCkg2s1QX3fuUNe9UN4BN2L4dxN7Kp1evsMUz\nEmhTCA+x8w6eKz6GrwCdizmOs+l/nck5sIqCLUIZlDFStD19rSJ1xvoxEtoo\nGeNd\r\n=SggN\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIECSNPiIx2q1Xpc/DDVBvvxkIyMMEtttoWpIeJCpAQunAiBx9Wz6QcXa5a80CM+seSl1sdYQEfzPg0jH80VuAxyArQ=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.26_1590068031925_0.6744432381545287"},"_hasShrinkwrap":false},"0.1.27":{"name":"@mgfx/connector-redis","version":"0.1.27","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.12","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.13","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.19","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"d9792140e08f621c3d28ac8d62377644097db638","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.27","_nodeVersion":"14.3.0","_npmVersion":"lerna/3.16.4/node@v14.3.0+x64 (linux)","dist":{"integrity":"sha512-i24d8T4U3/zeU5FT4Jhfb7djYOGMhcgSFsbQuFnNWegEyHt8sqvQUqLrDWcWSb4jVy0Ygv24MDOKESuoaC+a2A==","shasum":"1e8e393df2183ed91cf4670632987104b67948d1","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.27.tgz","fileCount":19,"unpackedSize":35962,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe14nvCRA9TVsSAnZWagAAjxsP/iTxa8TnY1ZR6+1maJPN\ndcWVNfaQO/mH3Kjtx3QVcSMA8pYgIfUMahk7rBy8sZebYrg7C4xQEtSblmwS\nWdY10MAGWTjTL9tSfixU8N6C4a/4UdpzGDgIUFrjqNp07lXXEdZK3iqwtdQW\nDqbdHzL3bba0O9hWwYp123RDeP4aXb4cba3Rmr7SXpFAC6YiaifGfiecc+jb\naKsHGsP3sshYggODHQB2pWHNDiYwFbi3lv+eQ7fX0aGaFh39g/DMy9GdtbnD\num/sRAFNkZfnbyAtyKOC0Dvaz+PePK6KavtMFdqXrOZBiB2zcIotZVx9pldZ\ngP4x/vyyDDezbrq0e4jZchoMmDaXXHv9OWtgsAfSsKimEmogSQC8bZr6oVpv\nKY/qqpPbTp953ZExFkn58PrFZ1c4irUDn9T6IVKCfvKK8VT3W3GXEawJZXKB\nekN0D7ZlHAjOhM+15ZGyFMnz2m3e6JSt0HCdkTTvPxU784lI8DrJUzGsROli\n05hQSrTpUxpfJ/1DxrqYbk1U4yXbm1cqMMM3eRvmiq+XEueEd8xduN3qs4DU\nDPNI1llG3/NQFeV7+WLz0rjaxzivxR7LbvW7jo3z/eqqvkClUhiMpSy8Z6UH\nc3bFkHF4A8/e/+BTjYMhPwyPuv8xQNnRJzNNUdMVEhDZ+goHw8hJhBSYgF6l\ng7NH\r\n=wt4Z\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDVtjWQP3VliV5yeBe9hNguuv5/jlCGbnRjDbjIGnV2swIgRG5U2F6AIYIjD/ezofIowuUTB5DnqGBnvdltjabueN8="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.27_1591183855085_0.37654279709161087"},"_hasShrinkwrap":false},"0.1.28":{"name":"@mgfx/connector-redis","version":"0.1.28","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.13","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.14","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.20","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"1e6eb6297e11dfc5c67051f120f4420b5e4d1d2d","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.28","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-OGKIW8k4qcZLJuNUNdN9U67CkZX7dQBUeY7Rn8DMyR/+3mXUtpwqCkNh/vqgOehZJKTgEJiDwINNwLnWHfrteQ==","shasum":"6911d96fdf059b4d882d23cdd4b2b75ad09b11e7","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.28.tgz","fileCount":19,"unpackedSize":36053,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe9NO7CRA9TVsSAnZWagAAP6oQAIM5Mit4p0hEVKWeZNSh\nohuBxwvNVI2+F9Ofb3OciZtTytGineU/tbqHcZafaA3CD4/RB32kcS6XqhAB\nHdqumBrstY2jhCnUI1BUiZ24lBNYRYrP/xJmiBP4/M6PWTrsxhfoktYcrMcb\nEWqQmqVN7VTR9hMPISmQkU4vJuLnCH+anduciHmMcauF3IY9q7vYtcionmx4\nqIXWnXk+kVslzRxzSkCPx6lkdFTwWmBIgnxRT97smdE6EA7/Nu7GCjW8s3wE\niVn5+xIjXVV7BVShskUyrBXk9GxaMK3ZHZ/zUwztCebdDijD5limeKcRjRyh\n1MRJ+S+kQiQld9P79SVZhZQh30PEVkGsvU6yB0vJpnfYT48dxzlOR/60WhZS\n8L+N6Lx88IAFJZB1v8wJNGM5ZSYqH2oNUQWwozDFA3qQ9s8vZ8TKAoJ66cAC\nmccnyLjo+anIcsjJFVec3We63J7Pk6pIWVCl15GjzJ9cKJQwePDnXNjcoIe5\njnNNgsVgFE9+Ueskv2Yy+UK4Id6yQq3LUcw2tTxY/c79rxuc2P5z+opnimDg\nPCbxYAWyHEWtqLkx9eoIR7h5DCZWW48gLkzxvtrqbKg9HMjlYRP0DJxytNBq\ngH7Xwp/EiaBPl0670U7/YHh2tPs7SRusSaBZG5TgidZIliDNtJI8zvxhcX0h\nzTfI\r\n=wSu5\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAHO76Tw+yPHXpqnOjCUi5DYJ78rekDBMXiE1h3XMe5qAiAdxaluaA+fHeuu6y6byWufh0gsx2b8LZ9dz3NjBnwrmQ=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.28_1593103290941_0.7846160080561131"},"_hasShrinkwrap":false},"0.1.29":{"name":"@mgfx/connector-redis","version":"0.1.29","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.14","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.15","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.21","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"7aaf043b9c745f39ca971ccf1d2f0334d5956433","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.29","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-9NVz2lWGddxJogBJb6Z0OPTh+R5z64oz6Vmvm9iMqSuJlQ32rlXpcCrHgBUiSrPrW2WrTMBwjq2vj9Yje+OhNg==","shasum":"1e9d92da4ba144b44f4c4fc65254f2a91588b4f9","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.29.tgz","fileCount":19,"unpackedSize":36233,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe9NoyCRA9TVsSAnZWagAAqDQP/02es23PMYOsWSMRZP2Z\nhyc47kEs9eJItJWy+4CH8JUvPuvbKXuLJqlYSSqYeAW766m8bBkCq3QU/N9p\nNG13iFfd7RPPJ0Zh225ni+9wFMQNGkwRgqaQQRcsk0Nh/YTF1O1AXxAUu1LQ\nivPKtJ/fb8DaXZsOX9CFHCUVHz+oi4fjiRJFh8kyyWi+pN/Y4uAmrjmMGgYq\nSB5PLK9cSYFgazIN8lMT4HVDXaSgOBlXJCKW3JWDp73+tU4GRomp6oJHoIoq\n0kAwATKlmrBv/oVRBXAOuBF602Jw1TpTuaSZ2XL1M0arsImCDDrgLLBiJMcI\nYs4VksFwcnN4Hb8IqqDx2R5Iib2R7lxa2xZz5OUS8hGlDZmCqdtHASSxrY9S\nYpJ5+9m1derMrmsyb/9gaBr830byGmucxaWMI5yubuoC8vgbG/QxN6RzXm7c\n7SIrFmjUQ0N8U+gXTqjDyUalxE5Rtwv3xhhMKTq0u61ihkNjSNBmiqr81xZ5\n825bdXdusxLc4fvxxBkOeAYYcb7Ga2wouMvkH0ZPklq4pesdXhBpcNBcO7p5\nD3biLAPpwD4VvlpBidSmzMCK34tgOdZbgWhmgwoRExX3rErZqfNd+rzpjVeV\netJx1NKS1deVPrZyQpX1Ka+4UF3DhAu737OwvskUPfiP8NwSvCRnVHuIIvnE\nVHZ7\r\n=tgx1\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD5F4/eWk4MbILs0UP+1wp6XUnrIR5vLfxkZdJObovbCgIhAPLppk1GGGRFnL17jEocS/8LLsnoOMNHfKpM5aMR6WVE"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.29_1593104945834_0.3985030447900568"},"_hasShrinkwrap":false},"0.1.30":{"name":"@mgfx/connector-redis","version":"0.1.30","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.15","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.16","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.22","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"174fde2e25c2f6e3eb4934b382a589fa79e075f1","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.30","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-oKjZ2XFI7TWW+4dk0PQS2/JkwIhBZlquNVPrQoLpqtaFNN9TUK4N4G7pJ3KTDKvBrZFXf15IfLXiuQFkxorICA==","shasum":"72da708143b09fb07ffdfb369d7f62e01892319e","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.30.tgz","fileCount":19,"unpackedSize":36402,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe9ODvCRA9TVsSAnZWagAA8bgQAIMoYM0+s+nct7n81kdt\nDj/L1v9O0DQFflCS5/TOTHMDIxPeVfLvsqi0KYHcyxYx6c/iiys91jkF7Xl2\nTbdVLrlh43ngXhJX23QaXNaq+SF2+thq6hL+Dmq2kfq9J7MO9msp/B2x5n4J\n2uiAB/yc3xrtpx98CooEIALzfY5JHJjk+M7A/yDtWdWgrKDXoz8EY6IZ72ZR\n7dIa5SSysRj8y9XbHvbZnId04FYzm40qTDULQ3p7F4lR1GHk/yOyj8gNNo92\nnu/TCr5BjqIBrN8U40bidK65cFxtibvZRIhuKBZ080DMKCeANyVlNOTyqho+\nz3hSNnaFoiV5U+lm8E8F063Ey7qiG1C6wkLaL2rfRJgQGu4cGdFzHD68Utmj\npn3IdclmQHuPCeE84OnxVthpBCZYiLHkbmD9ATNfEKREJMmZRgseTiC0c6hT\nwAsGzrSUM2hDQUVvTfTC2M/rGi+v0fbJWTd+D3jRV87jpsOyYTL9r6Uwg1QK\nh+WDSmw7InZA+r/GbS3symd//yYlTK+HNgVmo6IGby/zCGImhMdt7fxfD0YY\n2/2KqhMywVnaz/OIySI5A+oF1kNXMf7uCjTwbuRUvs6wqSTOfPOnF2FJ8Mut\nw/cGRWrsesIC76fhAavUjEF1n9SZeXKy83+SsTYhp2vxriZoqxHm7nfh4OeV\nW8ij\r\n=FCIV\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCvdXh6ArmtO6T/dvJcVgqp5J0ME8fUaPQU+NKLAa7dUQIgH9HwEFad9sRPn/gOoRtopHqu7ftMDyLGxz4ECbQlo7w="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.30_1593106670808_0.9956721697456672"},"_hasShrinkwrap":false},"0.1.31":{"name":"@mgfx/connector-redis","version":"0.1.31","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.16","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.17","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.23","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"0862590f6e66813aa6e96824c96265e809086826","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.31","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-ak1pHSYqwpE8djQYyml4Pl0yW8VQOgt61YLlHtWslkInh2sJUlM7BEg0uDuAh3nkXrTrfCDDOix8lwbEx4OvRA==","shasum":"be64f47bfad3e0ac5e9c5e627b23d3d23b4e4f02","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.31.tgz","fileCount":19,"unpackedSize":36493,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe/JRDCRA9TVsSAnZWagAAhU0QAKLXWYYfMphFa7jlz8ig\n09BPJTO11puo0YR1tjLpVe6/FO7F4p4CElznhjIKYtZzrUFaVmDzc4XVsdjJ\nNFqPyan9PIX5IehxHjt4hJVu1H1055PL0W5hx8Tknq+ceNSQyGrtyAWtl3uK\nWw//wQ1OXBwdVRKVPY7caw5oQ6EAL3QgbbzGDPZCrIpqpcff02HXW+nwyT+I\n6JxitQWbGDaVnioaMVYoY7DhEMECtpzAziMdQrrpX0WBZZO68KFn9IufWi/h\n4izctDR5LSKakQXysFFMu0BUV3+9aYr90wBD7/p3F0vQRBpBQB4kydSeWfwn\nzbNHUujvra0mR8Etv4k9ySD20QDaZnia6l1q99HMOy3MEeLLStn74L+azXv8\n7mazcBwAXrUGvfTlAuczKVmKbSUJGo2yPF9I+9AJA5AUtcsVYP2PUn9aoZQb\nYxQ1/XS0VmQ6Hks4byKyZ5T3EfQtxa0Yt/8o8qlqDfVUWKFJZZR2oexgD+BU\njarnGEPOndVW35z9xkqwxTbfQ/VZv+J7zak4pFgYentN46F1q5SMHBNhuj5B\nvzmYK5LN2+CMcTkiV6uhWqEJAtlGvIZbDQNFFtCclkz69T1DlBkv4RLY+F4x\nGqet/ZoFHJ5KECxKvqm+WA/grIzSso6xGULcTGAtWyXtLZ47H/NOAUNRXYFf\nE82Y\r\n=Cb59\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIF37c5qnBs2QDt0p4qc8si25Kj3Ll1SQqD23U59A6zdTAiANQ1wxEvBK0gxRNzws1fpdBX9CIB4tsTyEJFCkWwiykA=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.31_1593611331236_0.6734266997471221"},"_hasShrinkwrap":false},"0.1.32":{"name":"@mgfx/connector-redis","version":"0.1.32","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.17","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.18","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.24","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"266a80eb6c732e83bde49b6de17fa8190cd7ecf2","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.32","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-8ms4GY8KCK2XUme7PL6FTCq+7aygSF34D8+YO7bs0aS+ILO/0HqP3iYtLxKgf6DJhMTXi0yFOcP4UPMMYG63oA==","shasum":"f0c1ceb7874c55f0bb88c6ed80b58314268075b0","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.32.tgz","fileCount":19,"unpackedSize":36584,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfAyWzCRA9TVsSAnZWagAAAGoP/iwDLoEUPgE08OOv9oKS\nyiYQ3IizcywepXdjMvMXxpRgyLOlWFjGxfBKMZU+jgj+UV0a+3JyaKnFqfbI\nVfBIHC933ns0h7Sc/fiK8x2cxPPK2zuEeq6u3iCw2jQpYjOsEQw/Q0jLNU/E\nTeUbUDV9mlLdxyncOANxcHIaMPOuNWwIpU314be7nyvGzBwvgnR2hu30ko39\n88kxDyLJVCjowU+oMTWBW6ai5neJTge2yzolc4jD+kNHkkrkfo8WEs+xG4II\nMTY4t5dpfqs0gyiFHEk4fXOtr97bTChlIwHs1H6iV/iGKjiVXuRtc2Rode/j\nPm08CibRDRy8n/Ana3jINnNc4kbu1oQ00tiRukzeLm9WF+rm11o97SxvmBic\nFzcn4zTw0ooSh53gs+opcL8+vBOl1W34zGYNgtjzqFuyT8IPMoVP2JISE1Ym\n5VswauVah8borDMrD2hfI9V9pwYvzzmHmK/X5fZwbeExeHog1TVFnBXekLQz\nMWuElUnUthtDoVrh4zKyOXAu+gH40OL0gUaqfeGhr5QMDP/m98xs/vvAYw+y\nwRsSPvOKdo21r5nVHMrylT2Um/gEVEpkF0+AmUPueRlQqlGz34gTe98fLWpg\nY82Bk77h89MomSm1kia2ugcBngGLqduj4LlB5K/QsGGD4AkbOAePoGvHqwY4\nbEWY\r\n=NE8v\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCICIZR7MFfAWHlXVVLIgMkLo4R7SSAIEApi3dUFLNbHXjAiEA2krENEPTP6RG+pzFDqllCZRpqGoAf5LV28C2bfii+tY="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.32_1594041779296_0.033487049027953075"},"_hasShrinkwrap":false},"0.1.33":{"name":"@mgfx/connector-redis","version":"0.1.33","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.18","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.19","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.25","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"9ada6758610d76e410135aaacfcde1676f1e1fd2","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.33","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-Cc/LNdnO+IbX50BsSKZ6/RinPIRx1+hU9yrnsFBABg2LGiuQon288CBPl4LeASHlPM1NEwJ0illBRYNcfAlxdQ==","shasum":"ea2f11ac76898d2f380da1b5fc8b309169f0fc3d","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.33.tgz","fileCount":19,"unpackedSize":36675,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfBcDHCRA9TVsSAnZWagAAqKEP/2I9XhWgUFAGQj2f8u6A\nuUehnXppZyrf5740jr7lwQsaw8zzxcABwJTrjKaW5eD5IioLn8iB1Bq6lbvp\nnnaNc4MHAsmcyqPlaO7tRy/FNpk7/mnEdOAxfbc28102lQLgM3stfnETvUa5\n5xGt8Dvk0Z01Nk7S5CqquRzqf0ULChL4bBzYNeh0FYX8fmyblXN05sy93DSS\n3oFK6I9qFToguPD65lGdJ7IDeUhM1pngcUIrJ1/V5mjWNcMGyzavijJdt3Bb\niGUMEHGDdCH6jQvAqEAv4bhT8mN19RQiltyoNr23C+flDc6ltiaXb0hnoN7g\nfRlBPjdmwq5Afp9VEv1XO511CGL+wzYsXOHYAuV3pYCN/LcUnojfhfqTk4Zp\nEIEGD3yKj723edw/iicAugWF6cvKSt42dR/GWitHxMQurXbPcjK00QU8halP\nCjVlS4iDPqzuJjbEltTJVeV5DFcHZ7JGgwiq+JihrbHcn32g5BWCMDkiU5xd\nhb6LfjdXMJOWwkaWamQMCq84wh0YZllZV0y04q4xDq6sTaN3nvmL/HuoC70L\nF+2NACEqCK1sW20cFdqiWtP39fsaHux8vBaBLqc65ATgK7sLrBbl/0ng5w1A\nczzKyn8GGLJV5cprkLejx9BIuJhCQznoM5mNzslgZYTr7ZzoGvlhTsI/cTF6\nvCBQ\r\n=2JRl\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDxf2ey+PvA2hDjBXBBnJvi+t4+C9utmjKB059JD31CrwIgHNs6JW5dCBejcbmyT7ds7oOfgyYwV4mDyfM6Y7l54EA="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.33_1594212550728_0.5047117136760952"},"_hasShrinkwrap":false},"0.1.34":{"name":"@mgfx/connector-redis","version":"0.1.34","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.19","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.20","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.26","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"68db2cfed36ed56332d4e4208413312dfc827e0a","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.34","_nodeVersion":"14.8.0","_npmVersion":"lerna/3.16.4/node@v14.8.0+x64 (linux)","dist":{"integrity":"sha512-qvtPnSC/sWvsyk+cB642XowzDh55DFj5AFPKeFl5EKyY69pBY5d5/M+59rdaJ1jqbE9jYG5gtQ8z3okJkMOkNQ==","shasum":"ce9af5f3be48aea50981cbd04ed41fd88cb44175","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.34.tgz","fileCount":19,"unpackedSize":36766,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfPmWjCRA9TVsSAnZWagAADj8P/iiB51B9LhRjvGJHD1hc\nGbjwIOU+zr62Ut9bAIxnvj51/5YbCbIQsAmAaBRogM0PvZOa/2YQ/D+mJ/iK\nRsmHf0Q17atV71am4e7jQrmde2QvZhqWkxz5HnGFQscUGOmjBMeZnTcsr49e\nyaTRwismGowUeUbY3OjznVRxIvbWe9x2iMSXIWWxnLGZs9Z/3kqBYBKzTfeq\nzIBUNq4Yqj7A+rwZMCvZf/QytINzW88x9ZEMyYr94hdV9VGehMs4GoTqpUXc\nSdNZG4gcASvUPzJQ8FO9UGvuixWgoN9BIEENNKXdiMOKuEs6KnRHwcBUp8Ng\n/qs5n6dMO18ktYz9CWoSzhtZkapISbBgpJS0TVEwPhWRcHeXd0Y4hJIL40Sp\nTLg1P0pv+WdZTbrkVSHBiCCN6NrSN7kf10R/smCMpeuNkWZ2HgeaBNEsVPHO\nC57epKXFm6bsEGp2nxkyFCE0gMdMSAX7RUqRyKe0s1iyv2fzyXlpwfbrV6P6\nlK32VPXbPzJ25QSquqsR7vYS0TnXgr2z+3+K6y0WGyjJUg0LEjvVHLmQrygk\npjy1V/7LM6THQqB5cSmMHiq7On/dkSWN46XpQwkXP7RwzoCwA2f44C8IAsZ+\nvh7AzpF/3Rd5vYtXGJo2OgNqbK4WpnQSBHSXoiJsQxh827u+0SaAQqRBXbDX\nopuJ\r\n=EFUY\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDLsgEUTSNdKk8+nbu6t/VP0AQ8vylI5PX2lL5R/ZiB9AiEAgDVyhYijKijtrvqyJrO/Ts9p+d+FKhrCB7o1JL3aMAo="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.34_1597924770846_0.807252094341899"},"_hasShrinkwrap":false},"0.1.35":{"name":"@mgfx/connector-redis","version":"0.1.35","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.20","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.21","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.27","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"1802d9733b8dc735b2277dee6f92dc0f7f24cce4","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.35","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-lvyh5bSxlbngVuwkePmy80loi9/sY1Nv+2khfY06N4chKQ9CAq56ew3TRfe/s8n0/smgXP/c20PVA0vCdWST9g==","shasum":"3fe5d5be6ffee598813ad016f4614b1aa84c410f","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.35.tgz","fileCount":19,"unpackedSize":36857,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJffs5PCRA9TVsSAnZWagAAEfsQAJf+mqitw9zZ4CZ6ctfI\n4IGgaQP3wuKkgRFQj7yJaoKZwEjMBwYTMo8m+sXjdj28P2gu9ELBAua1Ffqi\nCUm4HLn/WCLYMJDtIXzfvGWQLrbxcf1tb91pgrwwzeIYouRHJ/Z+7205IYm9\nNg3fjHk4JTBFiN+XCfAyevZCmVEM7y6e72bsXCldQha/LnQE0jRT7b3EbRRD\n5TvEsq+5xchXZdLUV098KU8IyQtRFJQbkk1y/p4QyGSpQXcuHlluBCX6TmGa\nL0aXaNPKxP2i1FGW1/IDtWpkGQlKvM0KzsWeToph8Ub9/Zvfo/2NhlfIq3LO\nwiHbCUuOj85ABBZvMHMrB/RwZRJeZgqMfEHgz640l+xkADMw/l0p3lE+lbvb\nYAwaWlsl/t5Bf8Z4mmPNX0c37h2gpPKNrBzsfH2tKn/WZMnfrGky5JTBMFDJ\nVy88OSPTKmZkGiCknIZzlGyHram7cvrJhaFDxl5j+g0t/DczWZyuLTbE+kO6\nIfusqWikm9B4EHotwO2dlAmJ5fMX3ArrO4EzExtxepm55gduFbShKVkyMnND\nfJX8wGAAFxFr+a2JAyj4JIMe4bopPysGAggGWMbgr+Ruc/wR4GbYfT+vgbUH\nQ23i0pM2PCs4XVdpC9pcO61cKE8TCQ+CZUD4XUTmemiJbBt6eHoOT/GUDRSP\nmYif\r\n=0IP+\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQChzGTOl6VV4dEklgNTUjFjYZwUZVKyvswgC3GOwf071wIgdcv1EmhrDG052OgP+pexEPi1BtFAOxlOxNIyQNurfmk="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.35_1602145870258_0.21913785903776262"},"_hasShrinkwrap":false},"0.1.36":{"name":"@mgfx/connector-redis","version":"0.1.36","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.21","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.22","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.28","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"c0a3eab21300e508c235ee0b1ad7ae157ea1695b","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.36","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-Q7g9GuwA3hHoCTb76PWTLW58SMUfrZMG8e4j9S1wOQMf6Ucx4b2PnkIvsCxudYhz7GFbiIM1NCAucv+oIU95ig==","shasum":"49e0bdf050f4ec88a69ac22809621d21b10f5417","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.36.tgz","fileCount":19,"unpackedSize":36948,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJffvJbCRA9TVsSAnZWagAA6SgP/11y3scQCGAfNIs+9el9\n8GKtK7Ag+ndSKrsBZ/bDhqD9fdZe7lZzYNuhqc8Z5c58U49wXmoWidWfxOY2\nyjUxGL1t/ouPq1/FaYZwanZmcso/9CHcIzIp4jHyvg7H+o0koFaUVqZ0iAPb\nC/lXWKa8MgiETA6hv0/gDwHuH3zDzgTM2vHqbRF1eLrugRwPdDqLbO/8w6D4\no1p2hlIar/9IKxwfxI7brKdR35a6pQ5kvmG60vSfamJpS5Garj7l8HQllp4+\nYiSrtaf6Tq4Vy0RglCPI8LCx+3kIDJ2lu4U36OZl1Uy+RJURoCnXGvuAUUAT\nfgLygP3pv90jZqPBxT9beGSNPsUJiLIWgU66IAy5a+0BbWUzjnPuHoIH+fq0\nmDAqjcCk/EqxvURBsWNpn2m0Vsh9HHse5zS6Hn4woS9QsxyR4M3pXjr5It9t\nOLx0VVDqBGabSuLVGCbPbhoAvMivMmzrBOyDK5VhfTojaoqSeNvpZt1irLLb\nvX3KlbmfdK/mad9MtjlNWa/LAXVV8HDxXaz8q3Imy57rb8uClHdEoGFpB6l8\n14duzTjAb9quHYzyUvRiX29SjY+dzJh5WxW5KdaSCu53ZIfqFK40ZL/CyIaT\nAu1Z363cwD1shxUPvU0jYaxvUGJ235QqeZynbwXDXPVWnKTjYqRq0v25sqvu\nFxYr\r\n=ncZN\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEg37uvPsSmMsMo9S5XNXAg6Wc6tltnblBaIq1cLKImgAiBGyxpdyK3dcdNnn17AZxVSi7bmd+GAhHZ4hIeZcw7efg=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.36_1602155098954_0.2810312584991361"},"_hasShrinkwrap":false},"0.1.37":{"name":"@mgfx/connector-redis","version":"0.1.37","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.22","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.23","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.29","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"143ab624cb2475f3946f067462a5869d2f4b0a5a","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.37","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-ahFce1rHlZJyULOmL65gvZ80kaRFtS6G2vdpT0eCzRFUdRa6zVxQHhR9sGf2QjOW5W5SBEOy8GGKFEDEFz06ZA==","shasum":"25af11941f7da83296adc9ae1ab8e82f79fec6b0","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.37.tgz","fileCount":19,"unpackedSize":37039,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfgCN9CRA9TVsSAnZWagAAlHwP/RvFcwIB2OdN/nD9a6z6\nEX3ViDKsbtKD1xLZ3TA+TMTLccGmFjKkmbK/vLY6HHvE4ivxYLiUopQ5ZsJL\ni1lUtxgHfJ+Mjjw6m1MhFkQD34qY5kbjk3DAZd24o7hACoDXeLKYRDhE1dYK\nvvewSR34AQAcMRfAhOKR4kys2A6bK0Q9JcuIMbzUewJ7G9CW/WvBKo73ByFi\nMDT/4U1qQNN//trLB52qCi1LE9gRmeKXeD6Zs05KAXhmwqJLZjNsGRh/4Xfz\nUJ36721nzKhIMjFXNsypPxY+7ranHlBbFu0kzIvpKgvsvdqwcZbsL7FBw5CM\nPfk0rOLAIxsEVCEHUbiycAor6FzB12UdLPgKQNp9QhejXRFRVh+3YwFRgXwe\n0RiNm/AE9NF5/qyXFxpp4GHVB4VqE7UCDRyxmze9snoRYHPggBpRzSA9YeaL\nH/vV7FIEA751uLnHypCglSEl6X4s5kH31fZ8racPOhhOVo1hdHuLUXWu6het\nWXM+aE6O9nHB4VvQVekgAzXRDji2bq9wTt7DVd9DqoJsWANGfqJESpTMlbMO\nGxfWLIsoHJA601Rqp2959zIpPWx0cr0h5cnCrpoBfVHXubKMKlEYjOhVs8QI\nKKeY1dzmtpuPshXGFKkzb6aBrLIHRokzkQ58W5lfpU7ICMT45OnZYCOTir5X\nuxkw\r\n=sGro\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDACtFBqEvo3ZAlF3Ldhwli3pGOrMsMVMZ6BAvCDVMQOQIhANHSIv+uITOpH3nVQAgvusz243/c5A+ytadfl8kJpkrw"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.37_1602233212907_0.28727427499296776"},"_hasShrinkwrap":false},"0.1.38":{"name":"@mgfx/connector-redis","version":"0.1.38","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.23","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.24","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.30","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"9616dc9e215bfddc790e2e0aeaaa0152396c4deb","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.38","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-RpkEJO99MeqSucqs/Tm4O2Tsrgr0TL4SUgIJvz3s/w0nSF/CQQzjT5uMq0MG/FMaimvu4bAahEsAYKBlBRTbxA==","shasum":"da20a63e7b324ae92c24309c0c9dabb16d531a7a","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.38.tgz","fileCount":19,"unpackedSize":37130,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfgDD9CRA9TVsSAnZWagAADNIP/03uvwkMBsuVDPc9aY3r\n/X9ViSsQ7aPP3BDlVZc8hCvFgpWq+ax+J6oe6vNZFgHn9P3n0lQtGgUphC0p\nmd1loomBbPYJtEdBtJ3SCRJhTcECcb5xU4Ebc9ayFdogPZT6zcEgxOljMvll\nkh2Y87m2+W358vq6INIqQVro4bNOuufr4FyKAHxwxsh6XM5tZUYoqJm5XB2g\njBONJTLQJtNPUZHHPTfO38+D3lbKhb4IyWUhiqn1FC7DOmN323RnoxR7A79d\nVxnIrgD0pcM5R1k3K6X2taLJU4Ln4QqIRIDnucEBbCI5xIdbXDK0x8XNB+ZB\nW1xd5hjGUvrvEM42Va5itNAMT01taYdYp9vtJsuimINsDhUXLCrMMqmR9SwV\nZJeLbXrwZ1fq0dVcrlUkD6zv5xahQL7ocCeIXcmaMdhj501p1xaZAVbrqjyG\nRPIURZRGwyXAybuqis3yB57okqE4uPw1eDZaXNhevCpnSYWlWvJZ2xtMw415\nEvDmuL3HyG5lYOz/lgIKWTB32AidlT92NhL3GZMx5dD4pbmOX4ayJV/nkOpH\n9Mrt7dsbQzQ9WvvU1+aLBccCYa0iOo4Ik5iUoqilVMEbnTbiGs3xcHiocb4l\nGexeecNaxboPK6ZDqgRaht2cwlm3doA75SyQ7c6WjnufCAI0gwjs9d7mf5kr\n2a9o\r\n=1GtP\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCZDqWsW3YDhN/20Ybvu1dSfoHKBdVmGY6Z6Vo9zjUHFQIgG/F2W3KzZANURhbUWoU4Z2OgT5zFC5Tu+NaMzD+l+6I="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.38_1602236669304_0.8394590118107992"},"_hasShrinkwrap":false},"0.1.39":{"name":"@mgfx/connector-redis","version":"0.1.39","description":"An mgFx connector that uses Redis as a transport provider","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/codecs":"^0.2.24","fluture":"^12.2.0","generic-pool":"^3.7.1","ioredis":"^4.14.1","mgfx":"^0.6.25","serialize-error":"^5.0.0"},"devDependencies":{"@mgfx/validator-iots":"^0.2.31","@types/generic-pool":"^3.1.9","@types/ioredis":"^4.14.7","@types/jest":"^25.1.2","ts-jest":"^25.2.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"12d70abf1762db4c26a657739c7eed5974d167ed","readme":"# `@mgfx/connector-redis`\n\nAn mgFx connector that uses Redis to provide a distributed Task processing mechanism.\n\n## Usage\n\n1. Install `@mgfx/connector-redis` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/connector-redis\n```\n\n2. Define a Task that is visible to both the 'producer' and 'consumer':\n\n```typescript\n// tasks.ts\nimport { define } from 'mgfx';\nimport { ioTs, t } from '@mgfx/validator-iots';\n\nexport const myTask = define({\n  name: 'myTask',\n  input: ioTs(t.string),\n  output: ioTs(t.string)\n});\n```\n\n3. Create a 'consumer' module that uses the Redis connector to serve an implementation of your Task:\n\n```typescript\n// consumer.ts\nimport { implement } from 'mgfx';\nimport { redis } from '@mgx/connector-redis';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\nmgFx.serve(implement(myTask, name => `Hello ${name}!`));\n```\n\n4. Create a 'producer' module that uses the Redis connector to run Tasks in a distributed manner:\n\n```typescript\n// producer.ts\nimport { redis } from '@mgx/connector-redis';\nimport { promise } from 'fluture';\nimport { myTask } from './tasks';\n\nconst mgFx = redis();\n\npromise(mgFx.run(myTask('World'))).then(console.log);\n```\n","readmeFilename":"README.md","_id":"@mgfx/connector-redis@0.1.39","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-LOL/zivXS+5lfZ5a9oFK/nFq+Hqyagc2aRPeBBJ5SXQfcxxZreFcGX7yE3EnC97shyQukg9EywhfIcFedmB+pw==","shasum":"84cd2d4d251f30e8ec1ab241950812b970c7c766","tarball":"https://registry.npmjs.org/@mgfx/connector-redis/-/connector-redis-0.1.39.tgz","fileCount":19,"unpackedSize":37221,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfgJTwCRA9TVsSAnZWagAA1xQP/3x5EZRYCZzwPtU+fl5b\ni0Gd4hAL5hRikutLgmyt3jwJip+S7hZFohIRUZaBgRY2g0dM9rhIKcqlOdMJ\nmPKcyRBlp/CGSH1WXgw/xBBA2j0XqRaM3COuVvIF7stzxIxJFhBjhpnyogh3\n3yrwFsv+7OJCW6U9vMWdAUTzUo3IYrjotSvpLF5ijDFH97KJXDQa+Bc1LqKE\ndhLkusmlDGIjkDg5FMtV45jDfWn0HfDqui/seCBqLN+eqT3m4k/41cCVzi2K\ns+OwvhQBTUtCwEevudsPZ++sM/H0FUuT1gwGXremMwt4JGNkyRmP81DBl2JE\n/gXaKHfKnXC/MmMjCUZLCc9+8CRvSt/XP/YRJ/Ht5Jdy7Xo92AKTodZjuulu\nr4X7QtPBAKs/UqE+TjBTm4hHooOfQfUN6DgqFCqW2WGxoTrd6Wq8bmIZZ63U\nNYGfAwLCm9M10DPD2SEtGlWU85gAPuzfLzqsnNOxX6hzmznIJYUmuAkf6xlW\nCgGnk0McldfayMUFXqriIEeNHCaiPliKEsrkaSsD+nvBbkkxFTOKgso0YKoP\nTmrNQVc94Hui4O4B4g7qDRgpHKJI1lUdok6P0thbENiGQf1A65oJElOajHwl\nsUMrgHPk1PJ3mnlfqRTwdG0tvJwLA6ET3G+/L6TmmTe+9FRdF7sg2kSNAdyk\neUAK\r\n=mGq7\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDILnfkd/P5DCnlRKWzHw0/U6fuU9qjHln9jeIpU+dt/wIhAOXLsvkoFnGZSoyaYUovfHc4jVK5ASBVV0LOszaHtVt4"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/connector-redis_0.1.39_1602262255890_0.35678661312887483"},"_hasShrinkwrap":false}},"time":{"created":"2020-03-05T12:24:07.875Z","0.1.1":"2020-03-05T12:24:08.268Z","modified":"2022-04-06T05:17:49.738Z","0.1.2":"2020-03-09T10:12:11.213Z","0.1.4":"2020-03-11T09:25:14.943Z","0.1.6":"2020-03-16T15:14:41.155Z","0.1.7":"2020-03-16T18:37:03.177Z","0.1.8":"2020-03-31T10:57:40.300Z","0.1.9":"2020-03-31T11:20:28.774Z","0.1.10":"2020-04-01T21:23:04.961Z","0.1.11":"2020-04-02T06:23:06.353Z","0.1.12":"2020-04-02T06:52:08.340Z","0.1.13":"2020-04-02T07:49:17.695Z","0.1.14":"2020-04-03T13:29:42.682Z","0.1.15":"2020-04-08T10:04:36.076Z","0.1.16":"2020-04-08T19:01:22.699Z","0.1.17":"2020-05-01T15:43:32.658Z","0.1.18":"2020-05-01T16:09:41.597Z","0.1.19":"2020-05-01T16:40:24.493Z","0.1.20":"2020-05-05T15:21:57.581Z","0.1.21":"2020-05-07T10:01:28.506Z","0.1.22":"2020-05-13T10:57:42.158Z","0.1.23":"2020-05-18T10:01:41.996Z","0.1.24":"2020-05-19T13:45:56.640Z","0.1.25":"2020-05-19T15:50:53.041Z","0.1.26":"2020-05-21T13:33:52.024Z","0.1.27":"2020-06-03T11:30:55.191Z","0.1.28":"2020-06-25T16:41:31.065Z","0.1.29":"2020-06-25T17:09:06.006Z","0.1.30":"2020-06-25T17:37:50.981Z","0.1.31":"2020-07-01T13:48:51.378Z","0.1.32":"2020-07-06T13:22:59.485Z","0.1.33":"2020-07-08T12:49:10.992Z","0.1.34":"2020-08-20T11:59:30.958Z","0.1.35":"2020-10-08T08:31:10.832Z","0.1.36":"2020-10-08T11:04:59.063Z","0.1.37":"2020-10-09T08:46:53.055Z","0.1.38":"2020-10-09T09:44:29.471Z","0.1.39":"2020-10-09T16:50:56.037Z"},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"description":"An mgFx connector that uses Redis as a transport provider","homepage":"https://github.com/ai-labs-team/mgFx#readme","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"license":"ISC","readme":"","readmeFilename":""}