yuxh/gearman-go
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

Commit Graph

  • abd6ce9be3 调用Close后不再向JobServer获取任务 master yuxh 2023-02-13 01:01:37 +0800
  • 97187ecbf9 等待执行中的任务完成后再退出进程 yuxh 2023-02-13 00:29:22 +0800
  • 481c90625c
         Merge 76b2395d70 into 2a518e8661 Dmitry Krylov 2022-09-15 12:06:41 +0200
  • 3aaf0432c5
         Merge 06a017e098 into 2a518e8661 Sebastian Willing 2022-05-20 15:14:18 +1200
  • 2a518e8661
         Merge pull request #96 from floringavrila/add-support-for-own-ids Xing 2022-05-20 15:14:03 +1200
  • fa71d7a37a add support for own ids gavrila florin 2022-04-06 01:11:45 +0300
  • 76b2395d70 Added admin module Dmitry Krylov 2022-01-06 12:21:03 +0300
  • 68ccdfd408 Removed extra check Dmitry Krylov 2022-01-04 17:58:34 +0300
  • 3b13a9f51d Fixed Dmitry Krylov 2022-01-04 15:46:55 +0300
  • a20b263b9e Added Stop/WaitRunning methods Dmitry Krylov 2022-01-04 15:44:33 +0300
  • d484cb3b96 Fixed Dmitry Krylov 2022-01-04 15:36:45 +0300
  • 9cc0c12d96 Added graceful stop Dmitry Krylov 2022-01-04 15:23:39 +0300
  • 66e96d57ac
         Update worker.go Dmitry Krylov 2022-01-03 21:36:25 +0300
  • 2263172a84 Added graceful stop for worker Dmitry Krylov 2022-01-03 21:25:22 +0300
  • d36dcb7fc2
         Merge pull request #94 from cameronpm/client_race Xing 2021-05-03 16:56:33 +1200
  • a8f0a04c3d Fix two race conditions in client.Do Paul Cameron 2021-05-02 11:02:15 +1000
  • 06a017e098
         Lock the client when a non-parallel-safe function is called sewi-cpan 2019-11-08 13:09:41 +0100
  • d40cb7e2b9
         Remove client locking from pool.go sewi-cpan 2019-11-08 13:06:14 +0100
  • 81d00aa9ce add synchronization to prevent race condition on worker shutdown (#89) galih rivanto 2019-05-28 17:41:20 +0700
  • 3e669ef81e fix race while broadcasting outpack galih rivanto 2019-05-28 16:17:22 +0700
  • 5ba52de63c fix incorrect synchronization and add race unit test galih rivanto 2019-05-28 15:41:15 +0700
  • 0bae664968 add synchronization to prevent race condition on worker shutdown galih rivanto 2019-05-28 12:45:24 +0700
  • b902646ce8
         Merge pull request #87 from CodeLingoBot/rewrite Christoffer Fjellström 2019-02-28 11:28:24 +0100
  • 133dd3716f Fix function comments based on best practices from Effective Go CodeLingo Bot 2019-02-28 02:11:17 +0000
  • f333ba6102 Fix job register with timeout set 0.2 Christoffer Fjellström 2019-02-13 11:45:35 +0100
  • d0e6ec4878 Fix Odd use of time.Duration (#29) Md. Ashiquzzaman 2017-06-06 15:58:19 +0600
  • f2f0349d2d Remove lastcall. Sadlil Rhythom 2017-02-06 17:38:24 +0600
  • 5c665de2d6 fix worker reconnect errors, send cando after reconnection. Sadlil Rhythom 2017-01-27 17:32:20 +0600
  • 2fba865e37 Merge pull request #81 from Detectify/master Christoffer Fjellström 2017-10-18 14:34:29 +0200
  • 0ca6dc2c6f Remove duplicate locking Christoffer Fjellström 2017-09-30 09:30:29 +0200
  • 7b6215604e Merge remote-tracking branch 'upstream/master' No-ops 2017-09-29 10:51:16 +0200
  • 8a7ac5b450 Merge branch 'develop' No-ops 2017-09-27 16:57:19 +0200
  • a2eb7ba410 Remove unused imports No-ops 2017-09-27 16:57:03 +0200
  • 53bb686b76 Merge branch 'develop' No-ops 2017-09-27 16:51:18 +0200
  • e701107e40 Remove broken test suite Christoffer Fjellström 2017-09-27 16:42:48 +0200
  • 99d317427f Add skipping for integration tests when running unit tests Christoffer Fjellström 2017-09-27 16:42:21 +0200
  • d8cb3883ad Merge pull request #79 from John-Lin/fixed-typo Sadlil Rhythom 2017-09-27 16:59:04 +0600
  • d9ad23413d Merge pull request #1 from Detectify/develop Christoffer Fjellström 2017-09-27 12:00:00 +0200
  • 2dbf199260 Add lock on job handler assignment Christoffer Fjellström 2017-09-27 11:57:57 +0200
  • e1224a8c20 fixed typo and keep WorkComplate for downward compatibility John-Lin 2017-09-27 13:19:08 +0800
  • 94543bd9f1 Merge ea240397b7 into 9735b2e54f Sam Grimee 2017-04-15 23:34:36 +0000
  • cb619326bf Merge 234596770d into 9735b2e54f Kyle Vigen 2017-03-02 13:31:01 +0000
  • c6ceb2fac3 Merge bc27f6f7db into 9735b2e54f jian 2017-03-02 13:31:01 +0000
  • cb3b3e5d72 Merge bb34d7332d into 9735b2e54f jian 2017-03-02 13:31:01 +0000
  • 20069e6500 Merge f61772507f into 9735b2e54f Sadlil Rhythom 2017-03-02 13:31:00 +0000
  • 9735b2e54f Merge pull request #75 from No-ops/patch-1 Christoffer Fjellström 2017-03-02 13:40:41 +0100
  • 27942f55cd Add sync lock on do() to avoid race conditions when creating jobs Christoffer Fjellström 2017-02-03 10:06:27 +0100
  • d6791e2e42 Add sync lock to create job functions Christoffer Fjellström 2017-01-16 16:44:48 +0100
  • f61772507f fix counter bugs sadlil 2016-09-21 13:08:17 +0600
  • 475f2aa0d0 added counting running jobs, disable/enable worker to recive jobs sadlil 2016-09-21 12:05:34 +0600
  • b79fee2965 Merge pull request #70 from JessonChan/master Xing 2016-05-06 22:33:03 +1200
  • dd82e211a3 concurrent map bug fixed JessonChan 2016-05-06 18:00:58 +0800
  • 234596770d Merge pull request #3 from Clever/merge-from-upstream-master jian 2016-04-27 19:24:57 -0700
  • bb34d7332d Merge remote-tracking branch 'upstream/master' into merge-from-upstream-master Jian Cheung 2016-04-26 17:46:02 -0700
  • bc27f6f7db Check if buffer read is complete before decoding Dan Sparks 2014-09-29 18:01:50 -0700
  • f22d6d7e8d Ability to exit work loop gracefully Kyle Vigen 2014-06-10 11:37:10 -0700
  • 68777318f9 Merge pull request #65 from JessonChan/master Xing 2016-04-24 11:03:26 +1200
  • 99c8032384 fix a bug when high qps JessonChan 2016-04-20 12:54:21 +0800
  • 21cc8de64f Merge pull request #63 from kujohn/pool-custom-handler Xing 2015-12-14 18:41:29 +0800
  • 9d99accce2 Allow built in selectionHandlers to be reused outside of package John Ku 2015-12-11 13:48:02 -0800
  • 6d9b2fba51 Merge pull request #62 from kujohn/pool-custom-handler Xing 2015-12-11 12:44:35 +0800
  • 1c4b8aa000 Export pool.clients for custom Pool instantiation John Ku 2015-12-10 13:54:48 -0800
  • d20c3c7bd1 Allow custom Pool without constructor John Ku 2015-12-10 11:19:04 -0800
  • 453e1c902a Merge d17ea720c1 into c6c6c9cac2 John Ku 2015-12-10 18:20:49 +0000
  • d17ea720c1 custom selection and error handler for NewPool John Ku 2015-12-10 10:14:03 -0800
  • c6c6c9cac2 don't use sigillum Xing Xing 2015-07-10 20:30:35 +0800
  • 503d523dbf Merge pull request #60 from micmac/master Xing 2015-07-10 20:24:16 +0800
  • c615e74af8 Replace mutex in client.do() with a channel to avoid deadlock and introduce command timeout Endre Hirling 2015-07-06 21:40:49 +0200
  • df1af4f8cb 80 chars/line Xing Xing 2015-01-20 10:28:36 +0800
  • b612b80f80 complete the list of contributors Xing Xing 2015-01-20 10:27:12 +0800
  • 2c9d82830c merge, update README to the newest API design. Xing Xing 2015-01-20 09:43:54 +0800
  • 37db439a4a Update README.md C.R. Kirkwood-Watts 2015-01-19 10:28:21 -0800
  • bc80b2f853 fixed signal method Xing Xing 2015-01-16 17:41:19 +0800
  • 939189448e golib/signal upgrade Xing Xing 2015-01-15 10:28:21 +0800
  • 9dbb3ea3fc added lock-write to co-ordinate package sequence #56 Xing Xing 2015-01-15 10:26:53 +0800
  • c01a2e22c0 upgrade travis to Go 1.4 Xing Xing 2015-01-10 00:09:38 +0800
  • ad9b3cb988 go fmt Xing Xing 2015-01-06 11:45:18 +0800
  • a003eac543 fixed the closing method Xing Xing 2015-01-06 11:34:39 +0800
  • c9a5aea1cf Merge 0deaa25a0b into d32eb195e1 wickning1 2014-12-10 01:15:04 +0000
  • d32eb195e1 Merge branch 'kdar-big-data' Xing Xing 2014-12-10 09:14:08 +0800
  • 25735c8488 merge for issue #33 Xing Xing 2014-12-10 09:13:49 +0800
  • dc1af95307 Merge pull request #2 from Clever/dont-log-not-enough-data Dan Sparks 2014-09-30 11:09:09 -0700
  • e8802e3215 Check if buffer read is complete before decoding Dan Sparks 2014-09-29 18:01:50 -0700
  • ea92c122a5 Merge pull request #50 from AzuraMeta/patch-1 Xing 2014-08-21 16:32:24 +0800
  • e005ea4442 Fixed WORK_FAIL needing 2 arguments Gabriel Cristian Alecu 2014-08-21 10:41:23 +0300
  • 9387a36a0b Merge pull request #49 from gbarr/write-errors Xing 2014-08-21 09:24:18 +0800
  • 7bcc4de76f Do not ignore write errors Graham Barr 2014-08-20 11:27:32 -0500
  • ccb6f4a24f Merge pull request #48 from gbarr/large-packet-read Xing 2014-08-19 17:11:42 +0800
  • d82da8fd71 Avoid read channel corruption when response size > bufferSize Graham Barr 2014-08-18 09:58:28 -0500
  • 49ea8c0ec1 Increase buffer size to 8K Graham Barr 2014-08-18 09:51:33 -0500
  • 1f303d8145 Merge pull request #47 from gbarr/memleak Xing 2014-07-25 09:46:21 +0800
  • 3e556edb2d When a job completes, remove its handler Graham Barr 2014-05-23 08:00:58 -0500
  • 097037d212 Merge pull request #1 from Clever/graceful-shutdown kvigen 2014-06-17 11:24:19 -0700
  • d40888817d Merge branch 'master' into 0.2-dev Xing Xing 2014-06-16 11:00:20 +0800
  • dde0c3e9b3 Merge pull request #45 from draxil/worker_disconnect_testing Xing 2014-06-16 10:58:57 +0800
  • abfc23f301 Ability to exit work loop gracefully Kyle Vigen 2014-06-10 11:37:10 -0700
  • 14f4df8ede Joe helped us greatly 0.2-dev Xing Xing 2014-06-13 10:55:32 +0800
  • c8d59ea348 Merge branch 'master' into 0.2-dev Xing Xing 2014-06-13 10:51:48 +0800
  • c6c0d4f481 Merge pull request #43 from draxil/master Xing 2014-06-13 10:25:57 +0800
  • ccdbc5e3f5 Merge 8cdaef9752 into 320155c608 kvigen 2014-06-10 21:52:58 +0000