You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2018/10/26 07:19:30 UTC
[incubator-skywalking] branch h2-storage updated (986c650 ->
b5403a8)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch h2-storage
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git.
from 986c650 Fix rat
add 24e958f 1. Fixed the bug of inventory equals method. (#1814)
add d9556c3 Make Mesh and Istio receivers ready (#1821)
add b5403a8 Merge branch 'master' into h2-storage
No new revisions were added by this update.
Summary of changes:
.../apm/commons/datacarrier/DataCarrier.java | 10 +-
.../commons/datacarrier/consumer/ConsumerPool.java | 9 +-
.../datacarrier/consumer/ConsumerPoolTest.java | 4 +-
.../analysis/indicator/ThermodynamicIndicator.java | 18 +-
.../analysis/worker/IndicatorAggregateWorker.java | 16 +-
.../analysis/worker/IndicatorPersistentWorker.java | 19 +-
.../core/analysis/worker/IndicatorProcess.java | 4 +-
.../analysis/worker/IndicatorRemoteWorker.java | 8 +-
.../core/analysis/worker/PersistenceWorker.java | 2 +-
.../register/service/ServiceInventoryRegister.java | 1 +
.../register/worker/RegisterDistinctWorker.java | 6 +-
.../register/worker/RegisterPersistentWorker.java | 49 +++++-
.../core/remote/client/GRPCRemoteClient.java | 2 +-
.../oap/server/core/source/DetectPoint.java | 2 +-
.../core/storage/ttl/DataTTLKeeperTimer.java | 21 ++-
.../indicator/ThermodynamicIndicatorTest.java | 10 +-
.../handler/IstioTelemetryHandlerMainTest.java | 86 +++++++++
.../fixture/01-ingress-reviewsv1-policy.msg | 193 +++++++++++++++++++++
.../fixture/02-productpage-details-policy.msg | 193 +++++++++++++++++++++
.../resources/fixture/03-productpage-details.msg | 193 +++++++++++++++++++++
.../resources/fixture/04-productpage-details.msg | 105 +++++++++++
.../resources/fixture/05-productpage-reviews.msg | 105 +++++++++++
.../resources/fixture/06-productpage-reviews.msg | 105 +++++++++++
.../resources/fixture/07-ingress-productpage.msg | 105 +++++++++++
.../resources/fixture/08-ingress-productpage.msg | 105 +++++++++++
.../test/resources/fixture/09-policy-telemetry.msg | 105 +++++++++++
.../test/resources/fixture/10-policy-telemetry.msg | 105 +++++++++++
.../resources/fixture/11-details-telemetry.msg | 105 +++++++++++
.../fixture/12-ingress-productpage-telemetry.msg | 193 +++++++++++++++++++++
.../resources/fixture/13-productpage-telemetry.msg | 105 +++++++++++
.../fixture/14-reviews-productpage-telemetry.msg | 193 +++++++++++++++++++++
.../receiver/mesh/MeshDataBufferFileCache.java | 2 +-
.../receiver/mesh/TelemetryDataDispatcher.java | 47 ++++-
.../server/receiver/trace/mock/AgentDataMock.java | 12 +-
.../src/main/resources/component-libraries.yml | 6 +
.../elasticsearch/base/BatchProcessEsDAO.java | 2 +
36 files changed, 2191 insertions(+), 55 deletions(-)
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/istio/telemetry/handler/IstioTelemetryHandlerMainTest.java
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/01-ingress-reviewsv1-policy.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/02-productpage-details-policy.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/03-productpage-details.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/04-productpage-details.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/05-productpage-reviews.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/06-productpage-reviews.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/07-ingress-productpage.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/08-ingress-productpage.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/09-policy-telemetry.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/10-policy-telemetry.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/11-details-telemetry.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/12-ingress-productpage-telemetry.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/13-productpage-telemetry.msg
create mode 100644 oap-server/server-receiver-plugin/skywalking-istio-telemetry-receiver-plugin/src/test/resources/fixture/14-reviews-productpage-telemetry.msg