This is an automated email from the ASF dual-hosted git repository.
mrproliu pushed a change to branch fix/add-consistently-checks
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from 5015cbac3 add Consistently check after Eventually checks
add 152fa41f8 Fix block metadata reset before unmarshal for stream and
trace (#1195)
add 4c674abc4 feat: implement global tag type metadata for measure parts
(#1196)
add 38704419f Add FODC memory-pressure pprof capture (#1200)
add 2c9946197 Lifecycle only handle stream/measure/trace snapshots (#1202)
add 3daa63cc7 Merge branch 'main' into fix/add-consistently-checks
No new revisions were added by this update.
Summary of changes:
.github/workflows/test-fodc-e2e.yml | 49 ++-
CHANGES.md | 3 +
api/proto/banyandb/fodc/v1/rpc.proto | 75 ++++
banyand/backup/lifecycle/steps.go | 9 +
banyand/measure/block.go | 9 +
banyand/measure/block_metadata.go | 16 +
banyand/measure/block_metadata_test.go | 35 ++
banyand/measure/block_reader_test.go | 1 +
banyand/measure/block_test.go | 14 +
banyand/measure/block_writer.go | 11 +-
banyand/measure/file_part_sync_test.go | 30 +-
banyand/measure/merger.go | 14 +-
banyand/measure/merger_test.go | 40 +-
banyand/measure/part.go | 23 +-
banyand/measure/part_iter_test.go | 2 +
banyand/measure/part_metadata.go | 95 +++++
banyand/measure/part_test.go | 6 +
banyand/measure/syncer.go | 19 +
banyand/measure/tstable_test.go | 1 +
banyand/measure/write_data.go | 20 +-
banyand/protector/protector.go | 53 ++-
banyand/protector/protector_test.go | 107 ++++++
banyand/stream/block_metadata.go | 2 +
banyand/stream/block_metadata_test.go | 35 ++
banyand/stream/block_scanner_test.go | 1 +
banyand/stream/merger.go | 2 +-
banyand/stream/part_iter_test.go | 2 +
banyand/stream/query_by_idx_test.go | 1 +
banyand/stream/tstable_test.go | 1 +
banyand/trace/block_metadata.go | 2 +
banyand/trace/block_metadata_test.go | 34 ++
banyand/trace/merger.go | 6 +-
docs/api-reference.md | 155 ++++++++
fodc/agent/internal/cmd/root.go | 64 +++-
fodc/agent/internal/cmd/root_test.go | 39 ++
fodc/agent/internal/flightrecorder/datasource.go | 19 +
.../internal/flightrecorder/flightrecorder.go | 45 +++
.../internal/flightrecorder/flightrecorder_test.go | 52 +++
fodc/agent/internal/pressureprofiler/fetch.go | 59 +++
fodc/agent/internal/pressureprofiler/profiler.go | 239 ++++++++++++
.../internal/pressureprofiler/profiler_test.go | 206 +++++++++++
fodc/agent/internal/pressureprofiler/storage.go | 258 +++++++++++++
.../internal/pressureprofiler/storage_test.go | 128 +++++++
fodc/agent/internal/proxy/client.go | 263 +++++++++++++
.../internal/proxy/client_blocking_send_test.go | 4 +-
fodc/agent/internal/proxy/client_test.go | 99 ++---
fodc/agent/internal/watchdog/watchdog.go | 18 +
fodc/agent/testhelper/flightrecorder.go | 3 +
fodc/agent/testhelper/pressureprofiler.go | 110 ++++++
fodc/internal/pprofcapture/pprofcapture.go | 44 +++
fodc/proxy/cmd/proxy/main.go | 9 +-
fodc/proxy/internal/api/server.go | 136 +++++++
fodc/proxy/internal/api/server_test.go | 18 +-
fodc/proxy/internal/grpc/pressure_list_test.go | 130 +++++++
fodc/proxy/internal/grpc/server_test.go | 8 +-
fodc/proxy/internal/grpc/service.go | 406 ++++++++++++++++++++-
fodc/proxy/internal/grpc/service_test.go | 4 +-
.../integration/agent_reconnection_test.go | 4 +-
.../agent_registration_metrics_flow_test.go | 4 +-
.../cluster_topology_integration_test.go | 4 +-
fodc/proxy/internal/integration/diagnostic_test.go | 4 +-
.../internal/integration/failure_scenarios_test.go | 6 +-
.../integration/full_proxy_workflow_test.go | 4 +-
.../high_availability_scalability_test.go | 4 +-
.../integration/lifecycle_integration_test.go | 4 +-
.../integration/metrics_time_window_test.go | 4 +-
.../integration/multiple_agents_roles_test.go | 4 +-
.../internal/integration/pressure_profile_test.go | 246 +++++++++++++
.../integration/prometheus_integration_test.go | 4 +-
fodc/proxy/internal/pressure/aggregator.go | 269 ++++++++++++++
fodc/proxy/internal/pressure/aggregator_test.go | 99 +++++
.../cases/fodc-pressure/banyandb-cluster.yaml | 98 +++++
test/e2e-v2/cases/fodc-pressure/check-pressure.sh | 123 +++++++
test/e2e-v2/cases/fodc-pressure/e2e.yaml | 68 ++++
.../expected/pressure-status.yml} | 2 +-
75 files changed, 4044 insertions(+), 141 deletions(-)
create mode 100644 fodc/agent/internal/pressureprofiler/fetch.go
create mode 100644 fodc/agent/internal/pressureprofiler/profiler.go
create mode 100644 fodc/agent/internal/pressureprofiler/profiler_test.go
create mode 100644 fodc/agent/internal/pressureprofiler/storage.go
create mode 100644 fodc/agent/internal/pressureprofiler/storage_test.go
create mode 100644 fodc/agent/testhelper/pressureprofiler.go
create mode 100644 fodc/internal/pprofcapture/pprofcapture.go
create mode 100644 fodc/proxy/internal/grpc/pressure_list_test.go
create mode 100644 fodc/proxy/internal/integration/pressure_profile_test.go
create mode 100644 fodc/proxy/internal/pressure/aggregator.go
create mode 100644 fodc/proxy/internal/pressure/aggregator_test.go
create mode 100644 test/e2e-v2/cases/fodc-pressure/banyandb-cluster.yaml
create mode 100755 test/e2e-v2/cases/fodc-pressure/check-pressure.sh
create mode 100644 test/e2e-v2/cases/fodc-pressure/e2e.yaml
copy test/e2e-v2/cases/{zipkin/expected/remote-service-name.yml =>
fodc-pressure/expected/pressure-status.yml} (98%)
