Skip to content
Descoped Source Code Portalv2.2.13
PollingSign in

Commits in descoped/data-collector-core

Up to date
Expanded debug loggingbe5ef93
More monitor metrics and dump threads to failed worker7061cf0
Improved worker http request exception handlinga2fc421
Refactoring37f571c
Moved execute http status validation to exec request and retryb5e70f8
Use request timeout config2d00af2
Implemented more features from HttpClient and HttpRequestfb74497
Guard worker service create and cancel taskccc96b6
Improved EL exception handling1854370
Added specificationId to monitorbad92ad
Print global variable evaluation80887b5
Optimization: only call to lastPosition once during initializationdd9cfc2
Revert to use slf4j 1.8.0-beta2add503f
Set worker status to canceled on termination signal9279fdf
Http client async and timeout5d7a234
Terminate worker when signaled0f66ba4
Added unique specification id759b515
Close topic resources only when worker is completeb6b7278
Always close content-store on exception985600b
Critical region around reordering and content-store publication31e9408
Timeout http request after 5 secse40fc0e
Added write duration monitor metrics to content stream6e82182
Less verbose monitor thread info48b4800
Fixed monitor prefetch countc256a08
Refactoring97da7cf
Health and monitoring. Task list and cancel.6a8ce43
Revert slf4j and logback jpms because their broken. Added GCS providerafa1620
Upgrade slf4j and logback to JPMS compliant modules51ccf3d
Set default port to 9990c90e547
Removed unused props409f959
Refactoring and added health worker35c7a60
Refactoring6568031
Guard against running same specification in paralleldea6577
Added Health support6a7ec61
Added docs badgesec60336
Configured codacy and codecovbcf1505
Worker service test3f9f36e
Removed initial position from worker202470b
Added codeacy badge503c6b8
Docs updatefd2a0fd
Added EL function lastOrInitialPositiond83c359
Renamed connector module39b88ac
Removed unused codef843d55
Fixed correct handling of last position4ccb130
Fixed stop at numberOfParallelIterationsa818ace
Updated consumer specs and ensure content stream is always closedad5616f
Improved exception handler8bef505
ExecutionException base classfa48026
Evaluate nested expression in paginate handlere2d3958
Refactoring of ExpressionLanguagefaa5f6b
Renamed provider to connector4eb3b0b
Print config as yaml363e715
Renamed flow to specification and step to pipe5269e37
Tighten http error (require further improvements)d210302
Removed Position wrapper2f6eed1
Simplified parallel execution4b11212
Close content-stream and rawdata-client resources820785e
Docker server endpoint /task to exec a job (specification)2aeae38
Prepared endpoint /task for running data collector workerd55b001
Renamed nodes to functions and steps to pipes4bff864
Throw ParallelException in ParallelHandlere4c00c9
Gitignore certs archives4fed816
Test xpath parser serialization and deserialization16a8207
Made DocumentParserFeature for serialization and deserializatione8f6985
Configurable trace logging68c9eb9
Use argLine Jacoco parameter only for coverage profile8a0bf77
Fixed NPEcf3ee0b
Removed illegal ${argLine} in maven surefired47a5fb
Retry request on error (default: 3 retries)646ab7a
Forward page-entry to children in parallelcb17ff0
Improved exception handling in xpath2d03cd3
Replaced hard-coded nextSequence variable with condition.identifier()679f907
end-of-stream tracing92a6a0e
Refactoring (#1)dd051dc
Behold argLine parameter set by Jacocoe6a89a8
Renamed DSL: node to function and step to pipe46b3153
Refactoring0f4a179
Merge remote-tracking branch 'origin/master'Merge of 2 parents.f0fa2b7
Add Drone pipeline9c2f51e
Test if cert bundle existsed42eef
Test for unknown exception (requires code review)cfd676f
Paginate lifecycle and spawn thread for parallel handling4dc4c7a
Ignore initial position variable when null9ba85be
Renamed var and disabled test787df94
Delegated pagination to Lifecycle2fe1c84
Moved paginate loop to execute14acf31
Renamed builder method4a83a81
Added security config to FlowBuilderd0f965d
Expect ske-test-certs for sirius and freg test casesbabbff4
Gitignore **/*certs directories20246c4
Fixed unset topicName from builder config5853757
Worker.Builder fixes and cleaned up test casesadec4a7
Minor refactoring275767f
Fixed broken test caseba3df96
Disable cert scan testced7203
Implemented Worker.Builder that enables a complete fluent api exec798e982
Package private access security support classes25ee04e
Package private access security support classes13ecdd8
Renamed static method2db2730
Scan for certificate bundles and build SSLContext factory0b58952