This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from d9a991e [STREAMPIPES-272] Add javadoc to StreamPipes Client API
add 6a82830 [STREAMPIPES-245] Add initial version of pipeline monitoring
feature
add 9383b70 Merge branch 'dev' into STREAMPIPES-245
add 74e1492 [STREAMPIPES-245] Refactor pipeline monitoring feature
No new revisions were added by this update.
Summary of changes:
.../backend/StreamPipesResourceConfig.java | 1 +
.../kafka/config/ConsumerConfigFactory.java | 2 +-
.../model/monitoring/ConsumedMessagesInfo.java | 67 ++++++
...eamPipesRuntimeError.java => MessagesInfo.java} | 39 ++--
...mPipesStatistics.java => MessagesMetaInfo.java} | 30 ++-
.../monitoring/PipelineElementMonitoringInfo.java | 86 +++++++
.../PipelineMonitoringInfo.java} | 53 ++---
.../model/monitoring/ProducedMessagesInfo.java | 46 ++--
.../manager/execution/http/PipelineExecutor.java | 31 ++-
.../manager/matching/DataSetGroundingSelector.java | 2 -
.../pipeline/PipelineExecutionStatusCollector.java | 61 +++++
.../monitoring/pipeline/TopicInfoCollector.java | 258 +++++++++++++++++++++
.../streampipes/rest/api/IPipelineMonitoring.java | 8 +-
...rovidedOptions.java => PipelineMonitoring.java} | 23 +-
.../app-transport-monitoring.module.ts | 4 +-
.../outgoing/outgoing-view.component.html | 12 +-
.../transport-summary.component.html | 14 +-
ui/src/app/core-model/gen/streampipes-model.ts | 99 +++++++-
ui/src/app/core-ui/core-ui.module.ts | 12 +-
.../barchart/barchart-widget.component.html} | 20 +-
.../barchart/barchart-widget.component.scss} | 0
.../barchart/barchart-widget.component.ts} | 32 ++-
.../widget/status/status-widget.component.css} | 0
.../widget/status/status-widget.component.html} | 7 +-
.../widget/status/status-widget.component.ts} | 13 +-
.../actions/pipeline-actions.component.ts | 4 +-
.../elements/pipeline-elements-row.component.html | 4 +-
.../elements/pipeline-elements-row.component.ts | 3 +
.../components/model/pipeline-details.model.ts | 8 +-
.../monitoring/pipeline-monitoring.component.html | 50 ++++
.../monitoring/pipeline-monitoring.component.scss} | 25 +-
.../monitoring/pipeline-monitoring.component.ts | 112 +++++++++
.../pipeline-element-statistics.component.html | 45 ++++
.../pipeline-element-statistics.component.scss} | 8 +-
.../pipeline-element-statistics.component.ts | 140 +++++++++++
.../preview/pipeline-preview.component.html | 2 +-
.../pipeline-details.component.html | 7 +-
.../pipeline-details/pipeline-details.module.ts | 6 +
.../pipeline-overview.component.html | 4 +-
.../pipeline-overview.component.ts | 4 +-
.../services/pipeline-operations.service.ts | 16 +-
...s.service.ts => pipeline-monitoring.service.ts} | 24 +-
ui/src/app/platform-services/platform.module.ts | 2 +
ui/src/scss/sp/colors.scss | 4 +
ui/src/scss/sp/main.scss | 2 +-
45 files changed, 1197 insertions(+), 193 deletions(-)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/ConsumedMessagesInfo.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/{StreamPipesRuntimeError.java
=> MessagesInfo.java} (60%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/{StreamPipesStatistics.java
=> MessagesMetaInfo.java} (62%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/PipelineElementMonitoringInfo.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{runtime/DataSetStatusMessage.java
=> monitoring/PipelineMonitoringInfo.java} (52%)
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/RawUserApiToken.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/ProducedMessagesInfo.java
(53%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/PipelineExecutionStatusCollector.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/TopicInfoCollector.java
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineApi.java
=>
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineMonitoring.java
(82%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{ContainerProvidedOptions.java
=> PipelineMonitoring.java} (65%)
copy
ui/src/app/{app-transport-monitoring/components/dashboard-status-filled/dashboard-status-filled.component.html
=> core-ui/widget/barchart/barchart-widget.component.html} (63%)
copy ui/src/app/{editor/components/pipeline/pipeline.component.css =>
core-ui/widget/barchart/barchart-widget.component.scss} (100%)
copy ui/src/app/core-ui/{image/image.component.ts =>
widget/barchart/barchart-widget.component.ts} (66%)
rename
ui/src/app/{app-transport-monitoring/components/dashboard-status-filled/dashboard-status-filled.component.css
=> core-ui/widget/status/status-widget.component.css} (100%)
rename
ui/src/app/{app-transport-monitoring/components/dashboard-status-filled/dashboard-status-filled.component.html
=> core-ui/widget/status/status-widget.component.html} (84%)
rename
ui/src/app/{app-transport-monitoring/components/dashboard-status-filled/dashboard-status-filled.component.ts
=> core-ui/widget/status/status-widget.component.ts} (80%)
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/security/Role.java
=> ui/src/app/pipeline-details/components/model/pipeline-details.model.ts (91%)
create mode 100644
ui/src/app/pipeline-details/components/monitoring/pipeline-monitoring.component.html
copy ui/src/app/{files/files.component.scss =>
pipeline-details/components/monitoring/pipeline-monitoring.component.scss} (78%)
create mode 100644
ui/src/app/pipeline-details/components/monitoring/pipeline-monitoring.component.ts
create mode 100644
ui/src/app/pipeline-details/components/monitoring/statistics/pipeline-element-statistics.component.html
copy
ui/src/app/{connect/dialog/edit-event-property/components/edit-timestamp-property/edit-timestamp-property.component.css
=>
pipeline-details/components/monitoring/statistics/pipeline-element-statistics.component.scss}
(92%)
create mode 100644
ui/src/app/pipeline-details/components/monitoring/statistics/pipeline-element-statistics.component.ts
copy ui/src/app/platform-services/apis/{measurement-units.service.ts =>
pipeline-monitoring.service.ts} (74%)
