This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch vectorized-query
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from 475abf206 docs(changelog): note GroupBy+Agg coverage in vectorized
measure entry
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 d61e73dc2 Merge remote-tracking branch 'origin/main' into
vectorized-query
No new revisions were added by this update.
Summary of changes:
.gitignore | 2 -
.licenserc.yaml | 1 +
CHANGES.md | 32 +-
Makefile | 48 +-
api/proto/banyandb/fodc/v1/rpc.proto | 45 +
api/proto/banyandb/schema/v1/barrier.proto | 10 +-
api/validate/validate.go | 32 +
api/validate/validate_test.go | 163 ++++
banyand/backup/backup.go | 16 +-
banyand/backup/backup_test.go | 2 +-
banyand/backup/lifecycle/lifecycle.go | 6 +
banyand/backup/lifecycle/segment_boundary_utils.go | 43 +-
.../lifecycle/segment_boundary_utils_test.go | 229 ++++-
banyand/backup/lifecycle/service.go | 33 +-
banyand/backup/lifecycle/steps.go | 78 +-
banyand/backup/lifecycle/steps_test.go | 93 ++
banyand/backup/snapshot/snapshot.go | 3 +-
banyand/dquery/topn.go | 136 ++-
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/rotation.go | 18 +-
banyand/internal/storage/rotation_test.go | 48 +-
banyand/internal/storage/segment.go | 92 +-
banyand/internal/storage/segment_test.go | 777 ++++++++++++++-
banyand/internal/storage/storage.go | 39 +
banyand/internal/storage/tsdb.go | 25 +-
banyand/internal/storage/tsdb_test.go | 114 ++-
banyand/internal/storage/version.go | 5 +-
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/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 | 23 +-
banyand/liaison/http/server.go | 6 +-
banyand/measure/block.go | 134 +--
banyand/measure/block_metadata_test.go | 9 +-
banyand/measure/merger.go | 22 +-
banyand/measure/merger_durability_test.go | 82 ++
banyand/measure/merger_test.go | 70 +-
banyand/measure/metadata.go | 56 +-
banyand/measure/metadata_internal_test.go | 48 +
banyand/measure/part.go | 13 +-
banyand/measure/part_metadata.go | 2 +-
banyand/measure/query.go | 58 +-
banyand/measure/svc_data.go | 3 +-
banyand/measure/svc_standalone.go | 2 +-
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 | 62 +-
banyand/measure/write_data.go | 3 +-
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/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_topn.go | 85 +-
banyand/queue/local.go | 11 +
banyand/queue/pub/batch.go | 179 +++-
banyand/queue/pub/client.go | 34 +-
banyand/queue/pub/client_test.go | 2 +-
banyand/queue/pub/metrics_test.go | 499 ++++++++++
banyand/queue/pub/pub.go | 71 +-
banyand/queue/pub/retry_test.go | 18 +-
banyand/queue/queue.go | 20 +
banyand/queue/sub/chunked_sync.go | 169 +++-
banyand/queue/sub/chunked_sync_test.go | 13 +-
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 | 80 +-
banyand/queue/sub/server_metrics_test.go | 221 +++++
banyand/stream/merger.go | 3 +-
banyand/stream/merger_durability_test.go | 80 ++
banyand/stream/metadata.go | 20 +
banyand/stream/metadata_internal_test.go | 48 +
banyand/stream/part.go | 13 +-
banyand/stream/part_metadata.go | 2 +-
banyand/stream/query.go | 13 +
banyand/stream/query_by_idx.go | 21 +-
banyand/stream/query_by_ts.go | 8 +-
banyand/stream/tstable.go | 60 +-
banyand/stream/write_data.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 | 19 +
banyand/trace/metadata_internal_test.go | 48 +
banyand/trace/part.go | 13 +-
banyand/trace/part_metadata.go | 6 +-
banyand/trace/query.go | 12 +-
banyand/trace/streaming_pipeline.go | 33 +-
banyand/trace/tstable.go | 62 +-
banyand/trace/write_data.go | 7 +-
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 | 122 ++-
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 | 122 ++-
bydbctl/internal/cmd/topn.go | 34 +-
bydbctl/internal/cmd/topn_test.go | 148 +--
bydbctl/internal/cmd/trace.go | 42 +-
bydbctl/internal/cmd/trace_test.go | 122 ++-
bydbctl/internal/cmd/use.go | 4 +-
.../internal/cmd/use_test.go | 53 +-
dist/LICENSE | 13 +-
.../license-github.com-zenizh-go-capturer.txt | 21 -
dist/licenses/mcp-licenses/license-fast-uri.txt | 4 +-
docs/api-reference.md | 123 ++-
.../design/fodc/context-aware-panic-diagnostics.md | 432 +++++++++
docs/interacting/schema-consistency/scenarios.md | 4 +-
docs/operation/fodc/apis.md | 61 +-
docs/operation/grafana-cluster.json | 445 ++++++++-
docs/operation/observability.md | 60 +-
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 +++
.../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/proxy/client.go | 271 +++++-
.../internal/proxy/client_blocking_send_test.go | 4 +-
fodc/agent/internal/proxy/client_test.go | 97 +-
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 | 57 ++
fodc/proxy/cmd/proxy/main.go | 7 +-
fodc/proxy/internal/api/server.go | 58 +-
fodc/proxy/internal/api/server_test.go | 18 +-
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 | 37 +-
fodc/proxy/internal/lifecycle/manager_test.go | 61 ++
go.mod | 5 +-
go.sum | 2 -
mcp/LICENSE | 12 +-
mcp/package-lock.json | 219 ++---
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/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 | 99 +-
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} | 19 +-
pkg/fs/local_file_system_windows.go | 6 +
pkg/grpchelper/connmanager.go | 17 +-
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} | 24 +-
.../lintrawgo/testdata/src/baselined/baselined.go | 12 +-
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/query/logical/measure/measure_plan_top.go | 74 +-
pkg/query/logical/measure/measure_top.go | 67 +-
pkg/query/logical/measure/measure_top_test.go | 56 +-
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/model/model.go | 2 +
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 +-
.../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 +-
...ervice_instance_float_metric_top_bottom_3.json} | 9 +-
pkg/test/setup/setup.go | 45 +
pkg/test/setup/watch_control.go | 91 +-
pkg/timestamp/scheduler.go | 86 +-
pkg/timestamp/scheduler_test.go | 139 +++
pkg/tls/reloader.go | 8 +-
pkg/tls/reloader_test.go | 17 +-
scripts/lint/rawgo-baseline/main.go | 197 ++++
scripts/lint/rawgo/main.go | 113 +++
test/cases/init.go | 1 +
.../cases/measure/data/input/float_bottom.ql | 13 +-
.../data/input/{all.yaml => float_bottom.yaml} | 8 +-
.../cases/measure/data/input/float_top.ql | 13 +-
.../data/input/{all.yaml => float_top.yaml} | 8 +-
.../input/{all_max_limit.ql => float_top_count.ql} | 4 +-
.../{top_entity.yaml => float_top_count.yaml} | 6 +-
.../input/{all_max_limit.ql => float_top_mean.ql} | 4 +-
.../input/{top_entity.yaml => float_top_mean.yaml} | 4 +-
.../input/{all_max_limit.ql => float_top_sum.ql} | 4 +-
.../input/{top_entity.yaml => float_top_sum.yaml} | 6 +-
.../service_instance_float_metric_data.json | 422 ++++++++
.../want/{tag_filter_ne.yaml => float_bottom.yaml} | 42 +-
.../want/{tag_filter_ne.yaml => float_top.yaml} | 42 +-
.../{group_count.yaml => float_top_count.yaml} | 25 +-
.../want/{group_count.yaml => float_top_mean.yaml} | 25 +-
.../want/{group_count.yaml => float_top_sum.yaml} | 25 +-
test/cases/measure/measure.go | 5 +
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/tombstone_gc.go | 12 +-
test/cases/schema/write_gate.go | 14 +-
test/cases/topn/data/data.go | 39 +-
.../{topn_count.ql => float_count_aggr_desc.ql} | 2 +-
...{topn_count.yaml => float_count_aggr_desc.yaml} | 2 +-
.../input/{aggr_desc.ql => float_max_aggr_desc.ql} | 2 +-
.../{aggr_desc.yaml => float_max_aggr_desc.yaml} | 2 +-
.../{topn_mean.ql => float_mean_aggr_desc.ql} | 4 +-
.../{topn_count.yaml => float_mean_aggr_desc.yaml} | 4 +-
.../input/{topn_min.ql => float_min_aggr_asc.ql} | 2 +-
.../{topn_min.yaml => float_min_aggr_asc.yaml} | 2 +-
.../input/{topn_sum.ql => float_sum_aggr_desc.ql} | 2 +-
.../{topn_sum.yaml => float_sum_aggr_desc.yaml} | 2 +-
...{null_group.yaml => float_count_aggr_desc.yaml} | 19 +-
.../{null_group.yaml => float_max_aggr_desc.yaml} | 19 +-
.../{null_group.yaml => float_mean_aggr_desc.yaml} | 19 +-
.../{aggr_desc.yaml => float_min_aggr_asc.yaml} | 21 +-
.../{null_group.yaml => float_sum_aggr_desc.yaml} | 19 +-
test/cases/topn/topn.go | 5 +
test/integration/distributed/schema/common.go | 22 +-
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 +++-
364 files changed, 27702 insertions(+), 3323 deletions(-)
create mode 100644 api/validate/validate_test.go
create mode 100644 banyand/backup/lifecycle/steps_test.go
create mode 100644 banyand/internal/sidx/merger_durability_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/merger_durability_test.go
create mode 100644 banyand/measure/metadata_internal_test.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/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
copy pkg/meter/scope_test.go => bydbctl/internal/cmd/use_test.go (52%)
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 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/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/{convert/hash.go => fs/local_file_system_testhook_test.go} (65%)
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/{convert/hash.go => panicdiag/lintrawgo/testdata/src/badcode/bad.go}
(70%)
copy banyand/liaison/http/rpath_empty.go =>
pkg/panicdiag/lintrawgo/testdata/src/baselined/baselined.go (80%)
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/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
copy pkg/test/measure/testdata/measures/{service_instance_cpm_minute.json =>
service_instance_float_metric.json} (91%)
copy
pkg/test/measure/testdata/topn_aggregations/{endpoint_resp_time_minute_top_bottom_100.json
=> service_instance_float_metric_top_bottom_3.json} (61%)
create mode 100644 pkg/timestamp/scheduler_test.go
create mode 100644 scripts/lint/rawgo-baseline/main.go
create mode 100644 scripts/lint/rawgo/main.go
copy mcp/.gitignore => test/cases/measure/data/input/float_bottom.ql (84%)
copy test/cases/measure/data/input/{all.yaml => float_bottom.yaml} (86%)
copy mcp/.gitignore => test/cases/measure/data/input/float_top.ql (84%)
copy test/cases/measure/data/input/{all.yaml => float_top.yaml} (86%)
copy test/cases/measure/data/input/{all_max_limit.ql => float_top_count.ql}
(84%)
copy test/cases/measure/data/input/{top_entity.yaml => float_top_count.yaml}
(92%)
copy test/cases/measure/data/input/{all_max_limit.ql => float_top_mean.ql}
(85%)
copy test/cases/measure/data/input/{top_entity.yaml => float_top_mean.yaml}
(95%)
copy test/cases/measure/data/input/{all_max_limit.ql => float_top_sum.ql} (85%)
copy test/cases/measure/data/input/{top_entity.yaml => float_top_sum.yaml}
(92%)
create mode 100644
test/cases/measure/data/testdata/service_instance_float_metric_data.json
copy test/cases/measure/data/want/{tag_filter_ne.yaml => float_bottom.yaml}
(75%)
copy test/cases/measure/data/want/{tag_filter_ne.yaml => float_top.yaml} (78%)
copy test/cases/measure/data/want/{group_count.yaml => float_top_count.yaml}
(83%)
copy test/cases/measure/data/want/{group_count.yaml => float_top_mean.yaml}
(81%)
copy test/cases/measure/data/want/{group_count.yaml => float_top_sum.yaml}
(80%)
create mode 100644 test/cases/schema/barrier_cluster.go
copy test/cases/topn/data/input/{topn_count.ql => float_count_aggr_desc.ql}
(92%)
copy test/cases/topn/data/input/{topn_count.yaml =>
float_count_aggr_desc.yaml} (94%)
copy test/cases/topn/data/input/{aggr_desc.ql => float_max_aggr_desc.ql} (93%)
copy test/cases/topn/data/input/{aggr_desc.yaml => float_max_aggr_desc.yaml}
(94%)
copy test/cases/topn/data/input/{topn_mean.ql => float_mean_aggr_desc.ql} (91%)
copy test/cases/topn/data/input/{topn_count.yaml => float_mean_aggr_desc.yaml}
(93%)
copy test/cases/topn/data/input/{topn_min.ql => float_min_aggr_asc.ql} (92%)
copy test/cases/topn/data/input/{topn_min.yaml => float_min_aggr_asc.yaml}
(94%)
copy test/cases/topn/data/input/{topn_sum.ql => float_sum_aggr_desc.ql} (92%)
copy test/cases/topn/data/input/{topn_sum.yaml => float_sum_aggr_desc.yaml}
(94%)
copy test/cases/topn/data/want/{null_group.yaml => float_count_aggr_desc.yaml}
(87%)
copy test/cases/topn/data/want/{null_group.yaml => float_max_aggr_desc.yaml}
(86%)
copy test/cases/topn/data/want/{null_group.yaml => float_mean_aggr_desc.yaml}
(86%)
copy test/cases/topn/data/want/{aggr_desc.yaml => float_min_aggr_asc.yaml}
(84%)
copy test/cases/topn/data/want/{null_group.yaml => float_sum_aggr_desc.yaml}
(86%)
create mode 100644 test/load/schema_barrier/barrier_loadtest_test.go
