This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch fix/lifecycle-self-identity-resolution
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
discard 3efd9c5bb docs(grafana): add lifecycle migration dashboard; move Tier
Migrations panel from nodes dashboard
omit 0be42369a ci: re-run to verify cold_query test is flaky
omit c1bb0aa50 test(lifecycle): set POD_NAME=localhost for
runLifecycleMigration in integration test
omit 1e4e04bd7 test(fodc): add 4 lifecycle_migration metrics to
documented_gap.txt
omit 77dba8178 docs(lifecycle): tighten parseGroup comment, drop stale
historical note
omit 0dc28294d refactor(lifecycle): add emittedLastRunSet bool to correctly
Delete empty-tuple predecessor
omit 65775875f refactor(lifecycle): track emittedLastRun* tuple to
correctly delete stale series between cycles; strengthen per-pod identity
assertion
omit 3abe07efb refactor(lifecycle): recordLastRun Deletes stale tuple,
CHANGES.md entry corrected, regex label order, identity test strengthened
omit 6ac0d32db refactor(lifecycle): carry remote_*, group labels on
cycle-level metrics; drop self_identity_resolution_total
omit e8fd611f4 chore: fix lint issues
omit d0c28db76 docs(observability): split lifecycle traffic into its own
dashboard row
omit 87071c4ac fix(lifecycle): resolve sender identity from pod name
instead of grpc-addr
add 82a9a0218 refactor(lifecycle): carry remote_*, group labels on
cycle-level metrics; drop self_identity_resolution_total (#1172)
add 9aeec6f26 Refactor migration tool and support stream catalog data
(#1174)
add 9630914ae chore(mcp,ui): bump npm dependencies and update CI actions
(#1175)
add 6dc1b196e chore(deps): bump esbuild, @vitejs/plugin-vue and vite in
/ui (#1176)
add 6bd08635d Add vectorized pull-mode trace query pipeline (#1177)
add e38fa2434 fix(lifecycle): resolve sender identity from pod name
instead of grpc-addr
add 8810324e9 refactor(lifecycle): recordLastRun Deletes stale tuple,
CHANGES.md entry corrected, regex label order, identity test strengthened
add ac253a7e5 refactor(lifecycle): track emittedLastRun* tuple to
correctly delete stale series between cycles; strengthen per-pod identity
assertion
add 2337a275f refactor(lifecycle): add emittedLastRunSet bool to correctly
Delete empty-tuple predecessor
add 6ed77f552 ci: re-run to verify cold_query test is flaky
add 83133728d docs(grafana): add lifecycle migration dashboard; move Tier
Migrations panel from nodes dashboard
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (3efd9c5bb)
\
N -- N -- N refs/heads/fix/lifecycle-self-identity-resolution
(83133728d)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/actions/setup-build-env/action.yml | 18 +-
.github/workflows/e2e.yml | 2 +-
.github/workflows/prepare.yml | 4 +-
.github/workflows/publish-docker.yml | 2 +-
CHANGES.md | 2 +-
banyand/backup/lifecycle/service.go | 8 -
banyand/backup/lifecycle/steps_test.go | 1 +
banyand/cmd/migration/MIGRATION.md | 163 +-
banyand/cmd/migration/README.md | 49 +-
banyand/cmd/migration/analyze.go | 286 ++--
banyand/cmd/migration/copy.go | 65 +-
banyand/cmd/migration/example/plan-backup.yaml | 20 +-
banyand/cmd/migration/example/plan-live.yaml | 67 +-
banyand/cmd/migration/example/runner-pod.yaml | 19 +-
banyand/cmd/migration/main.go | 29 +-
banyand/cmd/migration/plan.go | 285 +---
banyand/cmd/migration/scripts/verify-data.sh | 77 +-
banyand/cmd/migration/verify.go | 186 ++-
banyand/internal/migration/classify.go | 84 +
banyand/internal/migration/classify_test.go | 178 +++
banyand/internal/migration/executor.go | 78 +
banyand/internal/migration/fsutil.go | 122 ++
banyand/internal/migration/fsutil_test.go | 74 +
.../internal/migration/migration_measure_test.go | 266 ++++
.../internal/migration/migration_stream_test.go | 581 +++++++
banyand/internal/migration/orchestrator.go | 314 ++++
banyand/internal/migration/orchestrator_test.go | 79 +
banyand/{cmd => internal}/migration/plan.go | 131 +-
banyand/{cmd => internal}/migration/plan_test.go | 18 +-
banyand/internal/migration/schemaroot.go | 98 ++
banyand/internal/migration/srcroots.go | 91 ++
banyand/internal/migration/unionsidx.go | 332 ++++
.../migration/unionsidx_test.go} | 96 +-
banyand/internal/sidx/block_scanner.go | 95 ++
banyand/internal/sidx/interfaces.go | 137 +-
banyand/internal/sidx/query.go | 185 +++
banyand/internal/sidx/query_test.go | 63 +
banyand/internal/sidx/sidx.go | 81 +
banyand/measure/migration_analyze.go | 7 -
banyand/measure/migration_copy.go | 881 +----------
banyand/measure/migration_copy_test.go | 245 ---
banyand/measure/migration_e2e_test.go | 43 +-
banyand/measure/migration_executor.go | 153 ++
banyand/measure/migration_schema.go | 404 +----
banyand/measure/migration_schema_test.go | 91 +-
banyand/measure/migration_verify.go | 143 +-
banyand/metadata/schema/property/client.go | 6 +-
banyand/metadata/schema/property/converter.go | 5 +-
banyand/metadata/schema/property/converter_test.go | 14 +-
banyand/metadata/schema/reader/loaders.go | 184 +++
banyand/metadata/schema/reader/reader.go | 213 +++
banyand/metadata/schema/reader/reader_test.go | 209 +++
banyand/stream/migration_analyze.go | 359 +++++
banyand/stream/migration_copy.go | 901 +++++++++++
banyand/stream/migration_copy_test.go | 349 ++++
banyand/stream/migration_element_index.go | 767 +++++++++
banyand/stream/migration_executor.go | 150 ++
banyand/stream/migration_schema.go | 150 ++
banyand/stream/migration_slowpath_test.go | 770 +++++++++
banyand/stream/migration_verify.go | 327 ++++
banyand/trace/block.go | 38 +-
banyand/trace/metadata.go | 4 +-
banyand/trace/query.go | 179 ++-
banyand/trace/query_test.go | 8 +
banyand/trace/query_vectorized.go | 601 +++++++
banyand/trace/query_vectorized_test.go | 408 +++++
banyand/trace/streaming_pipeline.go | 61 +-
banyand/trace/streaming_pipeline_test.go | 17 +-
banyand/trace/svc_liaison.go | 4 +-
banyand/trace/svc_standalone.go | 4 +-
banyand/trace/trace.go | 22 +-
banyand/trace/vectorized_bench_test.go | 79 +
banyand/trace/vectorized_parity_test.go | 484 ++++++
dist/LICENSE | 81 +-
... license-type-is-node-modules-content-type.txt} | 0
go.mod | 2 +-
mcp/.gitignore | 2 +-
mcp/.licenserc.yaml | 1 +
mcp/LICENSE | 17 +-
mcp/package-lock.json | 513 +++---
pkg/index/inverted/query.go | 11 +
pkg/query/vectorized/appendrange.go | 118 ++
pkg/query/vectorized/appendrange_test.go | 175 ++
pkg/query/vectorized/measure/batchsource.go | 101 +-
pkg/query/vectorized/trace/columns.go | 69 +
pkg/query/vectorized/trace/config.go | 56 +
.../query/vectorized/trace/config_test.go | 23 +-
.../query/vectorized/trace/counters.go | 19 +-
pkg/query/vectorized/trace/distinct_trace_id.go | 90 ++
.../query/vectorized/trace/doc.go | 11 +-
pkg/query/vectorized/trace/group_by_trace_id.go | 178 +++
.../vectorized/trace/group_by_trace_id_test.go | 192 +++
pkg/query/vectorized/trace/limit.go | 78 +
pkg/query/vectorized/trace/limit_carry.go | 111 ++
pkg/query/vectorized/trace/lint_test.go | 83 +
pkg/query/vectorized/trace/phase1_ops_test.go | 94 ++
pkg/query/vectorized/trace/plan.go | 78 +
pkg/query/vectorized/trace/plan_test.go | 156 ++
pkg/query/vectorized/trace/schema.go | 82 +
pkg/query/vectorized/trace/schema_test.go | 56 +
pkg/query/vectorized/trace/sidx_response_iter.go | 119 ++
.../vectorized/trace/sidx_response_iter_test.go | 78 +
.../query/vectorized/trace/sort_key.go | 13 +-
.../query/vectorized/trace/sort_key_test.go | 29 +-
pkg/query/vectorized/trace/sorted_merge.go | 166 ++
pkg/query/vectorized/trace/sorted_merge_test.go | 144 ++
pkg/query/vectorized/trace/static_source.go | 98 ++
.../query/vectorized/trace/static_source_test.go | 42 +-
pkg/query/vectorized/trace/trace_id_decode.go | 81 +
pkg/query/vectorized/trace/trace_project.go | 91 ++
pkg/query/vectorized/trace/trace_project_test.go | 87 +
.../query/vectorized/trace/util.go | 17 +-
test/e2e-v2/cases/cluster/docker-compose.yml | 4 +-
.../e2e-v2/cases/event/banyandb/docker-compose.yml | 2 +-
.../lifecycle/data-generator/docker-compose.yml | 2 +-
test/e2e-v2/cases/lifecycle/docker-compose.yml | 8 +-
test/e2e-v2/cases/log/banyandb/docker-compose.yml | 2 +-
.../profiling/trace/banyandb/docker-compose.yml | 2 +-
.../istio/banyandb/banyandb-deployment-vec.yaml | 1 +
.../istio/banyandb/banyandb-deployment.yaml | 1 +
.../cases/storage/banyandb/docker-compose.yml | 2 +-
.../cases/zipkin/banyandb/docker-compose.yml | 2 +-
.../distributed/query/vectorized_trace_test.go | 114 ++
.../standalone/query/vectorized_trace_test.go | 109 ++
test/soak/docker-compose.soak.yaml | 3 +-
ui/LICENSE | 64 +-
ui/package-lock.json | 1672 +++++++++-----------
ui/package.json | 4 +-
128 files changed, 13930 insertions(+), 4090 deletions(-)
create mode 100644 banyand/internal/migration/classify.go
create mode 100644 banyand/internal/migration/classify_test.go
create mode 100644 banyand/internal/migration/executor.go
create mode 100644 banyand/internal/migration/fsutil.go
create mode 100644 banyand/internal/migration/fsutil_test.go
create mode 100644 banyand/internal/migration/migration_measure_test.go
create mode 100644 banyand/internal/migration/migration_stream_test.go
create mode 100644 banyand/internal/migration/orchestrator.go
create mode 100644 banyand/internal/migration/orchestrator_test.go
copy banyand/{cmd => internal}/migration/plan.go (69%)
rename banyand/{cmd => internal}/migration/plan_test.go (93%)
create mode 100644 banyand/internal/migration/schemaroot.go
create mode 100644 banyand/internal/migration/srcroots.go
create mode 100644 banyand/internal/migration/unionsidx.go
copy banyand/{measure/migration_copy_test.go =>
internal/migration/unionsidx_test.go} (72%)
create mode 100644 banyand/measure/migration_executor.go
create mode 100644 banyand/metadata/schema/reader/loaders.go
create mode 100644 banyand/metadata/schema/reader/reader.go
create mode 100644 banyand/metadata/schema/reader/reader_test.go
create mode 100644 banyand/stream/migration_analyze.go
create mode 100644 banyand/stream/migration_copy.go
create mode 100644 banyand/stream/migration_copy_test.go
create mode 100644 banyand/stream/migration_element_index.go
create mode 100644 banyand/stream/migration_executor.go
create mode 100644 banyand/stream/migration_schema.go
create mode 100644 banyand/stream/migration_slowpath_test.go
create mode 100644 banyand/stream/migration_verify.go
create mode 100644 banyand/trace/query_vectorized.go
create mode 100644 banyand/trace/query_vectorized_test.go
create mode 100644 banyand/trace/vectorized_bench_test.go
create mode 100644 banyand/trace/vectorized_parity_test.go
copy dist/licenses/mcp-licenses/{license-content-type.txt =>
license-type-is-node-modules-content-type.txt} (100%)
create mode 100644 pkg/query/vectorized/appendrange.go
create mode 100644 pkg/query/vectorized/appendrange_test.go
create mode 100644 pkg/query/vectorized/trace/columns.go
create mode 100644 pkg/query/vectorized/trace/config.go
copy test/integration/standalone/deletion/suite_test.go =>
pkg/query/vectorized/trace/config_test.go (56%)
copy banyand/trace/constants.go => pkg/query/vectorized/trace/counters.go (57%)
create mode 100644 pkg/query/vectorized/trace/distinct_trace_id.go
copy banyand/trace/constants.go => pkg/query/vectorized/trace/doc.go (81%)
create mode 100644 pkg/query/vectorized/trace/group_by_trace_id.go
create mode 100644 pkg/query/vectorized/trace/group_by_trace_id_test.go
create mode 100644 pkg/query/vectorized/trace/limit.go
create mode 100644 pkg/query/vectorized/trace/limit_carry.go
create mode 100644 pkg/query/vectorized/trace/lint_test.go
create mode 100644 pkg/query/vectorized/trace/phase1_ops_test.go
create mode 100644 pkg/query/vectorized/trace/plan.go
create mode 100644 pkg/query/vectorized/trace/plan_test.go
create mode 100644 pkg/query/vectorized/trace/schema.go
create mode 100644 pkg/query/vectorized/trace/schema_test.go
create mode 100644 pkg/query/vectorized/trace/sidx_response_iter.go
create mode 100644 pkg/query/vectorized/trace/sidx_response_iter_test.go
copy banyand/trace/constants.go => pkg/query/vectorized/trace/sort_key.go (82%)
copy banyand/liaison/grpc/grpc_suite_test.go =>
pkg/query/vectorized/trace/sort_key_test.go (64%)
create mode 100644 pkg/query/vectorized/trace/sorted_merge.go
create mode 100644 pkg/query/vectorized/trace/sorted_merge_test.go
create mode 100644 pkg/query/vectorized/trace/static_source.go
copy bydbctl/internal/cmd/use_test.go =>
pkg/query/vectorized/trace/static_source_test.go (51%)
create mode 100644 pkg/query/vectorized/trace/trace_id_decode.go
create mode 100644 pkg/query/vectorized/trace/trace_project.go
create mode 100644 pkg/query/vectorized/trace/trace_project_test.go
copy banyand/trace/constants.go => pkg/query/vectorized/trace/util.go (73%)
create mode 100644 test/integration/distributed/query/vectorized_trace_test.go
create mode 100644 test/integration/standalone/query/vectorized_trace_test.go
