search

ru-fix / completable-reactor

CompletableReactor framework makes it easier to create business flows that have concurrently running parts and complex execution branching.
https://ru-fix.github.io/completable-reactor
MIT License
12 stars 2 forks source link

#32 use identity instead string, payload name and operation type (mer… #33

Closed KuznetsovVlad closed 4 years ago

KuznetsovVlad commented 4 years ago

…ger/handler) writes as labels

KuznetsovVlad commented 4 years ago

Now metrics looks like this

vertices ` ✔completable_reactor_vertices_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="merger",payload="ru.fix.ewp.bookkeeper.app.domain.payment.hold.PaymentHoldPayload",serverId="1",vertex="validateInputData"}

✔completable_reactor_vertices_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="merger",payload="ru.fix.ewp.bookkeeper.app.domain.payment.hold.PaymentHoldPayload",serverId="1",vertex="makePaymentHoldTransaction"}

✔completable_reactor_vertices_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="merger",payload="ru.fix.ewp.bookkeeper.app.domain.payment.hold.PaymentHoldPayload",serverId="1",vertex="findIdempotentTransaction"}

✔completable_reactor_vertices_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="merger",payload="ru.fix.ewp.bookkeeper.app.domain.payment.hold.PaymentHoldPayload",serverId="1",vertex="findContractorWallet"}

✔completable_reactor_vertices_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="merger",payload="ru.fix.ewp.bookkeeper.app.domain.payment.hold.PaymentHoldPayload",serverId="1",vertex="findContractor"}`

graph execution

`✔completable_reactor_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="payload_execution",payload="ru.fix.ewp.bookkeeper.app.domain.payment.replenishment.PaymentReplenishmentPayload",serverId="1"}

✔completable_reactor_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="payload_execution",payload="ru.fix.ewp.bookkeeper.app.domain.payment.hold.PaymentHoldPayload",serverId="1"}

✔completable_reactor_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="payload_execution",payload="ru.fix.ewp.bookkeeper.app.domain.payment.commit.PaymentCommitPayload",serverId="1"}

✔completable_reactor_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="execution",payload="ru.fix.ewp.bookkeeper.app.domain.payment.replenishment.PaymentReplenishmentPayload",serverId="1"}

✔completable_reactor_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="execution",payload="ru.fix.ewp.bookkeeper.app.domain.payment.hold.PaymentHoldPayload",serverId="1"}

✔completable_reactor_latencyPercentile95{app="bookkeeper",instance="bookkeeper:18001",job="profiler-bookkeeper",kubernetes_namespace="local",operation="execution",payload="ru.fix.ewp.bookkeeper.app.domain.payment.commit.PaymentCommitPayload",serverId="1"}`