This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a change to branch tracetest
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from dbe16d2a feat: add a command to query trace by id
add fe5ba87f Improve the trace model for the limit (#748)
add c4000531 Implement sidx flushing and merging (#745)
add 8ccede21 Add unit tests for sidx merge operation (#749)
add d293765d Implement a resilient publisher (#750)
add 03d413b7 Write index before core trace storage (#751)
add 7e6ac87d feat: optimize gRPC message size limits for better
time-series data handling (#752)
add 6beafa0a Add query access log support (#754)
add eaf69c38 fix panic when repair property (#753)
add 5741ebd0 Enhance query access logging across gRPC services (#755)
add d0942a3f Fix query access log unmarshal error (#756)
add d613e588 Fix bugs time query range will not automatically update and
add some new time query ranges (#757)
add 174405b4 Fix the merging panic (#759)
add 4d5813fd - Add the TRACE Model to BydbQL and support distributed
tracing with `WITH QUERY_TRACE` (#760)
add a287c38c feat: improve trace query functionality (#762)
add 46083529 Bump vite from 6.3.4 to 6.3.6 in /ui (#763)
add 55e78bb5 Fix variable assignment in OpenDB function to use group name
instead of group which is always "" (#765)
add 2e59df11 Refactor OpenDB functions to use 'Name' field from
groupSchema.Metadata instead of 'Group'. Add new test data for Zipkin trace,
index rules, and traces to enhance testing capabilities. (#766)
add 69179312 Implement versioning support in API (#768)
add c51150b6 Merge branch 'main' into tracetest
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 6 +-
api/proto/banyandb/cluster/v1/rpc.proto | 35 ++
api/proto/banyandb/model/v1/write.proto | 2 +
api/proto/banyandb/trace/v1/query.proto | 10 +-
banyand/internal/sidx/block.go | 278 ++++++++-
banyand/{trace => internal/sidx}/block_reader.go | 55 +-
banyand/internal/sidx/block_reader_test.go | 218 +++++++
banyand/internal/sidx/block_scanner_test.go | 2 -
banyand/internal/sidx/element.go | 3 -
banyand/internal/sidx/element_test.go | 2 -
banyand/{trace => internal/sidx}/gc.go | 6 +-
banyand/{trace => internal/sidx}/gc_test.go | 4 +-
banyand/internal/sidx/interfaces.go | 124 +++-
banyand/internal/sidx/introducer.go | 8 +-
banyand/internal/sidx/introducer_test.go | 12 +-
banyand/internal/sidx/iter_test.go | 56 +-
banyand/internal/sidx/merge.go | 231 +++++++
banyand/internal/sidx/merge_test.go | 431 +++++++++++++
banyand/internal/sidx/metadata.go | 27 +
banyand/internal/sidx/multi_sidx_query_test.go | 2 +-
banyand/internal/sidx/options.go | 63 +-
banyand/internal/sidx/options_test.go | 164 +----
banyand/internal/sidx/part.go | 7 +-
banyand/internal/sidx/part_iter.go | 144 +++++
banyand/internal/sidx/part_iter_test.go | 19 -
banyand/internal/sidx/part_test.go | 20 -
banyand/internal/sidx/part_wrapper.go | 2 +-
banyand/internal/sidx/query_result.go | 60 +-
banyand/internal/sidx/sidx.go | 330 ++++++----
banyand/internal/sidx/sidx_test.go | 41 +-
banyand/internal/sidx/snapshot.go | 77 ++-
banyand/internal/sidx/snapshot_test.go | 13 +-
banyand/internal/sidx/tag.go | 18 +-
banyand/internal/sidx/tag_filter_op.go | 14 +-
banyand/internal/sidx/tag_test.go | 14 +-
banyand/internal/storage/version.go | 10 +
banyand/liaison/grpc/measure.go | 28 +-
banyand/liaison/grpc/property.go | 65 +-
banyand/liaison/grpc/server.go | 26 +-
banyand/liaison/grpc/stream.go | 18 +-
banyand/liaison/grpc/trace.go | 22 +-
banyand/property/shard.go | 3 +
banyand/query/processor.go | 28 +-
banyand/queue/pub/batch.go | 96 ++-
banyand/queue/pub/chunked_sync.go | 12 +
banyand/queue/pub/circuitbreaker.go | 147 +++++
banyand/queue/pub/circuitbreaker_test.go | 683 +++++++++++++++++++++
banyand/queue/pub/client.go | 176 ++++--
banyand/queue/pub/client_test.go | 2 +-
banyand/queue/pub/pub.go | 67 +-
banyand/queue/pub/pub_suite_test.go | 28 +
banyand/queue/pub/pub_test.go | 18 +-
banyand/queue/pub/retry.go | 161 +++++
banyand/queue/pub/retry_test.go | 526 ++++++++++++++++
banyand/queue/sub/chunked_sync.go | 89 ++-
banyand/queue/sub/sub.go | 88 +++
banyand/queue/sub/version_compatibility_test.go | 337 ++++++++++
banyand/trace/block_metadata.go | 3 +
banyand/trace/block_reader.go | 2 +-
banyand/trace/flusher.go | 5 +-
banyand/trace/merger.go | 5 +-
banyand/trace/merger_test.go | 46 +-
banyand/trace/metadata.go | 8 +-
banyand/trace/query.go | 3 +
banyand/trace/svc_standalone.go | 2 +
banyand/trace/tstable.go | 45 +-
banyand/trace/write_standalone.go | 23 +-
docs/api-reference.md | 65 +-
docs/interacting/bydbql.md | 248 +++++++-
pkg/accesslog/accesslog.go | 4 +
pkg/accesslog/file.go | 51 +-
pkg/accesslog/query_log.go | 73 +++
pkg/accesslog/query_log_test.go | 160 +++++
pkg/schema/cache.go | 3 +
...st-trace-group.json => zipkin-trace-group.json} | 4 +-
.../index_rule_bindings/{sw.json => zipkin.json} | 11 +-
.../testdata/index_rules/zipkin-duration.json | 14 +
.../trace/testdata/index_rules/zipkin-service.json | 14 +
.../testdata/index_rules/zipkin-timestamp.json | 14 +
pkg/test/trace/testdata/traces/zipkin.json | 71 +++
test/cases/init.go | 1 +
test/cases/trace/data/data.go | 83 ++-
.../data/input/eq_endpoint_order_duration_asc.yml | 2 +-
test/cases/trace/data/input/eq_trace_id.yml | 2 +-
.../cases/trace/data/input/order_duration_desc.yml | 2 +-
...amp_desc.yml => order_timestamp_desc_limit.yml} | 1 +
test/cases/trace/data/testdata/sw.json | 308 +++++++++-
test/cases/trace/data/testdata/zipkin.json | 377 ++++++++++++
.../data/want/eq_endpoint_order_duration_asc.yml | 13 +-
.../want/eq_service_instance_order_time_asc.yml | 21 +-
.../data/want/eq_service_order_timestamp_desc.yml | 25 +-
test/cases/trace/data/want/eq_trace_id.yml | 27 +-
test/cases/trace/data/want/order_duration_desc.yml | 25 +-
.../cases/trace/data/want/order_timestamp_desc.yml | 25 +-
.../trace/data/want/order_timestamp_desc_limit.yml | 15 +-
test/cases/trace/trace.go | 1 +
.../standalone/cold_query/query_suite_test.go | 5 +
.../query_ondisk/query_ondisk_suite_test.go | 5 +
ui/package-lock.json | 8 +-
ui/package.json | 2 +-
ui/src/components/common/data.js | 38 +-
101 files changed, 6105 insertions(+), 883 deletions(-)
copy banyand/{trace => internal/sidx}/block_reader.go (83%)
create mode 100644 banyand/internal/sidx/block_reader_test.go
copy banyand/{trace => internal/sidx}/gc.go (95%)
copy banyand/{trace => internal/sidx}/gc_test.go (98%)
create mode 100644 banyand/internal/sidx/merge.go
create mode 100644 banyand/internal/sidx/merge_test.go
create mode 100644 banyand/queue/pub/circuitbreaker.go
create mode 100644 banyand/queue/pub/circuitbreaker_test.go
create mode 100644 banyand/queue/pub/retry.go
create mode 100644 banyand/queue/pub/retry_test.go
create mode 100644 banyand/queue/sub/version_compatibility_test.go
create mode 100644 pkg/accesslog/query_log.go
create mode 100644 pkg/accesslog/query_log_test.go
copy pkg/test/trace/testdata/groups/{test-trace-group.json =>
zipkin-trace-group.json} (85%)
copy pkg/test/trace/testdata/index_rule_bindings/{sw.json => zipkin.json} (56%)
create mode 100644 pkg/test/trace/testdata/index_rules/zipkin-duration.json
create mode 100644 pkg/test/trace/testdata/index_rules/zipkin-service.json
create mode 100644 pkg/test/trace/testdata/index_rules/zipkin-timestamp.json
create mode 100644 pkg/test/trace/testdata/traces/zipkin.json
copy test/cases/trace/data/input/{order_timestamp_desc.yml =>
order_timestamp_desc_limit.yml} (99%)
create mode 100644 test/cases/trace/data/testdata/zipkin.json
copy scripts/build/vendor.mk =>
test/cases/trace/data/want/order_timestamp_desc_limit.yml (82%)
