| .codeclimate.yml | |
|
|
| .eslintignore | |
|
|
| .eslintrc | |
|
|
| .gitignore | |
|
|
| .nrepl-history | |
|
|
| .travis.yml | |
|
|
| CHANGELOG.md | |
|
|
| LICENSE | |
|
|
| README.md | |
|
|
| README.ts.md | |
|
|
| package-lock.json | |
|
|
| package.json | |
|
|
| lib/assignment/partitioners/default.js | 32 |
|
|
| lib/assignment/partitioners/hash_crc32.js | 17 |
|
|
| lib/assignment/strategies/consistent.js | 40 | A 1 hr |
|
| lib/assignment/strategies/default.js | 18 |
|
|
| lib/assignment/strategies/weighted_round_robin.js | 31 |
|
|
| lib/base_consumer.js | 196 | B 5 hrs |
|
| lib/bluebird-configured.js | 6 |
|
|
| lib/client.js | 673 | F 1 wk |
|
| lib/connection.js | 159 | B 6 hrs |
|
| lib/errors.js | 93 | A 3 hrs |
|
| lib/group_admin.js | 77 | A 3 hrs |
|
| lib/group_consumer.js | 260 | C 1 day |
|
| lib/index.js | 18 |
|
|
| lib/producer.js | 172 | B 6 hrs |
|
| lib/protocol/admin.js | 86 | B 4 hrs |
|
| lib/protocol/common.js | 169 | B 5 hrs |
|
| lib/protocol/fetch.js | 66 | B 5 hrs |
|
| lib/protocol/globals.js | 18 |
|
|
| lib/protocol/group_membership.js | 259 | D 2 days |
|
| lib/protocol/index.js | 16 |
|
|
| lib/protocol/metadata.js | 49 | A 3 hrs |
|
| lib/protocol/misc/compression.js | 91 | A 1 hr |
|
| lib/protocol/misc/crc32.js | 75 |
|
|
| lib/protocol/offset.js | 53 | B 5 hrs |
|
| lib/protocol/offset_commit_fetch.js | 142 | D 1 day |
|
| lib/protocol/produce.js | 61 | B 6 hrs |
|
| lib/simple_consumer.js | 56 | B 5 hrs |
|
| types/assignment/index.d.ts | 2 |
|
|
| types/assignment/partitioners/default.d.ts | 4 |
|
|
| types/assignment/partitioners/hash_crc32.d.ts | 4 |
|
|
| types/assignment/partitioners/index.d.ts | 1 |
|
|
| types/assignment/strategies/consistent.d.ts | 4 |
|
|
| types/assignment/strategies/default.d.ts | 4 |
|
|
| types/assignment/strategies/index.d.ts | 3 |
|
|
| types/assignment/strategies/weighted_round_robin.d.ts | 4 |
|
|
| types/base_consumer.d.ts | 23 |
|
|
| types/client.d.ts | 57 |
|
|
| types/connection.d.ts | 19 |
|
|