This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch dependabot/npm_and_yarn/ui/echarts-6.1.0
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from 5609d3972 chore(deps): bump echarts from 5.6.0 to 6.1.0 in /ui
add ec48e7ff5 feat(trace): dynamic sampler registration via group-scoped
pipeline config (#1198)
add 152fa41f8 Fix block metadata reset before unmarshal for stream and
trace (#1195)
add 4c674abc4 feat: implement global tag type metadata for measure parts
(#1196)
add 38704419f Add FODC memory-pressure pprof capture (#1200)
add 2c9946197 Lifecycle only handle stream/measure/trace snapshots (#1202)
add a4fac2f4b Add Consistently check after Eventually checks (#1204)
add 9b83f0bc6 fix(stream): fix migration corruption from arena tagValue
double-free (#1205)
add 0e3254c99 Add the codex/claude plugin to bydbQL (#1201)
add 215f4bbe0 fix: avoid pooling arena-owned migration tag values (#1203)
add 7edf94bfb Merge branch 'main' into
dependabot/npm_and_yarn/ui/echarts-6.1.0
No new revisions were added by this update.
Summary of changes:
.agents/plugins/marketplace.json | 20 +
.claude-plugin/marketplace.json | 13 +
.claude-plugin/plugin.json | 37 +
.codex-plugin/plugin.json | 37 +
.github/workflows/ci.yml | 2 +
.github/workflows/test-fodc-e2e.yml | 49 +-
.gitignore | 2 +
.golangci.yml | 7 +
.mcp.json | 15 +
CHANGES.md | 8 +
api/proto/banyandb/common/v1/common.proto | 77 ++
api/proto/banyandb/fodc/v1/rpc.proto | 75 +
.../banyandb/pipeline/v1/trace_pipeline.proto | 196 +--
api/validate/validate.go | 44 +
api/validate/validate_test.go | 25 +
banyand/backup/lifecycle/steps.go | 9 +
.../internal/migration/migration_stream_test.go | 6 +-
banyand/measure/block.go | 9 +
banyand/measure/block_metadata.go | 16 +
banyand/measure/block_metadata_test.go | 35 +
banyand/measure/block_reader_test.go | 1 +
banyand/measure/block_test.go | 14 +
banyand/measure/block_writer.go | 11 +-
banyand/measure/file_part_sync_test.go | 30 +-
banyand/measure/merger.go | 14 +-
banyand/measure/merger_test.go | 40 +-
banyand/measure/metadata_test.go | 11 +-
banyand/measure/part.go | 23 +-
banyand/measure/part_iter_test.go | 2 +
banyand/measure/part_metadata.go | 95 ++
banyand/measure/part_test.go | 6 +
banyand/measure/syncer.go | 19 +
banyand/measure/tstable_test.go | 1 +
banyand/measure/write_data.go | 20 +-
banyand/metadata/schema/schemaserver/service.go | 9 +-
banyand/property/db/repair_gossip_test.go | 22 +-
banyand/protector/protector.go | 53 +-
banyand/protector/protector_test.go | 107 ++
banyand/stream/block_metadata.go | 2 +
banyand/stream/block_metadata_test.go | 35 +
banyand/stream/block_scanner_test.go | 1 +
banyand/stream/merger.go | 2 +-
banyand/stream/metadata_test.go | 9 +-
banyand/stream/migration_copy.go | 22 +-
banyand/stream/part_iter_test.go | 2 +
banyand/stream/query_by_idx_test.go | 1 +
banyand/stream/test_helper.go | 110 +-
banyand/stream/tstable_test.go | 1 +
banyand/stream/wqueue_test.go | 10 +-
banyand/trace/block_metadata.go | 2 +
banyand/trace/block_metadata_test.go | 34 +
banyand/trace/merger.go | 16 +-
banyand/trace/metadata.go | 161 ++-
banyand/trace/metadata_test.go | 7 +-
banyand/trace/metrics.go | 5 +-
banyand/trace/pipeline_loader.go | 67 +-
banyand/trace/pipeline_loader_test.go | 104 +-
banyand/trace/pipeline_metrics.go | 93 ++
banyand/trace/pipeline_metrics_test.go | 387 ++++++
banyand/trace/pipeline_registry.go | 89 +-
banyand/trace/pipeline_registry_test.go | 177 +++
banyand/trace/pipeline_watch_test.go | 491 +++++++
banyand/trace/svc_standalone.go | 42 -
banyand/trace/testmain_test.go | 46 +
banyand/trace/trace.go | 1 -
bydbctl/internal/cmd/measure_test.go | 5 +-
bydbctl/internal/cmd/property_test.go | 31 +-
bydbctl/internal/cmd/stream_test.go | 5 +-
bydbctl/internal/cmd/topn_test.go | 7 +-
bydbctl/internal/cmd/trace_test.go | 5 +-
docs/api-reference.md | 414 +++---
docs/menu.yml | 2 +
docs/operation/mcp/build.md | 16 +
docs/operation/mcp/plugin.md | 123 ++
fodc/agent/internal/cmd/root.go | 64 +-
fodc/agent/internal/cmd/root_test.go | 39 +
fodc/agent/internal/flightrecorder/datasource.go | 19 +
.../internal/flightrecorder/flightrecorder.go | 45 +
.../internal/flightrecorder/flightrecorder_test.go | 52 +
fodc/agent/internal/pressureprofiler/fetch.go | 59 +
fodc/agent/internal/pressureprofiler/profiler.go | 239 ++++
.../internal/pressureprofiler/profiler_test.go | 206 +++
fodc/agent/internal/pressureprofiler/storage.go | 258 ++++
.../internal/pressureprofiler/storage_test.go | 128 ++
fodc/agent/internal/proxy/client.go | 263 ++++
.../internal/proxy/client_blocking_send_test.go | 4 +-
fodc/agent/internal/proxy/client_test.go | 99 +-
fodc/agent/internal/watchdog/watchdog.go | 18 +
fodc/agent/testhelper/flightrecorder.go | 3 +
fodc/agent/testhelper/pressureprofiler.go | 110 ++
fodc/internal/pprofcapture/pprofcapture.go | 44 +
fodc/proxy/cmd/proxy/main.go | 9 +-
fodc/proxy/internal/api/server.go | 136 ++
fodc/proxy/internal/api/server_test.go | 18 +-
fodc/proxy/internal/grpc/pressure_list_test.go | 130 ++
fodc/proxy/internal/grpc/server_test.go | 8 +-
fodc/proxy/internal/grpc/service.go | 406 +++++-
fodc/proxy/internal/grpc/service_test.go | 4 +-
.../integration/agent_reconnection_test.go | 4 +-
.../agent_registration_metrics_flow_test.go | 4 +-
.../cluster_topology_integration_test.go | 4 +-
fodc/proxy/internal/integration/diagnostic_test.go | 4 +-
.../internal/integration/failure_scenarios_test.go | 6 +-
.../integration/full_proxy_workflow_test.go | 4 +-
.../high_availability_scalability_test.go | 4 +-
.../integration/lifecycle_integration_test.go | 4 +-
.../integration/metrics_time_window_test.go | 4 +-
.../integration/multiple_agents_roles_test.go | 4 +-
.../internal/integration/pressure_profile_test.go | 246 ++++
.../integration/prometheus_integration_test.go | 4 +-
fodc/proxy/internal/pressure/aggregator.go | 269 ++++
fodc/proxy/internal/pressure/aggregator_test.go | 99 ++
mcp/.gitignore | 1 +
mcp/.licenserc.yaml | 2 +
mcp/Makefile | 23 +-
mcp/package-lock.json | 1443 +++++++++++++++++++-
mcp/package.json | 8 +-
mcp/src/index.ts | 2 +-
mcp/src/query/parse-validator.test.ts | 79 ++
mcp/src/query/parse-validator.ts | 123 ++
mcp/src/query/validation.test.ts | 62 +
mcp/src/query/validation.ts | 2 +-
mcp/src/server/mcp.ts | 48 +
mcp/tools/build-validator.js | 44 +
mcp/tools/bydbql-parse/main.go | 96 ++
mcp/tools/bydbql-parse/main_test.go | 114 ++
mcp/tools/bydbql-parse/testdata/invalid.txt | 22 +
mcp/tools/bydbql-parse/testdata/valid.txt | 28 +
mcp/tools/check-plugin-manifests.js | 88 ++
mcp/tsconfig.json | 2 +-
pkg/test/eventually.go | 151 ++
pkg/test/eventually_test.go | 62 +
pkg/test/flags/flags.go | 31 +
pkg/test/setup/external.go | 79 ++
skills/bydbql/SKILL.md | 39 +
skills/bydbql/references/examples.md | 30 +
skills/bydbql/references/safety.md | 18 +
skills/bydbql/references/syntax.md | 374 +++++
test/cases/lifecycle/lifecycle.go | 25 +-
test/cases/lifecycle/orphan.go | 5 +-
test/cases/measure/measure.go | 3 +-
test/cases/property/data/data.go | 5 +
test/cases/property/property.go | 3 +-
test/cases/schema/clamp.go | 3 +-
test/cases/schema/shape_break.go | 7 +-
test/cases/schema/tag_family_move.go | 9 +-
test/cases/stream/stream.go | 3 +-
test/cases/trace/cmd/generate/seed.go | 4 +-
.../cases/trace/data/testdata/sw_mixed_traces.json | 4 +-
...duration_asc_limit2_offset1_proj_explicit_1.yml | 38 +-
...t_order_duration_asc_limit5_proj_explicit_6.yml | 78 +-
...en_feat_order_duration_desc_proj_explicit_3.yml | 4 +-
...ter_state_eq_limit5_offset1_proj_explicit_8.yml | 4 +-
test/cases/trace/data/want/gen_leaf_eq_state.yml | 4 +-
.../cases/trace/data/want/gen_leaf_ge_duration.yml | 4 +-
test/cases/trace/data/want/gen_leaf_ge_state.yml | 4 +-
.../cases/trace/data/want/gen_leaf_gt_duration.yml | 4 +-
test/cases/trace/data/want/gen_leaf_gt_state.yml | 4 +-
.../trace/data/want/gen_leaf_in_service_id.yml | 2 +-
.../cases/trace/data/want/gen_leaf_in_trace_id.yml | 2 +-
.../cases/trace/data/want/gen_leaf_le_duration.yml | 4 +-
test/cases/trace/data/want/gen_leaf_le_state.yml | 4 +-
.../cases/trace/data/want/gen_leaf_lt_duration.yml | 4 +-
test/cases/trace/data/want/gen_leaf_lt_state.yml | 4 +-
.../trace/data/want/gen_leaf_ne_service_id.yml | 4 +-
test/cases/trace/data/want/gen_leaf_ne_state.yml | 4 +-
.../cases/trace/data/want/gen_leaf_ne_trace_id.yml | 4 +-
.../trace/data/want/gen_leaf_not_in_service_id.yml | 4 +-
.../trace/data/want/gen_leaf_not_in_trace_id.yml | 4 +-
.../trace/data/want/gen_tree_depth5_deep_and.yml | 4 +-
test/cases/trace/trace.go | 3 +-
test/cases/tracepipeline/ops.go | 177 +++
test/cases/tracepipeline/tracepipeline.go | 260 +++-
.../cases/fodc-pressure/banyandb-cluster.yaml | 98 ++
test/e2e-v2/cases/fodc-pressure/check-pressure.sh | 123 ++
test/e2e-v2/cases/fodc-pressure/e2e.yaml | 68 +
.../expected/pressure-status.yml} | 2 +-
test/integration/distributed/pipeline/common.go | 138 +-
.../distributed/pipeline/dynamic_test.go | 505 +++++++
test/integration/handoff/handoff_suite_test.go | 6 +-
.../replication/measure_normal_replication_test.go | 3 +-
test/integration/replication/replication_test.go | 3 +-
.../replication/stream_replication_test.go | 3 +-
.../replication/trace_replication_test.go | 3 +-
test/integration/standalone/other/measure_test.go | 3 +-
test/integration/standalone/other/tls_test.go | 7 +-
test/integration/standalone/pipeline/common.go | 113 +-
.../standalone/pipeline/dynamic_test.go | 440 ++++++
test/integration/standalone/pipeline/soak_test.go | 26 +-
test/plugins/_latencystatussampler/main.go | 19 +-
190 files changed, 10980 insertions(+), 956 deletions(-)
create mode 100644 .agents/plugins/marketplace.json
create mode 100644 .claude-plugin/marketplace.json
create mode 100644 .claude-plugin/plugin.json
create mode 100644 .codex-plugin/plugin.json
create mode 100644 .mcp.json
create mode 100644 banyand/trace/pipeline_metrics.go
create mode 100644 banyand/trace/pipeline_metrics_test.go
create mode 100644 banyand/trace/pipeline_registry_test.go
create mode 100644 banyand/trace/pipeline_watch_test.go
create mode 100644 banyand/trace/testmain_test.go
create mode 100644 docs/operation/mcp/plugin.md
create mode 100644 fodc/agent/internal/pressureprofiler/fetch.go
create mode 100644 fodc/agent/internal/pressureprofiler/profiler.go
create mode 100644 fodc/agent/internal/pressureprofiler/profiler_test.go
create mode 100644 fodc/agent/internal/pressureprofiler/storage.go
create mode 100644 fodc/agent/internal/pressureprofiler/storage_test.go
create mode 100644 fodc/agent/testhelper/pressureprofiler.go
create mode 100644 fodc/internal/pprofcapture/pprofcapture.go
create mode 100644 fodc/proxy/internal/grpc/pressure_list_test.go
create mode 100644 fodc/proxy/internal/integration/pressure_profile_test.go
create mode 100644 fodc/proxy/internal/pressure/aggregator.go
create mode 100644 fodc/proxy/internal/pressure/aggregator_test.go
create mode 100644 mcp/src/query/parse-validator.test.ts
create mode 100644 mcp/src/query/parse-validator.ts
create mode 100644 mcp/src/query/validation.test.ts
create mode 100644 mcp/tools/build-validator.js
create mode 100644 mcp/tools/bydbql-parse/main.go
create mode 100644 mcp/tools/bydbql-parse/main_test.go
create mode 100644 mcp/tools/bydbql-parse/testdata/invalid.txt
create mode 100644 mcp/tools/bydbql-parse/testdata/valid.txt
create mode 100644 mcp/tools/check-plugin-manifests.js
create mode 100644 pkg/test/eventually.go
create mode 100644 pkg/test/eventually_test.go
create mode 100644 skills/bydbql/SKILL.md
create mode 100644 skills/bydbql/references/examples.md
create mode 100644 skills/bydbql/references/safety.md
create mode 100644 skills/bydbql/references/syntax.md
create mode 100644 test/cases/tracepipeline/ops.go
create mode 100644 test/e2e-v2/cases/fodc-pressure/banyandb-cluster.yaml
create mode 100755 test/e2e-v2/cases/fodc-pressure/check-pressure.sh
create mode 100644 test/e2e-v2/cases/fodc-pressure/e2e.yaml
copy test/e2e-v2/cases/{zipkin/expected/remote-service-name.yml =>
fodc-pressure/expected/pressure-status.yml} (98%)
create mode 100644 test/integration/distributed/pipeline/dynamic_test.go
create mode 100644 test/integration/standalone/pipeline/dynamic_test.go