 bigeagle
|
76ad3d40d6
feature(worker): when SIGINT/SIGTERM received, stop all the jobs and update their status before quit. Close #19.
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
51fa12900d
feature(worker): ability to hot reload mirror job configrations, close #18
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
f8fd1ae460
style: better logging
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
41e1f263a5
refactor(worker): use atomic state to simplify job control
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
292a24ba20
fix(worker): fixed job status and control logic
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
ce3471e30d
feature(worker): implemented Worker object, worker side code is almost done
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
9afd47ddcb
feature(worker): LogLimiter hook
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
731fba842f
feature(worker): job need to be started by jobStart signal
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
9339fba074
refactor(worker): use Run instead of Start and Wait
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
b077db1d0b
feature(worker): job schedule
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
f31bcfbcc3
feature(API): error message in manager channel
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
26b7ef9a9c
refactor(worker): use write blocking for semaphore
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
6b05a5894e
feature(worker): runMirrorJob no longer controls the interval
|
%!s(int64=9) %!d(string=hai) anos |
|
bigeagle
|
681388ffdd
feature(worker): toplevel mirror job logic
|
%!s(int64=9) %!d(string=hai) anos |
