[Transform] Improve robustness when saving state#62086

Merged

hendrikmuhs merged 21 commits intoelastic:masterfrom hendrikmuhs:transform-saveState

Sep 28, 2020

+931-62

Commits on Sep 23, 2020

refactor how state is persisted, so it can not be called from more than 1
Hendrik Muhs
committed
unmute integration tests
Hendrik Muhs
committed
enhance the integration test to do several runs with start and stop
Hendrik Muhs
committed
apply review comments
Hendrik Muhs
committed
ensure saveState listeners are called in either case and fix concurrency
Hendrik Muhs
committed
remove superflous line
Hendrik Muhs
committed
Call listener immediately if indexer is not indexing or value hasn't changed.
Hendrik Muhs
committed
add module tests for shopAtCheckpoint
Hendrik Muhs
committed
add file headers
Hendrik Muhs
committed
persist state if indexer state is started
Hendrik Muhs
committed
log if state persistance fails
Hendrik Muhs
committed
do not block the network thread
Hendrik Muhs
committed
adapt tests, so it does not assert on the threadpool
Hendrik Muhs
committed
add testcase for throttling
Hendrik Muhs
committed
assert that state has been persisted with shouldStopAtCheckpoint
Hendrik Muhs
committed
ensure listeners are called if transform stops
Hendrik Muhs
committed
add back synchronized to setShouldStopAtCheckpoint to avoid problems
Hendrik Muhs
committed
do not call action listener onResponse inside getAndUpdate
Hendrik Muhs
committed
simplify by using updateAndGet
Hendrik Muhs
committed
make updateAndGet free of side effects
Hendrik Muhs
committed
do not call listener from synchronized block
Hendrik Muhs
committed