This is an automated email from the ASF dual-hosted git repository.
lujiajing pushed a change to branch simple-streaming-api
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
omit fa88d53 Merge branch 'main' into simple-streaming-api
omit b13e09c fix lateness check
omit a677331 delete snapshot on purge
omit add246a refactor purge and polish API
omit e6f31f9 add streaming api and topN aggregator
add ff46b35 [BREAKING CHANGES] Introduce OR logical operation (#170)
add a861283 add streaming api and topN aggregator
add ca511ea refactor purge and polish API
add 76f0862 delete snapshot on purge
add ac812f9 fix lateness check
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (fa88d53)
\
N -- N -- N refs/heads/simple-streaming-api (ac812f9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/e2e.storage.yml | 3 +-
Makefile | 12 +-
api/proto/banyandb/measure/v1/query.pb.go | 6 +-
api/proto/banyandb/measure/v1/query.pb.validate.go | 47 +-
api/proto/banyandb/measure/v1/query.proto | 2 +-
api/proto/banyandb/model/v1/query.pb.go | 364 +++++--
api/proto/banyandb/model/v1/query.pb.validate.go | 208 +++-
api/proto/banyandb/model/v1/query.proto | 19 +-
api/proto/banyandb/stream/v1/query.pb.go | 6 +-
api/proto/banyandb/stream/v1/query.pb.validate.go | 47 +-
api/proto/banyandb/stream/v1/query.proto | 2 +-
.../openapi/banyandb/database/v1/rpc.swagger.json | 36 +-
.../openapi/banyandb/measure/v1/rpc.swagger.json | 41 +-
.../openapi/banyandb/stream/v1/rpc.swagger.json | 41 +-
banyand/liaison/grpc/grpc_suite_test.go | 3 -
banyand/liaison/grpc/measure_test.go | 171 ----
banyand/liaison/grpc/registry_test.go | 14 +
banyand/liaison/grpc/stream_test.go | 233 -----
banyand/measure/measure_query_test.go | 287 ------
banyand/measure/measure_write_test.go | 144 ---
.../measure/testdata/service_cpm_minute_data.json | 92 --
banyand/query/processor.go | 11 +-
banyand/query/processor_test.go | 419 --------
banyand/query/query_suite_test.go | 134 ---
banyand/query/testdata/global_index.json | 64 --
banyand/query/testdata/multiple_shards.json | 64 --
banyand/stream/stream_query_test.go | 1018 --------------------
banyand/stream/stream_write_test.go | 298 ------
banyand/stream/testdata/global_index.json | 64 --
banyand/tsdb/scope.go | 1 +
banyand/tsdb/series.go | 39 -
banyand/tsdb/series_filter.go | 278 ------
banyand/tsdb/series_filter_test.go | 315 ------
banyand/tsdb/series_seek.go | 61 +-
banyand/tsdb/series_seek_filter.go | 114 +--
banyand/tsdb/series_seek_sort.go | 67 +-
banyand/tsdb/seriesdb.go | 49 +
docs/api-reference.md | 40 +-
go.mod | 2 +-
pkg/index/index.go | 9 +-
pkg/index/inverted/inverted.go | 14 +-
pkg/index/inverted/inverted_test.go | 1 -
pkg/index/testcases/service_name.go | 1 -
pkg/index/tree.go | 367 -------
pkg/pb/v1/query.go | 477 ---------
pkg/query/logical/common.go | 79 +-
pkg/query/logical/common_test.go | 224 -----
pkg/query/logical/expr.go | 179 +---
pkg/query/logical/expr_literal.go | 169 ++--
pkg/query/logical/format.go | 2 +-
pkg/query/logical/index_filter.go | 647 +++++++++++++
pkg/query/logical/interface.go | 23 +-
pkg/query/logical/iter.go | 21 +-
pkg/query/logical/measure/measure_analyzer.go | 170 ++++
pkg/query/logical/{ => measure}/measure_plan.go | 52 +-
.../{ => measure}/measure_plan_aggregation.go | 101 +-
.../logical/{ => measure}/measure_plan_groupby.go | 91 +-
.../measure/measure_plan_indexscan_local.go | 308 ++++++
.../logical/{ => measure}/measure_plan_top.go | 63 +-
pkg/query/logical/{ => measure}/measure_top.go | 2 +-
.../logical/{ => measure}/measure_top_test.go | 8 +-
pkg/query/logical/measure/schema.go | 124 +++
pkg/query/logical/measure_analyzer.go | 233 -----
pkg/query/logical/measure_analyzer_test.go | 387 --------
pkg/query/logical/measure_plan_execution_test.go | 443 ---------
pkg/query/logical/measure_plan_indexscan_local.go | 406 --------
pkg/query/logical/plan.go | 136 +++
pkg/query/logical/plan_orderby.go | 38 +-
pkg/query/logical/schema.go | 242 +----
pkg/query/logical/stream/schema.go | 99 ++
pkg/query/logical/stream/stream_analyzer.go | 123 +++
.../{ => stream}/stream_plan_indexscan_global.go | 45 +-
.../logical/stream/stream_plan_indexscan_local.go | 127 +++
pkg/query/logical/stream/stream_plan_tag_filter.go | 195 ++++
pkg/query/logical/stream_analyzer.go | 211 ----
pkg/query/logical/stream_analyzer_test.go | 314 ------
pkg/query/logical/stream_plan.go | 166 ----
pkg/query/logical/stream_plan_execution_test.go | 407 --------
pkg/query/logical/stream_plan_indexscan_local.go | 199 ----
pkg/query/logical/stream_plan_tag_filter.go | 269 ------
pkg/query/logical/tag_filter.go | 451 +++++++++
pkg/test/helpers/context.go | 67 ++
pkg/test/retry.go | 42 -
pkg/test/setup.go | 107 --
pkg/test/setup/setup.go | 113 +++
pkg/test/setup_test.go | 107 --
{pkg => test}/Makefile | 4 +-
test/cases/measure/data/data.go | 129 +++
.../cases/measure/data/input/all.yaml | 14 +-
.../cases/measure/data/input/bottom.yaml | 35 +-
.../cases/measure/data/input/entity.yaml | 39 +-
.../cases/measure/data/input/group_max.yaml | 23 +-
.../cases/measure/data/input/group_no_field.yaml | 19 +-
.../cases/measure/data/input/limit.yaml | 16 +-
.../cases/measure/data/input/match_node.yaml | 19 +-
.../cases/measure/data/input/match_nodes.yaml | 19 +-
.../cases/measure/data/input/no_field.yaml | 21 +-
.../cases/measure/data/input/order_asc.yaml | 16 +-
.../cases/measure/data/input/order_desc.yaml | 16 +-
.../cases/measure/data/input/tag_filter.yaml | 21 +-
.../measure/data/input/tag_filter_unknown.yaml | 21 +-
.../cases/measure/data/input/top.yaml | 35 +-
.../data/testdata/service_cpm_minute_data.json | 0
.../data}/testdata/service_cpm_minute_data1.json | 0
.../testdata/service_instance_traffic_data.json | 0
.../data}/testdata/service_traffic_data.json | 0
test/cases/measure/data/want/all.yaml | 138 +++
.../cases/measure/data/want/bottom.yaml | 38 +-
.../cases/measure/data/want/entity.yaml | 17 +-
.../cases/measure/data/want/group_max.yaml | 42 +-
.../cases/measure/data/want/group_no_field.yaml | 35 +-
.../cases/measure/data/want/limit.yaml | 38 +-
.../cases/measure/data/want/match_node.yaml | 20 +-
.../cases/measure/data/want/match_nodes.yaml | 20 +-
.../cases/measure/data/want/no_field.yaml | 17 +-
test/cases/measure/data/want/order_asc.yaml | 114 +++
test/cases/measure/data/want/order_desc.yaml | 114 +++
.../cases/measure/data/want/tag_filter.yaml | 22 +-
.../cases/measure/data/want/top.yaml | 38 +-
test/cases/measure/data/want/update.yaml | 138 +++
test/cases/measure/measure.go | 53 +
.../cases/stream/input/all.yaml | 14 +-
.../cases/stream/input/filter_tag.yaml | 37 +-
.../cases/stream/input/filter_tag_empty.yaml | 37 +-
.../cases/stream/input/global_index.yaml | 21 +-
.../cases/stream/input/having.yaml | 21 +-
.../cases/stream/input/less.yaml | 21 +-
.../cases/stream/input/less_eq.yaml | 21 +-
.../cases/stream/input/limit.yaml | 15 +-
.../cases/stream/input/logical.yaml | 41 +-
.../cases/stream/input/offset.yaml | 15 +-
.../cases/stream/input/search.yaml | 21 +-
.../cases/stream/input/sort_desc.yaml | 17 +-
test/cases/stream/stream.go | 172 ++++
.../cases/stream/testdata/data.json | 27 +-
.../stream}/testdata/service_cpm_minute_data.json | 0
test/cases/stream/want/all.yaml | 83 ++
.../cases/stream/want/filter_tag.yaml | 18 +-
.../cases/stream/want/global_index.yaml | 19 +-
.../cases/stream/want/having.yaml | 45 +-
test/cases/stream/want/less.yaml | 69 ++
test/cases/stream/want/less_eq.yaml | 86 ++
.../cases/stream/want/limit.yaml | 45 +-
test/cases/stream/want/logical.yaml | 68 ++
.../cases/stream/want/offset.yaml | 32 +-
.../cases/stream/want/search.yaml | 40 +-
test/cases/stream/want/sort_desc.yaml | 103 ++
.../templates/searchable_template.json | 12 -
test/cases/stream_tests/write.go | 30 -
test/e2e-v2/cases/profiling/ebpf/sqrt.go | 1 +
test/integration/other/measure_test.go | 64 ++
.../integration/other/other_suite_test.go | 14 +-
.../integration/other}/testdata/server_cert.pem | 0
.../integration/other}/testdata/server_key.pem | 0
test/integration/other/tls_test.go | 68 ++
test/integration/query/query_suite_test.go | 92 ++
test/stress/stress_suite_test.go | 122 ---
157 files changed, 6085 insertions(+), 9572 deletions(-)
delete mode 100644 banyand/liaison/grpc/measure_test.go
delete mode 100644 banyand/liaison/grpc/stream_test.go
delete mode 100644 banyand/measure/measure_query_test.go
delete mode 100644 banyand/measure/measure_write_test.go
delete mode 100644 banyand/measure/testdata/service_cpm_minute_data.json
delete mode 100644 banyand/query/processor_test.go
delete mode 100644 banyand/query/query_suite_test.go
delete mode 100644 banyand/query/testdata/global_index.json
delete mode 100644 banyand/query/testdata/multiple_shards.json
delete mode 100644 banyand/stream/stream_query_test.go
delete mode 100644 banyand/stream/stream_write_test.go
delete mode 100644 banyand/stream/testdata/global_index.json
delete mode 100644 banyand/tsdb/series_filter.go
delete mode 100644 banyand/tsdb/series_filter_test.go
delete mode 100644 pkg/index/tree.go
delete mode 100644 pkg/pb/v1/query.go
delete mode 100644 pkg/query/logical/common_test.go
create mode 100644 pkg/query/logical/index_filter.go
create mode 100644 pkg/query/logical/measure/measure_analyzer.go
rename pkg/query/logical/{ => measure}/measure_plan.go (66%)
rename pkg/query/logical/{ => measure}/measure_plan_aggregation.go (67%)
rename pkg/query/logical/{ => measure}/measure_plan_groupby.go (73%)
create mode 100644 pkg/query/logical/measure/measure_plan_indexscan_local.go
rename pkg/query/logical/{ => measure}/measure_plan_top.go (65%)
rename pkg/query/logical/{ => measure}/measure_top.go (99%)
rename pkg/query/logical/{ => measure}/measure_top_test.go (89%)
create mode 100644 pkg/query/logical/measure/schema.go
delete mode 100644 pkg/query/logical/measure_analyzer.go
delete mode 100644 pkg/query/logical/measure_analyzer_test.go
delete mode 100644 pkg/query/logical/measure_plan_execution_test.go
delete mode 100644 pkg/query/logical/measure_plan_indexscan_local.go
create mode 100644 pkg/query/logical/plan.go
create mode 100644 pkg/query/logical/stream/schema.go
create mode 100644 pkg/query/logical/stream/stream_analyzer.go
rename pkg/query/logical/{ => stream}/stream_plan_indexscan_global.go (74%)
create mode 100644 pkg/query/logical/stream/stream_plan_indexscan_local.go
create mode 100644 pkg/query/logical/stream/stream_plan_tag_filter.go
delete mode 100644 pkg/query/logical/stream_analyzer.go
delete mode 100644 pkg/query/logical/stream_analyzer_test.go
delete mode 100644 pkg/query/logical/stream_plan.go
delete mode 100644 pkg/query/logical/stream_plan_execution_test.go
delete mode 100644 pkg/query/logical/stream_plan_indexscan_local.go
delete mode 100644 pkg/query/logical/stream_plan_tag_filter.go
create mode 100644 pkg/query/logical/tag_filter.go
create mode 100644 pkg/test/helpers/context.go
delete mode 100644 pkg/test/retry.go
create mode 100644 pkg/test/setup/setup.go
delete mode 100644 pkg/test/setup_test.go
copy {pkg => test}/Makefile (94%)
create mode 100644 test/cases/measure/data/data.go
copy api/buf.work.yaml => test/cases/measure/data/input/all.yaml (81%)
copy api/proto/buf.yaml => test/cases/measure/data/input/bottom.yaml (65%)
copy banyand/Makefile => test/cases/measure/data/input/entity.yaml (64%)
copy api/buf.work.yaml => test/cases/measure/data/input/group_max.yaml (69%)
copy pkg/Makefile => test/cases/measure/data/input/group_no_field.yaml (78%)
copy api/buf.work.yaml => test/cases/measure/data/input/limit.yaml (80%)
copy api/buf.work.yaml => test/cases/measure/data/input/match_node.yaml (76%)
copy api/buf.work.yaml => test/cases/measure/data/input/match_nodes.yaml (76%)
copy pkg/Makefile => test/cases/measure/data/input/no_field.yaml (75%)
copy api/buf.work.yaml => test/cases/measure/data/input/order_asc.yaml (79%)
copy api/buf.work.yaml => test/cases/measure/data/input/order_desc.yaml (79%)
copy api/buf.work.yaml => test/cases/measure/data/input/tag_filter.yaml (74%)
copy api/buf.work.yaml =>
test/cases/measure/data/input/tag_filter_unknown.yaml (74%)
copy api/proto/buf.yaml => test/cases/measure/data/input/top.yaml (65%)
copy pkg/query/logical/testdata/measure_top_data.json =>
test/cases/measure/data/testdata/service_cpm_minute_data.json (100%)
rename {banyand/measure =>
test/cases/measure/data}/testdata/service_cpm_minute_data1.json (100%)
copy pkg/query/logical/testdata/measure_search_data.json =>
test/cases/measure/data/testdata/service_instance_traffic_data.json (100%)
rename {banyand/measure =>
test/cases/measure/data}/testdata/service_traffic_data.json (100%)
create mode 100644 test/cases/measure/data/want/all.yaml
copy api/proto/buf.yaml => test/cases/measure/data/want/bottom.yaml (65%)
copy api/buf.work.yaml => test/cases/measure/data/want/entity.yaml (79%)
copy api/buf.work.yaml => test/cases/measure/data/want/group_max.yaml (56%)
copy api/proto/buf.yaml => test/cases/measure/data/want/group_no_field.yaml
(66%)
copy api/buf.work.yaml => test/cases/measure/data/want/limit.yaml (59%)
copy api/buf.work.yaml => test/cases/measure/data/want/match_node.yaml (74%)
copy api/buf.work.yaml => test/cases/measure/data/want/match_nodes.yaml (74%)
copy api/buf.work.yaml => test/cases/measure/data/want/no_field.yaml (79%)
create mode 100644 test/cases/measure/data/want/order_asc.yaml
create mode 100644 test/cases/measure/data/want/order_desc.yaml
copy api/buf.work.yaml => test/cases/measure/data/want/tag_filter.yaml (74%)
copy api/proto/buf.yaml => test/cases/measure/data/want/top.yaml (65%)
create mode 100644 test/cases/measure/data/want/update.yaml
create mode 100644 test/cases/measure/measure.go
copy api/buf.work.yaml => test/cases/stream/input/all.yaml (83%)
copy api/proto/buf.yaml => test/cases/stream/input/filter_tag.yaml (65%)
copy api/proto/buf.yaml => test/cases/stream/input/filter_tag_empty.yaml (65%)
copy api/buf.work.yaml => test/cases/stream/input/global_index.yaml (75%)
copy api/buf.work.yaml => test/cases/stream/input/having.yaml (72%)
copy api/buf.work.yaml => test/cases/stream/input/less.yaml (74%)
copy api/buf.work.yaml => test/cases/stream/input/less_eq.yaml (74%)
copy api/buf.work.yaml => test/cases/stream/input/limit.yaml (82%)
copy api/buf.work.yaml => test/cases/stream/input/logical.yaml (51%)
copy api/buf.work.yaml => test/cases/stream/input/offset.yaml (82%)
copy api/buf.work.yaml => test/cases/stream/input/search.yaml (73%)
copy api/buf.work.yaml => test/cases/stream/input/sort_desc.yaml (78%)
create mode 100644 test/cases/stream/stream.go
rename banyand/stream/testdata/multiple_shards.json =>
test/cases/stream/testdata/data.json (78%)
rename {banyand/query =>
test/cases/stream}/testdata/service_cpm_minute_data.json (100%)
create mode 100644 test/cases/stream/want/all.yaml
copy api/buf.work.yaml => test/cases/stream/want/filter_tag.yaml (77%)
copy api/buf.work.yaml => test/cases/stream/want/global_index.yaml (74%)
copy api/buf.work.yaml => test/cases/stream/want/having.yaml (50%)
create mode 100644 test/cases/stream/want/less.yaml
create mode 100644 test/cases/stream/want/less_eq.yaml
copy api/buf.work.yaml => test/cases/stream/want/limit.yaml (50%)
create mode 100644 test/cases/stream/want/logical.yaml
copy api/buf.work.yaml => test/cases/stream/want/offset.yaml (60%)
copy api/buf.work.yaml => test/cases/stream/want/search.yaml (52%)
create mode 100644 test/cases/stream/want/sort_desc.yaml
delete mode 100644 test/cases/stream_tests/templates/searchable_template.json
delete mode 100644 test/cases/stream_tests/write.go
create mode 100644 test/integration/other/measure_test.go
copy banyand/liaison/grpc/grpc_suite_test.go =>
test/integration/other/other_suite_test.go (87%)
rename {banyand/liaison/grpc =>
test/integration/other}/testdata/server_cert.pem (100%)
rename {banyand/liaison/grpc =>
test/integration/other}/testdata/server_key.pem (100%)
create mode 100644 test/integration/other/tls_test.go
create mode 100644 test/integration/query/query_suite_test.go
delete mode 100644 test/stress/stress_suite_test.go
