abd6ce9
(HEAD -> master)
调用Close后不再向JobServer获取任务 by
2023-02-13 01:01:37 +0800
97187ec
等待执行中的任务完成后再退出进程 by
2023-02-13 00:29:22 +0800
481c906
(refs/pull/95/merge)
Merge 76b2395d70
into 2a518e8661
by
2022-09-15 12:06:41 +0200
3aaf043
(refs/pull/91/merge)
Merge 06a017e098
into 2a518e8661
by
2022-05-20 15:14:18 +1200
2a518e8
Merge pull request #96 from floringavrila/add-support-for-own-ids by
2022-05-20 15:14:03 +1200
fa71d7a
(refs/pull/96/head)
add support for own ids by
2022-04-06 01:11:45 +0300
76b2395
(refs/pull/95/head)
Added admin module by
2022-01-06 12:21:03 +0300
68ccdfd
Removed extra check by
2022-01-04 17:58:34 +0300
3b13a9f
Fixed by
2022-01-04 15:46:55 +0300
a20b263
Added Stop/WaitRunning methods by
2022-01-04 15:44:33 +0300
d484cb3
Fixed by
2022-01-04 15:36:45 +0300
9cc0c12
Added graceful stop by
2022-01-04 15:23:39 +0300
66e96d5
Update worker.go by
2022-01-03 21:36:25 +0300
2263172
Added graceful stop for worker by
2022-01-03 21:25:22 +0300
d36dcb7
Merge pull request #94 from cameronpm/client_race by
2021-05-03 16:56:33 +1200
a8f0a04
(refs/pull/94/head)
Fix two race conditions in client.Do by
2021-05-02 11:02:15 +1000
06a017e
(refs/pull/91/head)
Lock the client when a non-parallel-safe function is called by
2019-11-08 13:09:41 +0100
d40cb7e
Remove client locking from pool.go by
2019-11-08 13:06:14 +0100
81d00aa
add synchronization to prevent race condition on worker shutdown (#89) by
2019-05-28 17:41:20 +0700
3e669ef
(refs/pull/89/head)
fix race while broadcasting outpack by
2019-05-28 16:17:22 +0700
5ba52de
fix incorrect synchronization and add race unit test by
2019-05-28 15:41:15 +0700
0bae664
add synchronization to prevent race condition on worker shutdown by
2019-05-28 12:45:24 +0700
b902646
Merge pull request #87 from CodeLingoBot/rewrite by
2019-02-28 11:28:24 +0100
133dd37
(refs/pull/87/head)
Fix function comments based on best practices from Effective Go by
2019-02-28 02:11:17 +0000
f333ba6
(tag: 0.2)
Fix job register with timeout set by
2019-02-13 11:45:35 +0100
d0e6ec4
Fix Odd use of time.Duration (#29) by
2017-06-06 15:58:19 +0600
f2f0349
Remove lastcall. by
2017-02-06 17:38:24 +0600
5c665de
fix worker reconnect errors, send cando after reconnection. by
2017-01-27 17:32:20 +0600
2fba865
Merge pull request #81 from Detectify/master by
2017-10-18 14:34:29 +0200
0ca6dc2
(refs/pull/81/head)
Remove duplicate locking by
2017-09-30 09:30:29 +0200
7b62156
Merge remote-tracking branch 'upstream/master' by
2017-09-29 10:51:16 +0200
8a7ac5b
Merge branch 'develop' by
2017-09-27 16:57:19 +0200
a2eb7ba
Remove unused imports by
2017-09-27 16:57:03 +0200
53bb686
Merge branch 'develop' by
2017-09-27 16:51:18 +0200
e701107
Remove broken test suite by
2017-09-27 16:42:48 +0200
99d3174
Add skipping for integration tests when running unit tests by
2017-09-27 16:42:21 +0200
d8cb388
Merge pull request #79 from John-Lin/fixed-typo by
2017-09-27 16:59:04 +0600
d9ad234
Merge pull request #1 from Detectify/develop by
2017-09-27 12:00:00 +0200
2dbf199
Add lock on job handler assignment by
2017-09-27 11:57:57 +0200
e1224a8
(refs/pull/79/head)
fixed typo and keep WorkComplate for downward compatibility by
2017-09-27 13:19:08 +0800
94543bd
(refs/pull/28/merge)
Merge ea240397b7
into 9735b2e54f
by
2017-04-15 23:34:36 +0000
cb61932
(refs/pull/46/merge)
Merge 234596770d
into 9735b2e54f
by
2017-03-02 13:31:01 +0000
c6ceb2f
(refs/pull/66/merge)
Merge bc27f6f7db
into 9735b2e54f
by
2017-03-02 13:31:01 +0000
cb3b3e5
(refs/pull/67/merge)
Merge bb34d7332d
into 9735b2e54f
by
2017-03-02 13:31:01 +0000
20069e6
(refs/pull/74/merge)
Merge f61772507f
into 9735b2e54f
by
2017-03-02 13:31:00 +0000
9735b2e
Merge pull request #75 from No-ops/patch-1 by
2017-03-02 13:40:41 +0100
27942f5
Add sync lock on do() to avoid race conditions when creating jobs by
2017-02-03 10:06:27 +0100
d6791e2
(refs/pull/75/head)
Add sync lock to create job functions by
2017-01-16 16:44:48 +0100
f617725
(refs/pull/74/head)
fix counter bugs by
2016-09-21 13:08:17 +0600
475f2aa
added counting running jobs, disable/enable worker to recive jobs by
2016-09-21 12:05:34 +0600
b79fee2
Merge pull request #70 from JessonChan/master by
2016-05-06 22:33:03 +1200
dd82e21
(refs/pull/70/head)
concurrent map bug fixed by
2016-05-06 18:00:58 +0800
2345967
(refs/pull/46/head)
Merge pull request #3 from Clever/merge-from-upstream-master by
2016-04-27 19:24:57 -0700
bb34d73
(refs/pull/67/head)
Merge remote-tracking branch 'upstream/master' into merge-from-upstream-master by
2016-04-26 17:46:02 -0700
bc27f6f
(refs/pull/66/head)
Check if buffer read is complete before decoding by
2014-09-29 18:01:50 -0700
f22d6d7
Ability to exit work loop gracefully by
2014-06-10 11:37:10 -0700
6877731
Merge pull request #65 from JessonChan/master by
2016-04-24 11:03:26 +1200
99c8032
(refs/pull/65/head)
fix a bug when high qps by
2016-04-20 12:54:21 +0800
21cc8de
Merge pull request #63 from kujohn/pool-custom-handler by
2015-12-14 18:41:29 +0800
9d99acc
(refs/pull/63/head)
Allow built in selectionHandlers to be reused outside of package by
2015-12-11 13:48:02 -0800
6d9b2fb
Merge pull request #62 from kujohn/pool-custom-handler by
2015-12-11 12:44:35 +0800
1c4b8aa
(refs/pull/62/head)
Export pool.clients for custom Pool instantiation by
2015-12-10 13:54:48 -0800
d20c3c7
Allow custom Pool without constructor by
2015-12-10 11:19:04 -0800
453e1c9
(refs/pull/61/merge)
Merge d17ea720c1
into c6c6c9cac2
by
2015-12-10 18:20:49 +0000
d17ea72
(refs/pull/61/head)
custom selection and error handler for NewPool by
2015-12-10 10:14:03 -0800
c6c6c9c
don't use sigillum by
2015-07-10 20:30:35 +0800
503d523
Merge pull request #60 from micmac/master by
2015-07-10 20:24:16 +0800
c615e74
(refs/pull/60/head)
Replace mutex in client.do() with a channel to avoid deadlock and introduce command timeout by
2015-07-06 21:40:49 +0200
df1af4f
80 chars/line by
2015-01-20 10:28:36 +0800
b612b80
complete the list of contributors by
2015-01-20 10:27:12 +0800
2c9d828
merge, update README to the newest API design. by
2015-01-20 09:43:54 +0800
37db439
(refs/pull/58/head)
Update README.md by
2015-01-19 10:28:21 -0800
bc80b2f
fixed signal method by
2015-01-16 17:41:19 +0800
9391894
golib/signal upgrade by
2015-01-15 10:28:21 +0800
9dbb3ea
added lock-write to co-ordinate package sequence #56 by
2015-01-15 10:26:53 +0800
c01a2e2
upgrade travis to Go 1.4 by
2015-01-10 00:09:38 +0800
ad9b3cb
go fmt by
2015-01-06 11:45:18 +0800
a003eac
fixed the closing method by
2015-01-06 11:34:39 +0800
c9a5aea
(refs/pull/37/merge)
Merge 0deaa25a0b
into d32eb195e1
by
2014-12-10 01:15:04 +0000
d32eb19
Merge branch 'kdar-big-data' by
2014-12-10 09:14:08 +0800
25735c8
merge for issue #33 by
2014-12-10 09:13:49 +0800
dc1af95
Merge pull request #2 from Clever/dont-log-not-enough-data by
2014-09-30 11:09:09 -0700
e8802e3
Check if buffer read is complete before decoding by
2014-09-29 18:01:50 -0700
ea92c12
Merge pull request #50 from AzuraMeta/patch-1 by
2014-08-21 16:32:24 +0800
e005ea4
(refs/pull/50/head)
Fixed WORK_FAIL needing 2 arguments by
2014-08-21 10:41:23 +0300
9387a36
Merge pull request #49 from gbarr/write-errors by
2014-08-21 09:24:18 +0800
7bcc4de
(refs/pull/49/head)
Do not ignore write errors by
2014-08-20 11:27:32 -0500
ccb6f4a
Merge pull request #48 from gbarr/large-packet-read by
2014-08-19 17:11:42 +0800
d82da8f
(refs/pull/48/head)
Avoid read channel corruption when response size > bufferSize by
2014-08-18 09:58:28 -0500
49ea8c0
Increase buffer size to 8K by
2014-08-18 09:51:33 -0500
1f303d8
Merge pull request #47 from gbarr/memleak by
2014-07-25 09:46:21 +0800
3e556ed
(refs/pull/47/head)
When a job completes, remove its handler by
2014-05-23 08:00:58 -0500
097037d
Merge pull request #1 from Clever/graceful-shutdown by
2014-06-17 11:24:19 -0700
d408888
Merge branch 'master' into 0.2-dev by
2014-06-16 11:00:20 +0800
dde0c3e
Merge pull request #45 from draxil/worker_disconnect_testing by
2014-06-16 10:58:57 +0800
abfc23f
Ability to exit work loop gracefully by
2014-06-10 11:37:10 -0700
14f4df8
(0.2-dev)
Joe helped us greatly by
2014-06-13 10:55:32 +0800
c8d59ea
Merge branch 'master' into 0.2-dev by
2014-06-13 10:51:48 +0800
c6c0d4f
Merge pull request #43 from draxil/master by
2014-06-13 10:25:57 +0800
ccdbc5e
(refs/pull/44/merge)
Merge 8cdaef9752
into 320155c608
by
2014-06-10 21:52:58 +0000