This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch docs/storage-format-accuracy
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from ac79797bf docs: make storage/file-format docs code-accurate and add
API-first reference
add 933e53d6a docs: add snapshot retention flags and relative path version
note (#1097)
add 8a39ceb19 fix(measure,stream,trace): wait until all mem parts flushed
in file_snapshot tests (#1098)
add e90e46934 fix(trace): resolve flaky schema change merge test (#1099)
add 7a339bfea fix: stabilize flaky TestCollectWithPartialClosedSegments
and fit flaky-test in 50min (#1100)
add fd89c669d fix(fodc): heal reconnect deadlock and add error message
when no agents for lifecycle request (#1101)
add b44d38b71 fix: Use `topic` instead of `session_id` as the Prometheus
label (#1093)
add 84d5879d6 chore: bump ui and mcp npm dependencies (#1104)
add 059c39686 Fix FODC lifecycle endpoint wrong encoding and increase the
gRPC timeout between agent and proxy (#1103)
add 772e749e7 feat(schema): add NodeSchemaStatusService (Phase 2 Step 2.1)
(#1108)
add 65df753ed feat(queue): add NewNodeSchemaStatusClient to queue.Client
(Phase 2 prep) (#1109)
add bb93d4813 sub pr2: queue_sub chunked sync observability (#1107)
add c936ce8b7 feat(barrier): cluster fan-out for AwaitRevisionApplied
(Phase 2 Step 2.2) (#1111)
add 4206e0ee6 test(bydbctl): avoid race-prone stdout capture in command
tests (#1105)
add e81064021 fix(trace): accept out-of-order timestamps within the same
traceID (#1114)
add b8168b76a Fix fetch segment nil pointer in cold stage and propagation
the error when inspect the group (#1115)
add 32aeea3bc Fix missing property group adapt when inspect group (#1117)
add 8f0033a6e fix(banyand): close merge durability gap (#13862) (#1118)
add bc093f218 feat(barrier): Phase 2 cluster-wide schema consistency
barrier (CP-5/CP-6) (#1121)
add e61f42e1c Make the InspectAll CI more stable (#1122)
add d2cb7daf6 Fix lifecycle migration segment shorter than the configured
`SegmentInterval` (#1120)
add 5c401217f fix: fail fast on incompatible storage version (boot +
runtime paths) (#1124)
add e189e0512 Validate ShardingKey against Entity tags (#1069)
add 32c5c7d83 feat: queue_pub observability (#1113)
add 61d698684 Support float64 type field for topn (#1110)
add 4ec4cf42c chore(mcp): upgrade Node dependencies to latest within
current majors (#1125)
add 0ffd0b91c feat: implement panic diagnostics and FODC crash reporting
pipeline (#1084)
add b60e588e1 fix(property): prevent gossip propagation from getting stuck
after replica scale-up (#1127)
add 2804bdf87 feat: vectorized measure query subsystem (scan +
GroupBy+Agg) (#1129)
add af5970f0c fix(queue/pub): keep pub-node-probe alive after caller ctx
cancel (#1130)
add 188e955ec ci(flaky-test): skip loadtest packages from ./... discovery
(#1131)
add 4320e7cee fix(query): dedup IndexMode measures by series ID across
data nodes (#1132)
add 0dd5d684c align part sync timestamp to segment grid so part and sidx
land in the same segment (#1136)
add 7ba863118 Fix backup restore path traversal (#1135)
add 3d4539308 fix: release bluge index writers on segment rotation
(#13874) (#1128)
add a3d7a97a7 Introduce measure migration tool (#1138)
add 349a41316 fix(test/cases/measure): preserve Apache license header on
captured want fixtures and gate the capture loop (#1137)
add 84b919efc Validate tag moves across stream and measure storage modes
(#1139)
add e695dad96 Fix incorrect counts, rate and missing trace fields in the
lifecycle migration report (#1133)
add db4faac28 Vectorized measure query: end-to-end implementation + opt-in
tracing (#1141)
add ccaf7228c Refactor the dump tool into a reusable `banyand/dump` parser
library (#1142)
add 28cd2a7a2 Support displaying a measure's indexed tags in the dump tool
(#1143)
add 46a3d9708 Fix lifecycle migration of non-multiple segment intervals
via row-replay (#1145)
add 0f6837aec Snapshot/backup and data inspection no longer reopen
idle-closed segments (#1146)
add 249424f99 Fix trace identity-tag projection and distributed span tag
alignment (#1147)
add ea481add8 Fix unstable measure dump UT (#1148)
add 06d592ead Fix measure, stream, and trace queries returning TTL-expired
data (#1149)
add 1b245e633 Enhance segment lifecycle (#1151)
add e34d0e4a5 Add program-generated trace query integration-test framework
(#1150)
add 3366d2a76 Fix flaky measure snapshot tests gating on part dir instead
of flush persist (#1152)
add 45e667437 Thread Prometheus metric type end-to-end through FODC agent
and proxy (#1153)
add b2be017c8 Fix migration failure when row replay from large data (#1154)
add af0b2cf49 fix(trace): move storage metrics under trace.storage
subscope (#1155)
add 30c4c65fc Merge branch 'main' into docs/storage-format-accuracy
No new revisions were added by this update.
Summary of changes:
.github/workflows/e2e.yml | 39 +-
.github/workflows/flaky-test.yml | 6 +-
.github/workflows/test.yml | 2 +-
.gitignore | 6 +
.licenserc.yaml | 1 +
CHANGES.md | 55 +-
Makefile | 57 +-
api/data/codec.go | 184 ++
api/data/codec_test.go | 269 +++
api/data/data.go | 88 +-
api/proto/banyandb/database/v1/rpc.proto | 2 +
api/proto/banyandb/fodc/v1/rpc.proto | 56 +
api/proto/banyandb/measure/v1/query.proto | 2 +
api/proto/banyandb/schema/v1/barrier.proto | 10 +-
api/proto/banyandb/stream/v1/write.proto | 6 +
api/validate/validate.go | 32 +
api/validate/validate_test.go | 163 ++
banyand/Dockerfile | 1 +
banyand/Makefile | 2 +-
banyand/backup/backup.go | 16 +-
banyand/backup/backup_test.go | 2 +-
banyand/backup/lifecycle/lifecycle.go | 6 +
.../backup/lifecycle/measure_migration_visitor.go | 225 ++-
banyand/backup/lifecycle/migration_integration.go | 161 +-
banyand/backup/lifecycle/progress.go | 354 +++-
banyand/backup/lifecycle/progress_mark_test.go | 269 +++
.../lifecycle/report_partial_failure_test.go | 313 ++++
banyand/backup/lifecycle/row_replay.go | 312 ++++
banyand/backup/lifecycle/row_replay_measure.go | 270 +++
banyand/backup/lifecycle/row_replay_pipeline.go | 351 ++++
banyand/backup/lifecycle/row_replay_stream.go | 224 +++
banyand/backup/lifecycle/row_replay_test.go | 1518 ++++++++++++++++
banyand/backup/lifecycle/row_replay_trace.go | 149 ++
banyand/backup/lifecycle/segment_boundary_utils.go | 46 +-
.../lifecycle/segment_boundary_utils_test.go | 245 ++-
banyand/backup/lifecycle/service.go | 177 +-
banyand/backup/lifecycle/steps.go | 87 +-
banyand/backup/lifecycle/steps_test.go | 93 +
.../backup/lifecycle/stream_migration_visitor.go | 229 ++-
.../backup/lifecycle/trace_migration_visitor.go | 227 ++-
banyand/backup/restore.go | 35 +-
banyand/backup/restore_test.go | 97 ++
banyand/backup/snapshot/snapshot.go | 3 +-
banyand/cmd/dump/measure.go | 1003 ++---------
banyand/cmd/dump/measure_test.go | 395 +++--
banyand/cmd/dump/stream.go | 818 +--------
banyand/cmd/dump/stream_test.go | 293 ++--
banyand/cmd/dump/trace.go | 799 +--------
banyand/cmd/dump/trace_test.go | 308 +---
banyand/cmd/migration/MIGRATION.md | 458 +++++
banyand/cmd/migration/README.md | 144 ++
banyand/cmd/migration/analyze.go | 186 ++
banyand/cmd/migration/copy.go | 189 ++
banyand/cmd/migration/example/plan-backup.yaml | 41 +
banyand/cmd/migration/example/plan-live.yaml | 67 +
banyand/cmd/migration/example/runner-pod.yaml | 80 +
banyand/cmd/migration/main.go | 88 +
banyand/cmd/migration/plan.go | 301 ++++
banyand/cmd/migration/plan_test.go | 290 ++++
banyand/cmd/migration/scripts/verify-data.sh | 113 ++
banyand/cmd/migration/verify.go | 339 ++++
banyand/dquery/dquery.go | 10 +
banyand/dquery/measure.go | 154 +-
banyand/dquery/measure_test.go | 252 +++
banyand/dquery/topn.go | 136 +-
banyand/internal/dump/decode.go | 149 ++
banyand/internal/dump/dump_test.go | 114 ++
banyand/internal/dump/helpers.go | 145 ++
banyand/internal/dump/index_resolver.go | 202 +++
banyand/internal/dump/iterator.go | 112 ++
banyand/internal/dump/measure/iterator.go | 165 ++
banyand/internal/dump/measure/measure.go | 663 +++++++
banyand/internal/dump/measure/measure_test.go | 567 ++++++
banyand/internal/dump/measure/suite_test.go | 612 +++++++
banyand/internal/dump/stream/iterator.go | 131 ++
banyand/internal/dump/stream/stream.go | 525 ++++++
banyand/internal/dump/stream/stream_test.go | 467 +++++
banyand/internal/dump/stream/suite_test.go | 218 +++
banyand/internal/dump/trace/iterator.go | 120 ++
banyand/internal/dump/trace/suite_test.go | 224 +++
banyand/internal/dump/trace/trace.go | 503 ++++++
banyand/internal/dump/trace/trace_test.go | 342 ++++
banyand/internal/sidx/merge.go | 3 +-
banyand/internal/sidx/merger_durability_test.go | 95 +
banyand/internal/sidx/metadata.go | 2 +-
banyand/internal/sidx/part.go | 19 +-
banyand/internal/sidx/part_wrapper.go | 13 +-
banyand/internal/sidx/query.go | 25 +-
banyand/internal/sidx/scan_query.go | 2 +-
banyand/internal/sidx/sidx.go | 2 +-
banyand/internal/storage/cache.go | 14 +-
banyand/internal/storage/cache_test.go | 3 +-
banyand/internal/storage/index.go | 49 +-
banyand/internal/storage/inspect_stats.go | 143 ++
banyand/internal/storage/inspect_stats_test.go | 96 ++
banyand/internal/storage/rotation.go | 29 +-
banyand/internal/storage/rotation_test.go | 48 +-
banyand/internal/storage/segment.go | 483 +++++-
.../internal/storage/segment_idle_reclaim_test.go | 708 ++++++++
.../storage/segment_lifecycle_integration_test.go | 218 +++
banyand/internal/storage/segment_test.go | 854 ++++++++-
banyand/internal/storage/snapshot.go | 16 +
.../storage/snapshot_closed_segment_test.go | 764 ++++++++
banyand/internal/storage/snapshot_test.go | 30 +
banyand/internal/storage/storage.go | 53 +-
banyand/internal/storage/tsdb.go | 128 +-
banyand/internal/storage/tsdb_test.go | 209 ++-
banyand/internal/storage/version.go | 24 +-
banyand/internal/storage/version_test.go | 29 +
banyand/internal/wqueue/wqueue.go | 2 +-
banyand/internal/wqueue/wqueue_test.go | 25 +-
banyand/liaison/grpc/barrier.go | 85 +-
banyand/liaison/grpc/barrier_cluster.go | 842 +++++++++
banyand/liaison/grpc/barrier_cluster_test.go | 1012 +++++++++++
banyand/liaison/grpc/barrier_metrics.go | 265 +++
banyand/liaison/grpc/barrier_metrics_test.go | 405 +++++
banyand/liaison/grpc/deletion.go | 14 +-
banyand/liaison/grpc/deletion_test.go | 28 +-
banyand/liaison/grpc/discovery.go | 37 +-
banyand/liaison/grpc/measure.go | 24 +-
banyand/liaison/grpc/metrics.go | 62 +-
banyand/liaison/grpc/registry.go | 9 +-
banyand/liaison/grpc/schema_revision_registry.go | 92 +
.../liaison/grpc/schema_revision_registry_test.go | 370 ++++
banyand/liaison/grpc/server.go | 93 +-
banyand/liaison/grpc/stream.go | 22 +-
banyand/liaison/grpc/trace.go | 27 +-
banyand/liaison/http/server.go | 6 +-
banyand/measure/batch_decode.go | 219 +++
banyand/measure/block.go | 134 +-
banyand/measure/block_batch.go | 626 +++++++
banyand/measure/block_batch_benchmark_test.go | 248 +++
banyand/measure/block_metadata_test.go | 9 +-
banyand/measure/cache_benchmark_test.go | 2 +-
banyand/measure/measure.go | 24 +
banyand/measure/merger.go | 22 +-
banyand/measure/merger_durability_test.go | 82 +
banyand/measure/merger_test.go | 70 +-
banyand/measure/metadata.go | 100 +-
banyand/measure/metadata_internal_test.go | 120 ++
banyand/measure/migration_analyze.go | 934 ++++++++++
banyand/measure/migration_copy.go | 1816 ++++++++++++++++++++
banyand/measure/migration_copy_test.go | 303 ++++
banyand/measure/migration_e2e_test.go | 598 +++++++
banyand/measure/migration_schema.go | 446 +++++
banyand/measure/migration_schema_test.go | 308 ++++
banyand/measure/migration_verify.go | 401 +++++
banyand/measure/migration_verify_test.go | 209 +++
banyand/measure/part.go | 13 +-
banyand/measure/part_metadata.go | 2 +-
banyand/measure/query.go | 98 +-
banyand/measure/query_batch.go | 391 +++++
banyand/measure/query_test.go | 64 +-
banyand/measure/snapshot_test.go | 71 +-
banyand/measure/svc_data.go | 17 +-
banyand/measure/svc_liaison.go | 14 +
banyand/measure/svc_standalone.go | 18 +-
banyand/measure/test_helper.go | 251 ++-
banyand/measure/topn.go | 636 +++++--
banyand/measure/topn_post_processor.go | 165 +-
banyand/measure/topn_post_processor_test.go | 201 ++-
banyand/measure/topn_test.go | 144 +-
banyand/measure/tstable.go | 73 +-
banyand/measure/write_data.go | 6 +-
banyand/measure/write_data_segmentref_test.go | 181 +-
banyand/measure/write_liaison.go | 6 +-
banyand/measure/write_standalone.go | 8 +-
banyand/metadata/client.go | 16 +-
banyand/metadata/discovery/dns/dns.go | 2 +-
banyand/metadata/metadata.go | 11 +-
banyand/metadata/schema/collector.go | 64 +-
banyand/metadata/schema/collector_test.go | 118 ++
banyand/metadata/schema/property/cache.go | 34 +
banyand/metadata/schema/property/client.go | 198 ++-
banyand/metadata/schema/property/client_test.go | 34 +
banyand/metadata/schema/property/converter.go | 41 +
.../metadata/schema/property/init_handler_test.go | 209 +++
banyand/metadata/schema/property/node_status.go | 288 ++++
.../schema/property/node_status_registry_test.go | 205 +++
.../metadata/schema/property/node_status_test.go | 301 ++++
banyand/metadata/schema/property/watch_control.go | 66 +
.../metadata/schema/property/watch_control_test.go | 139 ++
banyand/metadata/schema/schemaserver/grpc.go | 5 +-
.../metadata/schema/schemaserver/repair_service.go | 4 +-
banyand/metadata/schema/schemaserver/service.go | 22 +-
banyand/metadata/service/server.go | 11 +
banyand/observability/pprof.go | 6 +-
banyand/observability/services/meter_native.go | 12 +-
banyand/observability/services/service.go | 84 +-
banyand/property/db/repair.go | 21 +-
banyand/property/db/repair_gossip.go | 58 +-
banyand/property/db/repair_gossip_test.go | 338 ++++
banyand/property/db/shard.go | 41 +
banyand/property/gossip/client.go | 8 +-
banyand/property/gossip/server.go | 74 +-
banyand/property/gossip/service.go | 36 +-
banyand/property/gossip/service_test.go | 344 ++++
banyand/property/gossip/trace.go | 10 +-
banyand/property/scheduler.go | 4 +-
banyand/protector/protector.go | 4 +-
banyand/query/processor.go | 300 +++-
banyand/query/processor_topn.go | 85 +-
banyand/query/tracing_test.go | 167 ++
banyand/queue/local.go | 11 +
banyand/queue/pub/batch.go | 179 +-
banyand/queue/pub/client.go | 40 +-
banyand/queue/pub/client_test.go | 2 +-
banyand/queue/pub/metrics_test.go | 499 ++++++
banyand/queue/pub/pub.go | 80 +-
banyand/queue/pub/pub_suite_test.go | 14 +-
banyand/queue/pub/pub_tls_test.go | 13 +-
banyand/queue/pub/retry_test.go | 18 +-
banyand/queue/queue.go | 20 +
banyand/queue/sub/chunked_sync.go | 183 +-
banyand/queue/sub/chunked_sync_test.go | 124 ++
banyand/queue/sub/group_lifecycle.go | 14 +-
.../queue/sub/group_lifecycle_cold_tier_test.go | 324 ++++
banyand/queue/sub/group_lifecycle_test.go | 116 +-
banyand/queue/sub/server.go | 106 +-
banyand/queue/sub/server_metrics_test.go | 221 +++
banyand/queue/sub/sub.go | 26 +-
banyand/stream/block_scanner_test.go | 42 +-
banyand/stream/merger.go | 3 +-
banyand/stream/merger_durability_test.go | 80 +
banyand/stream/metadata.go | 64 +-
banyand/stream/metadata_internal_test.go | 120 ++
banyand/stream/part.go | 13 +-
banyand/stream/part_metadata.go | 2 +-
banyand/stream/query.go | 15 +-
banyand/stream/query_by_idx.go | 21 +-
banyand/stream/query_by_idx_test.go | 22 +-
banyand/stream/query_by_ts.go | 8 +-
banyand/stream/test_helper.go | 196 ++-
banyand/stream/tstable.go | 71 +-
banyand/stream/write_data.go | 6 +-
banyand/stream/write_data_segmentref_test.go | 149 +-
banyand/stream/write_standalone.go | 11 +-
banyand/trace/block.go | 3 +
banyand/trace/block_writer.go | 36 +-
banyand/trace/block_writer_test.go | 50 +
banyand/trace/handoff_controller.go | 31 +-
banyand/trace/handoff_replay_test.go | 8 +-
banyand/trace/merger.go | 22 +-
banyand/trace/merger_durability_test.go | 179 ++
banyand/trace/metadata.go | 65 +-
banyand/trace/metadata_internal_test.go | 120 ++
banyand/trace/metadata_test.go | 36 +-
banyand/trace/metrics.go | 4 +-
banyand/trace/part.go | 13 +-
banyand/trace/part_metadata.go | 6 +-
banyand/trace/query.go | 40 +-
banyand/trace/query_test.go | 57 +-
banyand/trace/storage_scope_test.go | 54 +
banyand/trace/streaming_pipeline.go | 33 +-
banyand/trace/test_helper.go | 176 +-
banyand/trace/tstable.go | 73 +-
banyand/trace/write_data.go | 10 +-
banyand/trace/write_data_segmentref_test.go | 182 +-
banyand/trace/write_liaison.go | 1 +
banyand/trace/write_standalone.go | 1 +
bydbctl/internal/cmd/analyze.go | 12 +-
bydbctl/internal/cmd/analyze_test.go | 13 +-
bydbctl/internal/cmd/auth_test.go | 24 +-
bydbctl/internal/cmd/group.go | 37 +-
bydbctl/internal/cmd/group_test.go | 74 +-
bydbctl/internal/cmd/health_check.go | 6 +-
bydbctl/internal/cmd/health_check_test.go | 68 +-
bydbctl/internal/cmd/index_rule.go | 40 +-
bydbctl/internal/cmd/index_rule_binding.go | 40 +-
bydbctl/internal/cmd/index_rule_binding_test.go | 100 +-
bydbctl/internal/cmd/index_rule_test.go | 100 +-
bydbctl/internal/cmd/measure.go | 34 +-
bydbctl/internal/cmd/measure_test.go | 129 +-
bydbctl/internal/cmd/property.go | 40 +-
bydbctl/internal/cmd/property_test.go | 236 ++-
bydbctl/internal/cmd/rest.go | 14 +-
bydbctl/internal/cmd/root.go | 5 +-
bydbctl/internal/cmd/stream.go | 34 +-
bydbctl/internal/cmd/stream_test.go | 129 +-
bydbctl/internal/cmd/topn.go | 34 +-
bydbctl/internal/cmd/topn_test.go | 168 +-
bydbctl/internal/cmd/trace.go | 42 +-
bydbctl/internal/cmd/trace_test.go | 129 +-
bydbctl/internal/cmd/use.go | 4 +-
bydbctl/internal/cmd/{use.go => use_test.go} | 50 +-
cmd/soak-driver/catalog/default.json | 99 ++
cmd/soak-driver/main.go | 674 ++++++++
dist/LICENSE | 55 +-
.../license-github.com-zenizh-go-capturer.txt | 21 -
.../mcp-licenses/license-eventsource-parser.txt | 2 +-
dist/licenses/mcp-licenses/license-fast-uri.txt | 4 +-
docs/api-reference.md | 145 +-
.../design/fodc/context-aware-panic-diagnostics.md | 432 +++++
docs/interacting/schema-consistency/scenarios.md | 4 +-
docs/observability/vec-query-tracing.md | 305 ++++
docs/operation/configuration.md | 14 +-
docs/operation/fodc/apis.md | 61 +-
docs/operation/grafana-cluster.json | 445 ++++-
docs/operation/observability.md | 60 +-
.../measure-vec-flag-off-rollback.md | 71 +
docs/soak/g5d-phase-d-summary.md | 94 +
docs/soak/g5d-runbook.md | 290 ++++
docs/soak/g9f-runbook.md | 154 ++
fodc/agent/internal/cmd/root.go | 162 +-
fodc/agent/internal/crashcollector/combined.go | 108 ++
fodc/agent/internal/crashcollector/fswatcher.go | 250 +++
.../internal/crashcollector/fswatcher_test.go | 185 ++
fodc/agent/internal/crashcollector/inprocess.go | 76 +
.../internal/crashcollector/inprocess_test.go | 141 ++
fodc/agent/internal/exporter/exporter.go | 19 +-
.../internal/exporter/prometheus_format_test.go | 3 +-
fodc/agent/internal/flightrecorder/datasource.go | 20 +
.../integration/basic_metrics_buffering_test.go | 2 +-
.../internal/integration/buffer_overflow_test.go | 2 +-
.../integration/diagnostic_extended_test.go | 283 +++
.../internal/integration/metrics_export_test.go | 9 +-
fodc/agent/internal/lifecycle/collector.go | 56 +-
fodc/agent/internal/lifecycle/collector_test.go | 263 ++-
fodc/agent/internal/metrics/parse.go | 57 +
fodc/agent/internal/metrics/parse_test.go | 45 +
fodc/agent/internal/proxy/client.go | 361 +++-
.../internal/proxy/client_blocking_send_test.go | 151 ++
fodc/agent/internal/proxy/client_test.go | 119 +-
fodc/agent/internal/proxy/wait.go | 69 +
fodc/agent/internal/proxy/wait_test.go | 61 +
fodc/agent/internal/server/server.go | 141 +-
fodc/agent/internal/server/server_test.go | 97 +-
fodc/agent/internal/watchdog/watchdog.go | 98 +-
fodc/agent/internal/watchdog/watchdog_test.go | 62 +-
fodc/agent/testhelper/flightrecorder.go | 59 +
.../use.go => fodc/internal/timeouts/timeouts.go | 39 +-
fodc/proxy/cmd/proxy/main.go | 7 +-
fodc/proxy/internal/api/server.go | 371 +++-
fodc/proxy/internal/api/server_test.go | 424 ++++-
fodc/proxy/internal/diagnostics/aggregator.go | 281 +++
fodc/proxy/internal/diagnostics/aggregator_test.go | 58 +
fodc/proxy/internal/grpc/server_test.go | 8 +-
fodc/proxy/internal/grpc/service.go | 168 +-
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 | 413 +++++
.../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 +-
.../integration/prometheus_integration_test.go | 4 +-
fodc/proxy/internal/lifecycle/manager.go | 83 +-
fodc/proxy/internal/lifecycle/manager_test.go | 92 +-
fodc/proxy/internal/metrics/aggregator.go | 21 +
go.mod | 7 +-
go.sum | 2 -
mcp/LICENSE | 22 +-
mcp/package-lock.json | 325 ++--
mcp/package.json | 27 +-
pkg/cmdsetup/data.go | 15 +-
pkg/cmdsetup/liaison.go | 19 +-
pkg/cmdsetup/root.go | 14 +
pkg/cmdsetup/standalone.go | 18 +-
pkg/cmdsetup/supervisor.go | 90 +
pkg/cmdsetup/supervisor_test.go | 146 ++
pkg/convert/number.go | 34 +-
pkg/convert/number_test.go | 75 +
pkg/dump/dump.go | 16 +-
pkg/encoding/float.go | 258 ++-
pkg/encoding/float_test.go | 397 ++++-
pkg/flow/streaming/streaming_test.go | 65 +-
pkg/flow/streaming/topn.go | 273 +--
pkg/flow/streaming/topn_heap.go | 162 ++
pkg/flow/streaming/topn_heap_test.go | 212 +++
pkg/flow/streaming/topn_test.go | 285 +--
pkg/flow/types.go | 2 -
pkg/fs/file_system.go | 59 +
pkg/fs/local_file_system.go | 103 +-
pkg/fs/local_file_system_darwin.go | 17 +
pkg/fs/local_file_system_linux.go | 17 +
pkg/fs/local_file_system_test.go | 62 +
.../local_file_system_testhook_test.go} | 22 +-
pkg/fs/local_file_system_windows.go | 6 +
pkg/fs/remote/local/local.go | 94 +-
pkg/fs/remote/local/local_test.go | 307 ++++
pkg/grpchelper/connmanager.go | 17 +-
pkg/index/index.go | 5 +
pkg/index/inverted/inverted.go | 26 +
pkg/index/inverted/inverted_series.go | 53 +
pkg/index/inverted/inverted_series_test.go | 66 +
pkg/initerror/initerror.go | 61 +
pkg/initerror/initerror_test.go | 71 +
pkg/meter/native/collection.go | 4 +-
pkg/panicdiag/artifact.go | 163 ++
pkg/panicdiag/artifact_test.go | 110 ++
pkg/panicdiag/breadcrumb.go | 148 ++
pkg/panicdiag/breadcrumb_test.go | 233 +++
pkg/panicdiag/collections.go | 211 +++
pkg/panicdiag/collections_test.go | 212 +++
pkg/panicdiag/crashoutput.go | 82 +
pkg/panicdiag/crashoutput_test.go | 142 ++
pkg/panicdiag/grpcinterceptors.go | 57 +
pkg/panicdiag/lintrawgo/analyzer.go | 436 +++++
pkg/panicdiag/lintrawgo/analyzer_test.go | 96 ++
pkg/panicdiag/lintrawgo/baseline.txt | 263 +++
.../lintrawgo/testdata/src/badcode/bad.go} | 29 +-
.../lintrawgo/testdata/src/baselined/baselined.go} | 18 +-
pkg/panicdiag/memlimit.go | 57 +
pkg/panicdiag/memlimit_test.go | 120 ++
pkg/panicdiag/metrics.go | 149 ++
pkg/panicdiag/recovery.go | 189 ++
pkg/panicdiag/recovery_test.go | 718 ++++++++
pkg/panicdiag/sink.go | 191 ++
pkg/panicdiag/sink_test.go | 470 +++++
pkg/panicdiag/state.go | 83 +
pkg/panicdiag/state_test.go | 64 +
pkg/panicdiag/types.go | 131 ++
pkg/partition/route.go | 36 +
pkg/partition/route_test.go | 155 ++
pkg/path/path.go | 14 +
pkg/path/path_test.go | 36 +
pkg/query/logical/measure/cross_group_merge.go | 131 ++
pkg/query/logical/measure/measure_analyzer.go | 21 +-
pkg/query/logical/measure/measure_plan.go | 3 +
.../logical/measure/measure_plan_aggregation.go | 4 +
.../logical/measure/measure_plan_distributed.go | 118 +-
.../measure/measure_plan_distributed_test.go | 93 +
pkg/query/logical/measure/measure_plan_groupby.go | 4 +
.../measure/measure_plan_indexscan_local.go | 104 +-
pkg/query/logical/measure/measure_plan_merge.go | 47 +-
pkg/query/logical/measure/measure_plan_top.go | 77 +-
pkg/query/logical/measure/measure_top.go | 76 +-
pkg/query/logical/measure/measure_top_test.go | 56 +-
pkg/query/logical/measure/schema.go | 10 +
pkg/query/logical/measure/schema_test.go | 90 +
pkg/query/logical/measure/topn_analyzer.go | 78 +-
pkg/query/logical/measure/topn_plan_distinct.go | 95 +-
.../logical/measure/topn_plan_distinct_test.go | 92 +-
pkg/query/logical/measure/topn_plan_localscan.go | 123 +-
pkg/query/logical/measure/topn_plan_merge.go | 32 +-
pkg/query/logical/trace/trace_plan_distributed.go | 27 +-
.../logical/trace/trace_plan_distributed_test.go | 130 ++
pkg/query/logical/trace/trace_plan_tag_filter.go | 15 +-
pkg/query/model/batch.go | 175 ++
pkg/query/model/batch_test.go | 186 ++
pkg/query/model/model.go | 20 +
pkg/query/tracelabels/labels.go | 172 ++
pkg/query/tracelabels/labels_doc.go | 16 +
pkg/query/tracelabels/labels_doc_test.go | 81 +
pkg/query/tracelabels/static_usage_test.go | 96 ++
pkg/query/tracer.go | 11 +-
pkg/query/vectorized/batch.go | 66 +
pkg/query/vectorized/batch_test.go | 101 ++
pkg/query/vectorized/column.go | 117 ++
pkg/query/vectorized/column_pool.go | 161 ++
pkg/query/vectorized/column_test.go | 81 +
.../route.go => query/vectorized/doc.go} | 19 +-
pkg/query/vectorized/fused.go | 109 ++
pkg/query/vectorized/fused_test.go | 225 +++
pkg/query/vectorized/measure/AGENTS.md | 3 +
pkg/query/vectorized/measure/adapter.go | 173 ++
pkg/query/vectorized/measure/adapter_test.go | 124 ++
.../vectorized/measure/agg_value_path_test.go | 121 ++
pkg/query/vectorized/measure/aggregation.go | 727 ++++++++
pkg/query/vectorized/measure/aggregation_reduce.go | 197 +++
pkg/query/vectorized/measure/aggregation_test.go | 947 ++++++++++
pkg/query/vectorized/measure/batchsource.go | 327 ++++
pkg/query/vectorized/measure/batchsource_test.go | 247 +++
pkg/query/vectorized/measure/bench_gates_test.go | 146 ++
pkg/query/vectorized/measure/bench_test.go | 788 +++++++++
pkg/query/vectorized/measure/bench_tracing_test.go | 124 ++
pkg/query/vectorized/measure/build_batch.go | 293 ++++
pkg/query/vectorized/measure/build_batch_test.go | 329 ++++
pkg/query/vectorized/measure/config.go | 64 +
pkg/query/vectorized/measure/config_test.go | 52 +
pkg/query/vectorized/measure/cursor.go | 168 ++
pkg/query/vectorized/measure/cursor_test.go | 206 +++
pkg/query/vectorized/measure/diff_test.go | 592 +++++++
.../route.go => query/vectorized/measure/doc.go} | 19 +-
pkg/query/vectorized/measure/extract.go | 169 ++
pkg/query/vectorized/measure/extract_test.go | 355 ++++
pkg/query/vectorized/measure/fixtures_test.go | 61 +
pkg/query/vectorized/measure/frame/decode.go | 328 ++++
pkg/query/vectorized/measure/frame/decode_test.go | 447 +++++
pkg/query/vectorized/measure/frame/encode.go | 296 ++++
pkg/query/vectorized/measure/frame/frame.go | 187 ++
pkg/query/vectorized/measure/frame/frame_test.go | 381 ++++
pkg/query/vectorized/measure/frame/validate.go | 63 +
pkg/query/vectorized/measure/groupby.go | 410 +++++
pkg/query/vectorized/measure/groupby_test.go | 433 +++++
pkg/query/vectorized/measure/integration.go | 301 ++++
pkg/query/vectorized/measure/limit.go | 121 ++
pkg/query/vectorized/measure/limit_test.go | 154 ++
pkg/query/vectorized/measure/plan.go | 183 ++
pkg/query/vectorized/measure/plan/analyzer.go | 308 ++++
pkg/query/vectorized/measure/plan/analyzer_test.go | 361 ++++
pkg/query/vectorized/measure/plan/build_test.go | 233 +++
pkg/query/vectorized/measure/plan/dispatch.go | 493 ++++++
pkg/query/vectorized/measure/plan/dispatch_test.go | 701 ++++++++
pkg/query/vectorized/measure/plan/distributed.go | 1197 +++++++++++++
.../vectorized/measure/plan/distributed_rows.go | 828 +++++++++
.../measure/plan/distributed_rows_test.go | 919 ++++++++++
.../vectorized/measure/plan/distributed_test.go | 837 +++++++++
pkg/query/vectorized/measure/plan/executor.go | 81 +
pkg/query/vectorized/measure/plan/executor_test.go | 255 +++
pkg/query/vectorized/measure/plan/groupby_agg.go | 134 ++
pkg/query/vectorized/measure/plan/hidden_tags.go | 173 ++
pkg/query/vectorized/measure/plan/limit.go | 76 +
.../vectorized/measure/plan/multi_group_schema.go | 255 +++
.../measure/plan/multi_group_schema_test.go | 298 ++++
pkg/query/vectorized/measure/plan/orderby.go | 80 +
pkg/query/vectorized/measure/plan/plan.go | 100 ++
pkg/query/vectorized/measure/plan/scan.go | 89 +
pkg/query/vectorized/measure/plan/sort_key.go | 96 ++
pkg/query/vectorized/measure/plan/sort_key_test.go | 156 ++
pkg/query/vectorized/measure/plan/top.go | 92 +
.../measure/plan/tracing_bottleneck_test.go | 324 ++++
.../measure/plan/tracing_collect_test.go | 87 +
.../measure/plan/tracing_rolling_upgrade_test.go | 119 ++
.../vectorized/measure/plan/tracing_summary.go | 285 +++
.../measure/plan/tracing_summary_test.go | 353 ++++
pkg/query/vectorized/measure/plan_test.go | 217 +++
pkg/query/vectorized/measure/raw_emit.go | 700 ++++++++
.../vectorized/measure/raw_emit_bench_test.go | 214 +++
pkg/query/vectorized/measure/raw_emit_test.go | 485 ++++++
pkg/query/vectorized/measure/reduce.go | 392 +++++
pkg/query/vectorized/measure/scan.go | 345 ++++
pkg/query/vectorized/measure/scan_test.go | 255 +++
pkg/query/vectorized/measure/serialize.go | 181 ++
pkg/query/vectorized/measure/serialize_test.go | 171 ++
.../vectorized/measure/shared_tracker_test.go | 139 ++
pkg/query/vectorized/measure/top.go | 333 ++++
pkg/query/vectorized/measure/top_test.go | 313 ++++
.../vectorized/measure/topology_matrix_test.go | 413 +++++
.../vectorized/measure/tracing_operator_test.go | 74 +
pkg/query/vectorized/memory.go | 79 +
pkg/query/vectorized/memory_test.go | 119 ++
pkg/query/vectorized/operator.go | 70 +
.../route.go => query/vectorized/operator_test.go} | 21 +-
pkg/query/vectorized/pipeline.go | 207 +++
pkg/query/vectorized/pipeline_test.go | 275 +++
pkg/query/vectorized/pool.go | 54 +
pkg/query/vectorized/pool_test.go | 69 +
pkg/query/vectorized/schema.go | 134 ++
pkg/query/vectorized/schema_test.go | 127 ++
pkg/query/vectorized/typed_column.go | 149 ++
pkg/query/vectorized/typed_column_test.go | 142 ++
pkg/run/channel_closer.go | 28 +-
pkg/run/goroutine.go | 210 +++
pkg/run/goroutine_test.go | 425 +++++
pkg/run/run.go | 67 +-
pkg/run/run_test.go | 156 ++
pkg/schema/cache.go | 112 +-
pkg/schema/cache_test.go | 127 ++
pkg/schema/cache_watcher_fatal_test.go | 257 +++
pkg/schema/init.go | 19 +-
pkg/schema/registry/registry.go | 163 ++
pkg/schema/registry/registry_test.go | 185 ++
pkg/schema/schema.go | 5 +-
pkg/test/helpers/constant.go | 19 +-
.../testdata/group_stages/sw_cross_segment.json | 33 +
.../measure/testdata/groups/sw_cross_segment.json | 18 +
.../testdata/measures/cross_segment_metric.json | 32 +
.../measures/service_instance_cpm_minute.json | 11 +-
.../service_instance_cpm_minute_updated.json | 11 +-
.../service_instance_endpoint_cpm_minute.json | 11 +-
...ute.json => service_instance_float_metric.json} | 6 +-
...service_instance_float_metric_top_bottom_3.json | 18 +
pkg/test/setup/setup.go | 45 +
pkg/test/setup/watch_control.go | 91 +-
pkg/test/stream/testdata/group.json | 18 +
pkg/test/stream/testdata/group_with_stages.json | 33 +
.../stream/testdata/streams/cross_segment_log.json | 27 +
.../testdata/groups/sw_cross_segment_trace.json | 19 +
.../groups_stages/sw_cross_segment_trace.json | 34 +
.../index_rule_bindings/cross_segment_trace.json | 16 +
.../index_rules/cross_segment_timestamp.json | 11 +
.../trace/testdata/traces/cross_segment_trace.json | 24 +
pkg/timestamp/scheduler.go | 94 +-
pkg/timestamp/scheduler_test.go | 139 ++
pkg/tls/reloader.go | 8 +-
pkg/tls/reloader_test.go | 17 +-
scripts/bench-vectorized.sh | 117 ++
.../lint/no-span-without-stop.yml | 26 +-
.../lint/no-string-trace-tags.yml | 32 +-
scripts/lint/rawgo-baseline/main.go | 197 +++
scripts/lint/rawgo/main.go | 113 ++
.../lint/stop-before-toproto.yml | 26 +-
scripts/soak-monitor.sh | 181 ++
scripts/soak-vectorized.sh | 329 ++++
test/CLAUDE.md | 39 +
test/cases/init.go | 37 +-
test/cases/lifecycle/lifecycle.go | 910 +++++++++-
test/cases/measure/cmd/capture/capture_test.go | 27 +-
test/cases/measure/cmd/generate/capture.go | 9 +-
test/cases/measure/cmd/generate/types.go | 18 +-
.../cases/measure/data/input/empty_result.ql | 21 +-
.../cases/measure/data/input/empty_result.yaml | 34 +-
.../cases/measure/data/input/float_bottom.ql | 20 +-
.../cases/measure/data/input/float_bottom.yaml | 31 +-
.../cases/measure/data/input/float_top.ql | 20 +-
.../cases/measure/data/input/float_top.yaml | 31 +-
.../cases/measure/data/input/float_top_count.ql | 21 +-
.../cases/measure/data/input/float_top_count.yaml | 40 +-
.../cases/measure/data/input/float_top_mean.ql | 21 +-
.../cases/measure/data/input/float_top_mean.yaml | 40 +-
.../cases/measure/data/input/float_top_sum.ql | 21 +-
.../cases/measure/data/input/float_top_sum.yaml | 40 +-
.../data/input/project_non_existent_field.ql | 21 +-
.../data/input/project_non_existent_field.yaml | 27 +-
test/cases/measure/data/license_header.go | 43 +
.../service_instance_float_metric_data.json | 422 +++++
.../testdata/service_traffic_data_expired.json | 78 +
test/cases/measure/data/want/float_bottom.yaml | 90 +
test/cases/measure/data/want/float_top.yaml | 90 +
.../cases/measure/data/want/float_top_count.yaml | 56 +-
.../cases/measure/data/want/float_top_mean.yaml | 56 +-
.../cases/measure/data/want/float_top_sum.yaml | 56 +-
test/cases/measure/measure.go | 14 +
test/cases/schema/apply_rollback.go | 32 +-
test/cases/schema/barrier_cluster.go | 340 ++++
test/cases/schema/clamp.go | 60 +-
test/cases/schema/clients.go | 2 +-
test/cases/schema/query_gate.go | 24 +-
test/cases/schema/shape_break.go | 87 +-
test/cases/schema/tag_family_move.go | 1294 ++++++++++++++
test/cases/schema/tombstone_gc.go | 12 +-
test/cases/schema/write_gate.go | 14 +-
test/cases/stream/stream.go | 5 +
test/cases/topn/data/data.go | 39 +-
.../cases/topn/data/input/float_count_aggr_desc.ql | 24 +-
.../topn/data/input/float_count_aggr_desc.yaml | 24 +-
.../cases/topn/data/input/float_max_aggr_desc.ql | 24 +-
.../cases/topn/data/input/float_max_aggr_desc.yaml | 24 +-
.../cases/topn/data/input/float_mean_aggr_desc.ql | 24 +-
.../topn/data/input/float_mean_aggr_desc.yaml | 24 +-
.../cases/topn/data/input/float_min_aggr_asc.ql | 24 +-
.../cases/topn/data/input/float_min_aggr_asc.yaml | 24 +-
.../cases/topn/data/input/float_sum_aggr_desc.ql | 24 +-
.../cases/topn/data/input/float_sum_aggr_desc.yaml | 24 +-
.../topn/data/want/float_count_aggr_desc.yaml | 57 +-
.../cases/topn/data/want/float_max_aggr_desc.yaml | 57 +-
.../cases/topn/data/want/float_mean_aggr_desc.yaml | 57 +-
.../cases/topn/data/want/float_min_aggr_asc.yaml | 57 +-
.../cases/topn/data/want/float_sum_aggr_desc.yaml | 57 +-
test/cases/topn/topn.go | 5 +
test/cases/trace/cmd/capture/capture_test.go | 263 +++
test/cases/trace/cmd/generate/entry.go | 64 +
test/cases/trace/cmd/generate/gap.go | 149 ++
test/cases/trace/cmd/generate/layer1_leaf.go | 146 ++
test/cases/trace/cmd/generate/layer2_tree.go | 108 ++
test/cases/trace/cmd/generate/layer3_features.go | 194 +++
test/cases/trace/cmd/generate/main.go | 101 ++
test/cases/trace/cmd/generate/pairwise.go | 179 ++
test/cases/trace/cmd/generate/ql_renderer.go | 154 ++
test/cases/trace/cmd/generate/ql_renderer_test.go | 60 +
test/cases/trace/cmd/generate/seed.go | 231 +++
.../cases/{measure => trace}/cmd/generate/types.go | 95 +-
test/cases/trace/data/data.go | 40 +-
.../cases/trace/data/input/gen_err_match_sw.ql | 22 +-
.../cases/trace/data/input/gen_err_match_sw.yml | 32 +-
..._duration_asc_limit2_offset1_proj_explicit_1.ql | 24 +-
...duration_asc_limit2_offset1_proj_explicit_1.yml | 32 +-
...at_order_duration_asc_limit5_proj_explicit_6.ql | 23 +-
...t_order_duration_asc_limit5_proj_explicit_6.yml | 31 +-
...der_duration_desc_filter_service_eq_limit2_7.ql | 24 +-
...er_duration_desc_filter_service_eq_limit2_7.yml | 33 +-
...gen_feat_order_duration_desc_proj_explicit_3.ql | 22 +-
...en_feat_order_duration_desc_proj_explicit_3.yml | 30 +-
...lter_state_eq_limit5_offset1_proj_explicit_8.ql | 25 +-
...ter_state_eq_limit5_offset1_proj_explicit_8.yml | 39 +-
...imestamp_desc_filter_duration_range_limit2_9.ql | 24 +-
...mestamp_desc_filter_duration_range_limit2_9.yml | 43 +-
.../cases/trace/data/input/gen_feat_traceid_0.ql | 22 +-
.../cases/trace/data/input/gen_feat_traceid_0.yml | 29 +-
.../trace/data/input/gen_feat_traceid_limit2_5.ql | 23 +-
.../trace/data/input/gen_feat_traceid_limit2_5.yml | 30 +-
..._feat_traceid_limit5_offset3_proj_explicit_2.ql | 24 +-
...feat_traceid_limit5_offset3_proj_explicit_2.yml | 36 +-
.../data/input/gen_feat_traceid_proj_explicit_4.ql | 22 +-
.../input/gen_feat_traceid_proj_explicit_4.yml | 34 +-
.../cases/trace/data/input/gen_leaf_eq_duration.ql | 23 +-
.../trace/data/input/gen_leaf_eq_duration.yml | 37 +-
.../trace/data/input/gen_leaf_eq_service_id.ql | 23 +-
.../trace/data/input/gen_leaf_eq_service_id.yml | 37 +-
.../data/input/gen_leaf_eq_service_id_null.ql | 23 +-
.../data/input/gen_leaf_eq_service_id_null.yml | 36 +-
.../cases/trace/data/input/gen_leaf_eq_state.ql | 23 +-
.../cases/trace/data/input/gen_leaf_eq_state.yml | 37 +-
.../cases/trace/data/input/gen_leaf_eq_trace_id.ql | 22 +-
.../trace/data/input/gen_leaf_eq_trace_id.yml | 34 +-
.../cases/trace/data/input/gen_leaf_ge_duration.ql | 23 +-
.../trace/data/input/gen_leaf_ge_duration.yml | 37 +-
.../cases/trace/data/input/gen_leaf_ge_state.ql | 23 +-
.../cases/trace/data/input/gen_leaf_ge_state.yml | 36 +-
.../cases/trace/data/input/gen_leaf_gt_duration.ql | 23 +-
.../trace/data/input/gen_leaf_gt_duration.yml | 37 +-
.../cases/trace/data/input/gen_leaf_gt_state.ql | 23 +-
.../cases/trace/data/input/gen_leaf_gt_state.yml | 36 +-
.../trace/data/input/gen_leaf_in_service_id.ql | 23 +-
.../trace/data/input/gen_leaf_in_service_id.yml | 39 +-
.../cases/trace/data/input/gen_leaf_in_trace_id.ql | 22 +-
.../trace/data/input/gen_leaf_in_trace_id.yml | 36 +-
.../cases/trace/data/input/gen_leaf_le_duration.ql | 23 +-
.../trace/data/input/gen_leaf_le_duration.yml | 37 +-
.../cases/trace/data/input/gen_leaf_le_state.ql | 23 +-
.../cases/trace/data/input/gen_leaf_le_state.yml | 37 +-
.../cases/trace/data/input/gen_leaf_lt_duration.ql | 23 +-
.../trace/data/input/gen_leaf_lt_duration.yml | 37 +-
.../cases/trace/data/input/gen_leaf_lt_state.ql | 23 +-
.../cases/trace/data/input/gen_leaf_lt_state.yml | 37 +-
.../trace/data/input/gen_leaf_ne_service_id.ql | 23 +-
.../trace/data/input/gen_leaf_ne_service_id.yml | 37 +-
.../cases/trace/data/input/gen_leaf_ne_state.ql | 23 +-
.../cases/trace/data/input/gen_leaf_ne_state.yml | 36 +-
.../cases/trace/data/input/gen_leaf_ne_trace_id.ql | 23 +-
.../trace/data/input/gen_leaf_ne_trace_id.yml | 37 +-
.../trace/data/input/gen_leaf_not_in_service_id.ql | 23 +-
.../data/input/gen_leaf_not_in_service_id.yml | 38 +-
.../trace/data/input/gen_leaf_not_in_trace_id.ql | 23 +-
.../trace/data/input/gen_leaf_not_in_trace_id.yml | 38 +-
.../cases/trace/data/input/gen_tree_depth1_leaf.ql | 23 +-
.../trace/data/input/gen_tree_depth1_leaf.yml | 37 +-
.../cases/trace/data/input/gen_tree_depth2_and.ql | 23 +-
.../cases/trace/data/input/gen_tree_depth2_and.yml | 47 +-
.../cases/trace/data/input/gen_tree_depth2_or.ql | 23 +-
.../cases/trace/data/input/gen_tree_depth2_or.yml | 47 +-
.../trace/data/input/gen_tree_depth3_and_or.ql | 23 +-
.../trace/data/input/gen_tree_depth3_and_or.yml | 64 +
.../trace/data/input/gen_tree_depth3_or_and.ql | 23 +-
.../trace/data/input/gen_tree_depth3_or_and.yml | 64 +
.../trace/data/input/gen_tree_depth5_deep_and.ql | 23 +-
.../trace/data/input/gen_tree_depth5_deep_and.yml | 182 ++
.../trace/data/input/gen_tree_depth5_deep_or.ql | 23 +-
.../trace/data/input/gen_tree_depth5_deep_or.yml | 182 ++
test/cases/trace/data/license_header.go | 43 +
...duration_asc_limit2_offset1_proj_explicit_1.yml | 155 ++
...t_order_duration_asc_limit5_proj_explicit_6.yml | 389 +++++
...er_duration_desc_filter_service_eq_limit2_7.yml | 40 +-
...en_feat_order_duration_desc_proj_explicit_3.yml | 509 ++++++
...ter_state_eq_limit5_offset1_proj_explicit_8.yml | 313 ++++
...mestamp_desc_filter_duration_range_limit2_9.yml | 34 +-
.../cases/trace/data/want/gen_feat_traceid_0.yml | 32 +-
.../trace/data/want/gen_feat_traceid_limit2_5.yml | 32 +-
.../data/want/gen_feat_traceid_proj_explicit_4.yml | 115 ++
.../trace/data/want/gen_leaf_eq_service_id.yml | 115 ++
test/cases/trace/data/want/gen_leaf_eq_state.yml | 509 ++++++
.../cases/trace/data/want/gen_leaf_eq_trace_id.yml | 115 ++
.../cases/trace/data/want/gen_leaf_ge_duration.yml | 509 ++++++
test/cases/trace/data/want/gen_leaf_ge_state.yml | 509 ++++++
.../cases/trace/data/want/gen_leaf_gt_duration.yml | 509 ++++++
test/cases/trace/data/want/gen_leaf_gt_state.yml | 509 ++++++
.../trace/data/want/gen_leaf_in_service_id.yml | 193 +++
.../cases/trace/data/want/gen_leaf_in_trace_id.yml | 193 +++
.../cases/trace/data/want/gen_leaf_le_duration.yml | 509 ++++++
test/cases/trace/data/want/gen_leaf_le_state.yml | 509 ++++++
.../cases/trace/data/want/gen_leaf_lt_duration.yml | 509 ++++++
test/cases/trace/data/want/gen_leaf_lt_state.yml | 509 ++++++
.../trace/data/want/gen_leaf_ne_service_id.yml | 509 ++++++
test/cases/trace/data/want/gen_leaf_ne_state.yml | 509 ++++++
.../cases/trace/data/want/gen_leaf_ne_trace_id.yml | 509 ++++++
.../trace/data/want/gen_leaf_not_in_service_id.yml | 509 ++++++
.../trace/data/want/gen_leaf_not_in_trace_id.yml | 509 ++++++
.../cases/trace/data/want/gen_tree_depth1_leaf.yml | 115 ++
test/cases/trace/data/want/gen_tree_depth2_and.yml | 115 ++
test/cases/trace/data/want/gen_tree_depth2_or.yml | 115 ++
.../trace/data/want/gen_tree_depth3_or_and.yml | 155 ++
.../trace/data/want/gen_tree_depth5_deep_and.yml | 509 ++++++
test/cases/trace/trace.go | 48 +
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 | 1 +
.../profiling/trace/banyandb/docker-compose.yml | 2 +-
...eployment.yaml => banyandb-deployment-vec.yaml} | 1 +
.../istio/banyandb/banyandb-deployment.yaml | 1 +
.../rover/process/istio/banyandb/e2e-banyandb.yaml | 2 +-
.../cases/storage/banyandb/docker-compose.yml | 2 +-
.../cases/zipkin/banyandb/docker-compose.yml | 1 +
.../distributed/query/vectorized_test.go | 146 ++
.../integration/distributed/querybench/Dockerfile | 22 +-
test/integration/distributed/querybench/README.md | 75 +
.../distributed/querybench/benchmark_test.go | 314 ++++
test/integration/distributed/querybench/config.go | 233 +++
.../distributed/querybench/config_test.go | 161 ++
.../distributed/querybench/orchestrate.sh | 77 +
test/integration/distributed/querybench/profile.go | 172 ++
test/integration/distributed/querybench/report.go | 398 +++++
.../distributed/querybench/report_test.go | 120 ++
.../distributed/querybench/run-docker.sh | 95 +
.../integration/distributed/querybench/workload.go | 375 ++++
.../distributed/querybench/workload_test.go | 83 +
test/integration/distributed/schema/common.go | 22 +-
.../standalone/benchmark/benchmark_suite_test.go | 39 +-
.../standalone/benchmark/benchmark_test.go | 63 +
.../standalone/benchmark/workloads_test.go | 60 +
test/integration/standalone/other/property_test.go | 53 +-
.../standalone/query/vectorized_test.go | 161 ++
test/load/schema_barrier/barrier_loadtest_test.go | 393 +++++
test/property_repair/full_data/integrated_test.go | 7 +-
test/property_repair/half_data/integrated_test.go | 7 +-
test/property_repair/same_data/integrated_test.go | 7 +-
test/property_repair/shared_utils.go | 172 +-
test/soak/Dockerfile.banyand | 52 +
test/soak/docker-compose.soak.yaml | 235 +++
ui/LICENSE | 32 +-
ui/package-lock.json | 397 ++---
807 files changed, 103699 insertions(+), 10097 deletions(-)
create mode 100644 api/data/codec.go
create mode 100644 api/data/codec_test.go
create mode 100644 api/validate/validate_test.go
create mode 100644 banyand/backup/lifecycle/progress_mark_test.go
create mode 100644 banyand/backup/lifecycle/report_partial_failure_test.go
create mode 100644 banyand/backup/lifecycle/row_replay.go
create mode 100644 banyand/backup/lifecycle/row_replay_measure.go
create mode 100644 banyand/backup/lifecycle/row_replay_pipeline.go
create mode 100644 banyand/backup/lifecycle/row_replay_stream.go
create mode 100644 banyand/backup/lifecycle/row_replay_test.go
create mode 100644 banyand/backup/lifecycle/row_replay_trace.go
create mode 100644 banyand/backup/lifecycle/steps_test.go
create mode 100644 banyand/cmd/migration/MIGRATION.md
create mode 100644 banyand/cmd/migration/README.md
create mode 100644 banyand/cmd/migration/analyze.go
create mode 100644 banyand/cmd/migration/copy.go
create mode 100644 banyand/cmd/migration/example/plan-backup.yaml
create mode 100644 banyand/cmd/migration/example/plan-live.yaml
create mode 100644 banyand/cmd/migration/example/runner-pod.yaml
create mode 100644 banyand/cmd/migration/main.go
create mode 100644 banyand/cmd/migration/plan.go
create mode 100644 banyand/cmd/migration/plan_test.go
create mode 100755 banyand/cmd/migration/scripts/verify-data.sh
create mode 100644 banyand/cmd/migration/verify.go
create mode 100644 banyand/dquery/measure_test.go
create mode 100644 banyand/internal/dump/decode.go
create mode 100644 banyand/internal/dump/dump_test.go
create mode 100644 banyand/internal/dump/helpers.go
create mode 100644 banyand/internal/dump/index_resolver.go
create mode 100644 banyand/internal/dump/iterator.go
create mode 100644 banyand/internal/dump/measure/iterator.go
create mode 100644 banyand/internal/dump/measure/measure.go
create mode 100644 banyand/internal/dump/measure/measure_test.go
create mode 100644 banyand/internal/dump/measure/suite_test.go
create mode 100644 banyand/internal/dump/stream/iterator.go
create mode 100644 banyand/internal/dump/stream/stream.go
create mode 100644 banyand/internal/dump/stream/stream_test.go
create mode 100644 banyand/internal/dump/stream/suite_test.go
create mode 100644 banyand/internal/dump/trace/iterator.go
create mode 100644 banyand/internal/dump/trace/suite_test.go
create mode 100644 banyand/internal/dump/trace/trace.go
create mode 100644 banyand/internal/dump/trace/trace_test.go
create mode 100644 banyand/internal/sidx/merger_durability_test.go
create mode 100644 banyand/internal/storage/inspect_stats.go
create mode 100644 banyand/internal/storage/inspect_stats_test.go
create mode 100644 banyand/internal/storage/segment_idle_reclaim_test.go
create mode 100644
banyand/internal/storage/segment_lifecycle_integration_test.go
create mode 100644 banyand/internal/storage/snapshot_closed_segment_test.go
create mode 100644 banyand/liaison/grpc/barrier_cluster.go
create mode 100644 banyand/liaison/grpc/barrier_cluster_test.go
create mode 100644 banyand/liaison/grpc/barrier_metrics.go
create mode 100644 banyand/liaison/grpc/barrier_metrics_test.go
create mode 100644 banyand/liaison/grpc/schema_revision_registry.go
create mode 100644 banyand/liaison/grpc/schema_revision_registry_test.go
create mode 100644 banyand/measure/batch_decode.go
create mode 100644 banyand/measure/block_batch.go
create mode 100644 banyand/measure/block_batch_benchmark_test.go
create mode 100644 banyand/measure/merger_durability_test.go
create mode 100644 banyand/measure/metadata_internal_test.go
create mode 100644 banyand/measure/migration_analyze.go
create mode 100644 banyand/measure/migration_copy.go
create mode 100644 banyand/measure/migration_copy_test.go
create mode 100644 banyand/measure/migration_e2e_test.go
create mode 100644 banyand/measure/migration_schema.go
create mode 100644 banyand/measure/migration_schema_test.go
create mode 100644 banyand/measure/migration_verify.go
create mode 100644 banyand/measure/migration_verify_test.go
create mode 100644 banyand/measure/query_batch.go
create mode 100644 banyand/metadata/schema/collector_test.go
create mode 100644 banyand/metadata/schema/property/init_handler_test.go
create mode 100644 banyand/metadata/schema/property/node_status.go
create mode 100644
banyand/metadata/schema/property/node_status_registry_test.go
create mode 100644 banyand/metadata/schema/property/node_status_test.go
create mode 100644 banyand/metadata/schema/property/watch_control.go
create mode 100644 banyand/metadata/schema/property/watch_control_test.go
create mode 100644 banyand/query/tracing_test.go
create mode 100644 banyand/queue/pub/metrics_test.go
create mode 100644 banyand/queue/sub/group_lifecycle_cold_tier_test.go
create mode 100644 banyand/queue/sub/server_metrics_test.go
create mode 100644 banyand/stream/merger_durability_test.go
create mode 100644 banyand/stream/metadata_internal_test.go
create mode 100644 banyand/trace/merger_durability_test.go
create mode 100644 banyand/trace/metadata_internal_test.go
create mode 100644 banyand/trace/storage_scope_test.go
copy bydbctl/internal/cmd/{use.go => use_test.go} (51%)
create mode 100644 cmd/soak-driver/catalog/default.json
create mode 100644 cmd/soak-driver/main.go
delete mode 100644 dist/licenses/license-github.com-zenizh-go-capturer.txt
create mode 100644 docs/design/fodc/context-aware-panic-diagnostics.md
create mode 100644 docs/observability/vec-query-tracing.md
create mode 100644
docs/operation/troubleshooting/measure-vec-flag-off-rollback.md
create mode 100644 docs/soak/g5d-phase-d-summary.md
create mode 100644 docs/soak/g5d-runbook.md
create mode 100644 docs/soak/g9f-runbook.md
create mode 100644 fodc/agent/internal/crashcollector/combined.go
create mode 100644 fodc/agent/internal/crashcollector/fswatcher.go
create mode 100644 fodc/agent/internal/crashcollector/fswatcher_test.go
create mode 100644 fodc/agent/internal/crashcollector/inprocess.go
create mode 100644 fodc/agent/internal/crashcollector/inprocess_test.go
create mode 100644 fodc/agent/internal/integration/diagnostic_extended_test.go
create mode 100644 fodc/agent/internal/proxy/client_blocking_send_test.go
create mode 100644 fodc/agent/internal/proxy/wait.go
create mode 100644 fodc/agent/internal/proxy/wait_test.go
copy bydbctl/internal/cmd/use.go => fodc/internal/timeouts/timeouts.go (50%)
create mode 100644 fodc/proxy/internal/diagnostics/aggregator.go
create mode 100644 fodc/proxy/internal/diagnostics/aggregator_test.go
create mode 100644 fodc/proxy/internal/integration/diagnostic_test.go
create mode 100644 pkg/cmdsetup/supervisor.go
create mode 100644 pkg/cmdsetup/supervisor_test.go
create mode 100644 pkg/flow/streaming/topn_heap.go
create mode 100644 pkg/flow/streaming/topn_heap_test.go
copy pkg/{partition/route.go => fs/local_file_system_testhook_test.go} (64%)
create mode 100644 pkg/fs/remote/local/local_test.go
create mode 100644 pkg/initerror/initerror.go
create mode 100644 pkg/initerror/initerror_test.go
create mode 100644 pkg/panicdiag/artifact.go
create mode 100644 pkg/panicdiag/artifact_test.go
create mode 100644 pkg/panicdiag/breadcrumb.go
create mode 100644 pkg/panicdiag/breadcrumb_test.go
create mode 100644 pkg/panicdiag/collections.go
create mode 100644 pkg/panicdiag/collections_test.go
create mode 100644 pkg/panicdiag/crashoutput.go
create mode 100644 pkg/panicdiag/crashoutput_test.go
create mode 100644 pkg/panicdiag/grpcinterceptors.go
create mode 100644 pkg/panicdiag/lintrawgo/analyzer.go
create mode 100644 pkg/panicdiag/lintrawgo/analyzer_test.go
create mode 100644 pkg/panicdiag/lintrawgo/baseline.txt
copy pkg/{partition/route.go =>
panicdiag/lintrawgo/testdata/src/badcode/bad.go} (70%)
copy pkg/{partition/route.go =>
panicdiag/lintrawgo/testdata/src/baselined/baselined.go} (70%)
create mode 100644 pkg/panicdiag/memlimit.go
create mode 100644 pkg/panicdiag/memlimit_test.go
create mode 100644 pkg/panicdiag/metrics.go
create mode 100644 pkg/panicdiag/recovery.go
create mode 100644 pkg/panicdiag/recovery_test.go
create mode 100644 pkg/panicdiag/sink.go
create mode 100644 pkg/panicdiag/sink_test.go
create mode 100644 pkg/panicdiag/state.go
create mode 100644 pkg/panicdiag/state_test.go
create mode 100644 pkg/panicdiag/types.go
create mode 100644 pkg/partition/route_test.go
create mode 100644 pkg/query/logical/measure/cross_group_merge.go
create mode 100644 pkg/query/logical/measure/schema_test.go
create mode 100644 pkg/query/logical/trace/trace_plan_distributed_test.go
create mode 100644 pkg/query/model/batch.go
create mode 100644 pkg/query/model/batch_test.go
create mode 100644 pkg/query/tracelabels/labels.go
create mode 100644 pkg/query/tracelabels/labels_doc.go
create mode 100644 pkg/query/tracelabels/labels_doc_test.go
create mode 100644 pkg/query/tracelabels/static_usage_test.go
create mode 100644 pkg/query/vectorized/batch.go
create mode 100644 pkg/query/vectorized/batch_test.go
create mode 100644 pkg/query/vectorized/column.go
create mode 100644 pkg/query/vectorized/column_pool.go
create mode 100644 pkg/query/vectorized/column_test.go
copy pkg/{partition/route.go => query/vectorized/doc.go} (70%)
create mode 100644 pkg/query/vectorized/fused.go
create mode 100644 pkg/query/vectorized/fused_test.go
create mode 100644 pkg/query/vectorized/measure/AGENTS.md
create mode 100644 pkg/query/vectorized/measure/adapter.go
create mode 100644 pkg/query/vectorized/measure/adapter_test.go
create mode 100644 pkg/query/vectorized/measure/agg_value_path_test.go
create mode 100644 pkg/query/vectorized/measure/aggregation.go
create mode 100644 pkg/query/vectorized/measure/aggregation_reduce.go
create mode 100644 pkg/query/vectorized/measure/aggregation_test.go
create mode 100644 pkg/query/vectorized/measure/batchsource.go
create mode 100644 pkg/query/vectorized/measure/batchsource_test.go
create mode 100644 pkg/query/vectorized/measure/bench_gates_test.go
create mode 100644 pkg/query/vectorized/measure/bench_test.go
create mode 100644 pkg/query/vectorized/measure/bench_tracing_test.go
create mode 100644 pkg/query/vectorized/measure/build_batch.go
create mode 100644 pkg/query/vectorized/measure/build_batch_test.go
create mode 100644 pkg/query/vectorized/measure/config.go
create mode 100644 pkg/query/vectorized/measure/config_test.go
create mode 100644 pkg/query/vectorized/measure/cursor.go
create mode 100644 pkg/query/vectorized/measure/cursor_test.go
create mode 100644 pkg/query/vectorized/measure/diff_test.go
copy pkg/{partition/route.go => query/vectorized/measure/doc.go} (70%)
create mode 100644 pkg/query/vectorized/measure/extract.go
create mode 100644 pkg/query/vectorized/measure/extract_test.go
create mode 100644 pkg/query/vectorized/measure/fixtures_test.go
create mode 100644 pkg/query/vectorized/measure/frame/decode.go
create mode 100644 pkg/query/vectorized/measure/frame/decode_test.go
create mode 100644 pkg/query/vectorized/measure/frame/encode.go
create mode 100644 pkg/query/vectorized/measure/frame/frame.go
create mode 100644 pkg/query/vectorized/measure/frame/frame_test.go
create mode 100644 pkg/query/vectorized/measure/frame/validate.go
create mode 100644 pkg/query/vectorized/measure/groupby.go
create mode 100644 pkg/query/vectorized/measure/groupby_test.go
create mode 100644 pkg/query/vectorized/measure/integration.go
create mode 100644 pkg/query/vectorized/measure/limit.go
create mode 100644 pkg/query/vectorized/measure/limit_test.go
create mode 100644 pkg/query/vectorized/measure/plan.go
create mode 100644 pkg/query/vectorized/measure/plan/analyzer.go
create mode 100644 pkg/query/vectorized/measure/plan/analyzer_test.go
create mode 100644 pkg/query/vectorized/measure/plan/build_test.go
create mode 100644 pkg/query/vectorized/measure/plan/dispatch.go
create mode 100644 pkg/query/vectorized/measure/plan/dispatch_test.go
create mode 100644 pkg/query/vectorized/measure/plan/distributed.go
create mode 100644 pkg/query/vectorized/measure/plan/distributed_rows.go
create mode 100644 pkg/query/vectorized/measure/plan/distributed_rows_test.go
create mode 100644 pkg/query/vectorized/measure/plan/distributed_test.go
create mode 100644 pkg/query/vectorized/measure/plan/executor.go
create mode 100644 pkg/query/vectorized/measure/plan/executor_test.go
create mode 100644 pkg/query/vectorized/measure/plan/groupby_agg.go
create mode 100644 pkg/query/vectorized/measure/plan/hidden_tags.go
create mode 100644 pkg/query/vectorized/measure/plan/limit.go
create mode 100644 pkg/query/vectorized/measure/plan/multi_group_schema.go
create mode 100644 pkg/query/vectorized/measure/plan/multi_group_schema_test.go
create mode 100644 pkg/query/vectorized/measure/plan/orderby.go
create mode 100644 pkg/query/vectorized/measure/plan/plan.go
create mode 100644 pkg/query/vectorized/measure/plan/scan.go
create mode 100644 pkg/query/vectorized/measure/plan/sort_key.go
create mode 100644 pkg/query/vectorized/measure/plan/sort_key_test.go
create mode 100644 pkg/query/vectorized/measure/plan/top.go
create mode 100644 pkg/query/vectorized/measure/plan/tracing_bottleneck_test.go
create mode 100644 pkg/query/vectorized/measure/plan/tracing_collect_test.go
create mode 100644
pkg/query/vectorized/measure/plan/tracing_rolling_upgrade_test.go
create mode 100644 pkg/query/vectorized/measure/plan/tracing_summary.go
create mode 100644 pkg/query/vectorized/measure/plan/tracing_summary_test.go
create mode 100644 pkg/query/vectorized/measure/plan_test.go
create mode 100644 pkg/query/vectorized/measure/raw_emit.go
create mode 100644 pkg/query/vectorized/measure/raw_emit_bench_test.go
create mode 100644 pkg/query/vectorized/measure/raw_emit_test.go
create mode 100644 pkg/query/vectorized/measure/reduce.go
create mode 100644 pkg/query/vectorized/measure/scan.go
create mode 100644 pkg/query/vectorized/measure/scan_test.go
create mode 100644 pkg/query/vectorized/measure/serialize.go
create mode 100644 pkg/query/vectorized/measure/serialize_test.go
create mode 100644 pkg/query/vectorized/measure/shared_tracker_test.go
create mode 100644 pkg/query/vectorized/measure/top.go
create mode 100644 pkg/query/vectorized/measure/top_test.go
create mode 100644 pkg/query/vectorized/measure/topology_matrix_test.go
create mode 100644 pkg/query/vectorized/measure/tracing_operator_test.go
create mode 100644 pkg/query/vectorized/memory.go
create mode 100644 pkg/query/vectorized/memory_test.go
create mode 100644 pkg/query/vectorized/operator.go
copy pkg/{partition/route.go => query/vectorized/operator_test.go} (65%)
create mode 100644 pkg/query/vectorized/pipeline.go
create mode 100644 pkg/query/vectorized/pipeline_test.go
create mode 100644 pkg/query/vectorized/pool.go
create mode 100644 pkg/query/vectorized/pool_test.go
create mode 100644 pkg/query/vectorized/schema.go
create mode 100644 pkg/query/vectorized/schema_test.go
create mode 100644 pkg/query/vectorized/typed_column.go
create mode 100644 pkg/query/vectorized/typed_column_test.go
create mode 100644 pkg/run/goroutine.go
create mode 100644 pkg/run/goroutine_test.go
create mode 100644 pkg/run/run_test.go
create mode 100644 pkg/schema/cache_watcher_fatal_test.go
create mode 100644 pkg/schema/registry/registry.go
create mode 100644 pkg/schema/registry/registry_test.go
create mode 100644 pkg/test/measure/testdata/group_stages/sw_cross_segment.json
create mode 100644 pkg/test/measure/testdata/groups/sw_cross_segment.json
create mode 100644 pkg/test/measure/testdata/measures/cross_segment_metric.json
copy pkg/test/measure/testdata/measures/{service_instance_cpm_minute.json =>
service_instance_float_metric.json} (91%)
create mode 100644
pkg/test/measure/testdata/topn_aggregations/service_instance_float_metric_top_bottom_3.json
create mode 100644 pkg/test/stream/testdata/streams/cross_segment_log.json
create mode 100644 pkg/test/trace/testdata/groups/sw_cross_segment_trace.json
create mode 100644
pkg/test/trace/testdata/groups_stages/sw_cross_segment_trace.json
create mode 100644
pkg/test/trace/testdata/index_rule_bindings/cross_segment_trace.json
create mode 100644
pkg/test/trace/testdata/index_rules/cross_segment_timestamp.json
create mode 100644 pkg/test/trace/testdata/traces/cross_segment_trace.json
create mode 100644 pkg/timestamp/scheduler_test.go
create mode 100755 scripts/bench-vectorized.sh
copy banyand/Makefile => scripts/lint/no-span-without-stop.yml (61%)
copy banyand/Makefile => scripts/lint/no-string-trace-tags.yml (61%)
create mode 100644 scripts/lint/rawgo-baseline/main.go
create mode 100644 scripts/lint/rawgo/main.go
copy banyand/Makefile => scripts/lint/stop-before-toproto.yml (61%)
create mode 100755 scripts/soak-monitor.sh
create mode 100755 scripts/soak-vectorized.sh
create mode 100644 test/CLAUDE.md
copy banyand/Makefile => test/cases/measure/data/input/empty_result.ql (61%)
copy banyand/Makefile => test/cases/measure/data/input/empty_result.yaml (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_bottom.ql (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_bottom.yaml (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top.ql (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top.yaml (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top_count.ql (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top_count.yaml
(61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top_mean.ql (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top_mean.yaml
(61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top_sum.ql (61%)
copy banyand/Makefile => test/cases/measure/data/input/float_top_sum.yaml (61%)
copy banyand/Makefile =>
test/cases/measure/data/input/project_non_existent_field.ql (61%)
copy banyand/Makefile =>
test/cases/measure/data/input/project_non_existent_field.yaml (61%)
create mode 100644 test/cases/measure/data/license_header.go
create mode 100644
test/cases/measure/data/testdata/service_instance_float_metric_data.json
create mode 100644
test/cases/measure/data/testdata/service_traffic_data_expired.json
create mode 100644 test/cases/measure/data/want/float_bottom.yaml
create mode 100644 test/cases/measure/data/want/float_top.yaml
copy banyand/Makefile => test/cases/measure/data/want/float_top_count.yaml
(58%)
copy banyand/Makefile => test/cases/measure/data/want/float_top_mean.yaml (57%)
copy banyand/Makefile => test/cases/measure/data/want/float_top_sum.yaml (57%)
create mode 100644 test/cases/schema/barrier_cluster.go
create mode 100644 test/cases/schema/tag_family_move.go
copy banyand/Makefile => test/cases/topn/data/input/float_count_aggr_desc.ql
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_count_aggr_desc.yaml
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_max_aggr_desc.ql
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_max_aggr_desc.yaml
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_mean_aggr_desc.ql
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_mean_aggr_desc.yaml
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_min_aggr_asc.ql (61%)
copy banyand/Makefile => test/cases/topn/data/input/float_min_aggr_asc.yaml
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_sum_aggr_desc.ql
(61%)
copy banyand/Makefile => test/cases/topn/data/input/float_sum_aggr_desc.yaml
(61%)
copy banyand/Makefile => test/cases/topn/data/want/float_count_aggr_desc.yaml
(57%)
copy banyand/Makefile => test/cases/topn/data/want/float_max_aggr_desc.yaml
(56%)
copy banyand/Makefile => test/cases/topn/data/want/float_mean_aggr_desc.yaml
(56%)
copy banyand/Makefile => test/cases/topn/data/want/float_min_aggr_asc.yaml
(56%)
copy banyand/Makefile => test/cases/topn/data/want/float_sum_aggr_desc.yaml
(56%)
create mode 100644 test/cases/trace/cmd/capture/capture_test.go
create mode 100644 test/cases/trace/cmd/generate/entry.go
create mode 100644 test/cases/trace/cmd/generate/gap.go
create mode 100644 test/cases/trace/cmd/generate/layer1_leaf.go
create mode 100644 test/cases/trace/cmd/generate/layer2_tree.go
create mode 100644 test/cases/trace/cmd/generate/layer3_features.go
create mode 100644 test/cases/trace/cmd/generate/main.go
create mode 100644 test/cases/trace/cmd/generate/pairwise.go
create mode 100644 test/cases/trace/cmd/generate/ql_renderer.go
create mode 100644 test/cases/trace/cmd/generate/ql_renderer_test.go
create mode 100644 test/cases/trace/cmd/generate/seed.go
copy test/cases/{measure => trace}/cmd/generate/types.go (51%)
copy banyand/Makefile => test/cases/trace/data/input/gen_err_match_sw.ql (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_err_match_sw.yml (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_asc_limit2_offset1_proj_explicit_1.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_asc_limit2_offset1_proj_explicit_1.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_asc_limit5_proj_explicit_6.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_asc_limit5_proj_explicit_6.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_desc_filter_service_eq_limit2_7.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_desc_filter_service_eq_limit2_7.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_desc_proj_explicit_3.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_duration_desc_proj_explicit_3.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_timestamp_asc_filter_state_eq_limit5_offset1_proj_explicit_8.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_timestamp_asc_filter_state_eq_limit5_offset1_proj_explicit_8.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_timestamp_desc_filter_duration_range_limit2_9.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_order_timestamp_desc_filter_duration_range_limit2_9.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_feat_traceid_0.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_feat_traceid_0.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_traceid_limit2_5.ql (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_traceid_limit2_5.yml (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_traceid_limit5_offset3_proj_explicit_2.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_traceid_limit5_offset3_proj_explicit_2.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_traceid_proj_explicit_4.ql (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_feat_traceid_proj_explicit_4.yml (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_eq_duration.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_eq_duration.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_eq_service_id.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_eq_service_id.yml (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_eq_service_id_null.ql (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_eq_service_id_null.yml (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_eq_state.ql (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_eq_state.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_eq_trace_id.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_eq_trace_id.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ge_duration.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ge_duration.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ge_state.ql (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ge_state.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_gt_duration.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_gt_duration.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_gt_state.ql (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_gt_state.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_in_service_id.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_in_service_id.yml (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_in_trace_id.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_in_trace_id.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_le_duration.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_le_duration.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_le_state.ql (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_le_state.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_lt_duration.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_lt_duration.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_lt_state.ql (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_lt_state.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ne_service_id.ql
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_ne_service_id.yml (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ne_state.ql (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ne_state.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ne_trace_id.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_leaf_ne_trace_id.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_not_in_service_id.ql (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_not_in_service_id.yml (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_not_in_trace_id.ql (61%)
copy banyand/Makefile =>
test/cases/trace/data/input/gen_leaf_not_in_trace_id.yml (61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth1_leaf.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth1_leaf.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth2_and.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth2_and.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth2_or.ql
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth2_or.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth3_and_or.ql
(61%)
create mode 100644 test/cases/trace/data/input/gen_tree_depth3_and_or.yml
copy banyand/Makefile => test/cases/trace/data/input/gen_tree_depth3_or_and.ql
(61%)
create mode 100644 test/cases/trace/data/input/gen_tree_depth3_or_and.yml
copy banyand/Makefile =>
test/cases/trace/data/input/gen_tree_depth5_deep_and.ql (54%)
create mode 100644 test/cases/trace/data/input/gen_tree_depth5_deep_and.yml
copy banyand/Makefile =>
test/cases/trace/data/input/gen_tree_depth5_deep_or.ql (54%)
create mode 100644 test/cases/trace/data/input/gen_tree_depth5_deep_or.yml
create mode 100644 test/cases/trace/data/license_header.go
create mode 100644
test/cases/trace/data/want/gen_feat_order_duration_asc_limit2_offset1_proj_explicit_1.yml
create mode 100644
test/cases/trace/data/want/gen_feat_order_duration_asc_limit5_proj_explicit_6.yml
copy banyand/Makefile =>
test/cases/trace/data/want/gen_feat_order_duration_desc_filter_service_eq_limit2_7.yml
(61%)
create mode 100644
test/cases/trace/data/want/gen_feat_order_duration_desc_proj_explicit_3.yml
create mode 100644
test/cases/trace/data/want/gen_feat_order_timestamp_asc_filter_state_eq_limit5_offset1_proj_explicit_8.yml
copy banyand/Makefile =>
test/cases/trace/data/want/gen_feat_order_timestamp_desc_filter_duration_range_limit2_9.yml
(61%)
copy banyand/Makefile => test/cases/trace/data/want/gen_feat_traceid_0.yml
(61%)
copy banyand/Makefile =>
test/cases/trace/data/want/gen_feat_traceid_limit2_5.yml (61%)
create mode 100644
test/cases/trace/data/want/gen_feat_traceid_proj_explicit_4.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_eq_service_id.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_eq_state.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_eq_trace_id.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_ge_duration.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_ge_state.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_gt_duration.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_gt_state.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_in_service_id.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_in_trace_id.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_le_duration.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_le_state.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_lt_duration.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_lt_state.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_ne_service_id.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_ne_state.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_ne_trace_id.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_not_in_service_id.yml
create mode 100644 test/cases/trace/data/want/gen_leaf_not_in_trace_id.yml
create mode 100644 test/cases/trace/data/want/gen_tree_depth1_leaf.yml
create mode 100644 test/cases/trace/data/want/gen_tree_depth2_and.yml
create mode 100644 test/cases/trace/data/want/gen_tree_depth2_or.yml
create mode 100644 test/cases/trace/data/want/gen_tree_depth3_or_and.yml
create mode 100644 test/cases/trace/data/want/gen_tree_depth5_deep_and.yml
copy test/e2e-v2/cases/rover/process/istio/banyandb/{banyandb-deployment.yaml
=> banyandb-deployment-vec.yaml} (97%)
create mode 100644 test/integration/distributed/query/vectorized_test.go
copy banyand/Makefile => test/integration/distributed/querybench/Dockerfile
(61%)
create mode 100644 test/integration/distributed/querybench/README.md
create mode 100644 test/integration/distributed/querybench/benchmark_test.go
create mode 100644 test/integration/distributed/querybench/config.go
create mode 100644 test/integration/distributed/querybench/config_test.go
create mode 100755 test/integration/distributed/querybench/orchestrate.sh
create mode 100644 test/integration/distributed/querybench/profile.go
create mode 100644 test/integration/distributed/querybench/report.go
create mode 100644 test/integration/distributed/querybench/report_test.go
create mode 100755 test/integration/distributed/querybench/run-docker.sh
create mode 100644 test/integration/distributed/querybench/workload.go
create mode 100644 test/integration/distributed/querybench/workload_test.go
copy bydbctl/internal/cmd/use.go =>
test/integration/standalone/benchmark/benchmark_suite_test.go (50%)
create mode 100644 test/integration/standalone/benchmark/benchmark_test.go
create mode 100644 test/integration/standalone/benchmark/workloads_test.go
create mode 100644 test/integration/standalone/query/vectorized_test.go
create mode 100644 test/load/schema_barrier/barrier_loadtest_test.go
create mode 100644 test/soak/Dockerfile.banyand
create mode 100644 test/soak/docker-compose.soak.yaml
