Commits in descoped/data-collector-core
Up to date
Expanded debug loggingoranheimbe5ef93
More monitor metrics and dump threads to failed workeroranheim7061cf0
Improved worker http request exception handlingoranheima2fc421
Refactoringoranheim37f571c
Moved execute http status validation to exec request and retryoranheimb5e70f8
Use request timeout configoranheim2d00af2
Implemented more features from HttpClient and HttpRequestoranheimfb74497
Guard worker service create and cancel taskoranheimccc96b6
Improved EL exception handlingoranheim1854370
Added specificationId to monitororanheimbad92ad
Print global variable evaluationoranheim80887b5
Optimization: only call to lastPosition once during initializationoranheimdd9cfc2
Revert to use slf4j 1.8.0-beta2oranheimadd503f
Set worker status to canceled on termination signaloranheim9279fdf
Http client async and timeoutoranheim5d7a234
Terminate worker when signaledoranheim0f66ba4
Added unique specification idoranheim759b515
Close topic resources only when worker is completekimcsb6b7278
Always close content-store on exceptionkimcs985600b
Critical region around reordering and content-store publicationkimcs31e9408
Timeout http request after 5 secsoranheime40fc0e
Added write duration monitor metrics to content streamoranheim6e82182
Less verbose monitor thread infooranheim48b4800
Fixed monitor prefetch countoranheimc256a08
Refactoringoranheim97da7cf
Health and monitoring. Task list and cancel.oranheim6a8ce43
Revert slf4j and logback jpms because their broken. Added GCS provideroranheimafa1620
Upgrade slf4j and logback to JPMS compliant modulesoranheim51ccf3d
Set default port to 9990oranheimc90e547
Removed unused propsoranheim409f959
Refactoring and added health workeroranheim35c7a60
Refactoringoranheim6568031
Guard against running same specification in paralleloranheimdea6577
Added Health supportoranheim6a7ec61
Added docs badgesoranheimec60336
Configured codacy and codecovoranheimbcf1505
Worker service testoranheim3f9f36e
Removed initial position from workeroranheim202470b
Added codeacy badgeoranheim503c6b8
Docs updateoranheimfd2a0fd
Added EL function lastOrInitialPositionoranheimd83c359
Renamed connector moduleoranheim39b88ac
Removed unused codeoranheimf843d55
Fixed correct handling of last positionoranheim4ccb130
Fixed stop at numberOfParallelIterationsoranheima818ace
Updated consumer specs and ensure content stream is always closedoranheimad5616f
Improved exception handleroranheim8bef505
ExecutionException base classoranheimfa48026
Evaluate nested expression in paginate handleroranheime2d3958
Refactoring of ExpressionLanguageoranheimfaa5f6b
Renamed provider to connectororanheim4eb3b0b
Print config as yamloranheim363e715
Renamed flow to specification and step to pipeoranheim5269e37
Tighten http error (require further improvements)oranheimd210302
Removed Position wrapperoranheim2f6eed1
Simplified parallel executionoranheim4b11212
Close content-stream and rawdata-client resourcesoranheim820785e
Docker server endpoint /task to exec a job (specification)oranheim2aeae38
Prepared endpoint /task for running data collector workeroranheimd55b001
Renamed nodes to functions and steps to pipesoranheim4bff864
Throw ParallelException in ParallelHandleroranheime4c00c9
Gitignore certs archivesoranheim4fed816
Test xpath parser serialization and deserializationoranheim16a8207
Made DocumentParserFeature for serialization and deserializationoranheime8f6985
Configurable trace loggingoranheim68c9eb9
Use argLine Jacoco parameter only for coverage profilepawbu8a0bf77
Fixed NPEoranheimcf3ee0b
Removed illegal ${argLine} in maven surefireoranheimd47a5fb
Retry request on error (default: 3 retries)oranheim646ab7a
Forward page-entry to children in paralleloranheimcb17ff0
Improved exception handling in xpathoranheim2d03cd3
Replaced hard-coded nextSequence variable with condition.identifier()oranheim679f907
end-of-stream tracingkimcs92a6a0e
Refactoring (#1)kimcsdd051dc
Behold argLine parameter set by Jacocopawbue6a89a8
Renamed DSL: node to function and step to pipeoranheim46b3153
Refactoringoranheim0f4a179
Merge remote-tracking branch 'origin/master'Merge of 2 parents.pawbuf0fa2b7
Add Drone pipelinepawbu9c2f51e
Test if cert bundle existsoranheimed42eef
Test for unknown exception (requires code review)oranheimcfd676f
Paginate lifecycle and spawn thread for parallel handlingoranheim4dc4c7a
Ignore initial position variable when nulloranheim9ba85be
Renamed var and disabled testoranheim787df94
Delegated pagination to Lifecycleoranheim2fe1c84
Moved paginate loop to executeoranheim14acf31
Renamed builder methodoranheim4a83a81
Added security config to FlowBuilderoranheimd0f965d
Expect ske-test-certs for sirius and freg test casesoranheimbabbff4
Gitignore **/*certs directoriesoranheim20246c4
Fixed unset topicName from builder configoranheim5853757
Worker.Builder fixes and cleaned up test casesoranheimadec4a7
Minor refactoringoranheim275767f
Fixed broken test caseoranheimba3df96
Disable cert scan testoranheimced7203
Implemented Worker.Builder that enables a complete fluent api execoranheim798e982
Package private access security support classesoranheim25ee04e
Package private access security support classesoranheim13ecdd8
Renamed static methodoranheim2db2730
Scan for certificate bundles and build SSLContext factoryoranheim0b58952