You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by lu...@apache.org on 2022/05/22 10:17:42 UTC
[skywalking-banyandb] branch oap-e2e updated (7250f13 -> 27da8b3)
This is an automated email from the ASF dual-hosted git repository.
lujiajing pushed a change to branch oap-e2e
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from 7250f13 use apache archive
add e5bdb20 Add groupBy to the measure query request (#87)
add bcf9fa4 Add the location to the start time parser (#88)
add 7f95762 Add measure query (#89)
add f9d6d1a Add a prefix to the root path and flag (#90)
add 885898f Add the TopNAggregation schema registration (#91)
add 007867d Support measure aggregation (#92)
add 29c9cbf Improve the measure module due to the integration (#93)
add b340899 Support top function on measure querying (#94)
add 7f05229 Add Property CRUD (#95)
add 1d5c0a6 Improve the observability of banyandb: (#96)
add 3c8d162 Fix NPE of stating badger kv (#97)
add 697582d Uncomment measure (#98)
add d061ab4 Add measure tests to liaison (#99)
add fd1aa3a Fix duplicate datapoints (#101)
add 54c252b Return error created from status (#100)
add 7a9a8c8 Trigger inverted index flushing on flushing the main store (#102)
add 6f081f2 Add test cases for handling numeric values of the inverted index (#103)
add ad94bb9 fix deletion problem (#105)
add 0f78d0d Make sure index rule ID is set by (#104)
add b7e24c2 Introduce the clock mock to test block controller (#106)
add 036d719 Increase time range to fix flaky testing (#107)
add a548cfa Check input time range (#108)
add 49a23ae Append group name to the end of tsdb's path (#109)
add 73a24bc Introduce gorilla encoder to measure (#110)
add 69420e6 Add docs (#111)
add 70f1a6b Fix UT failures under a non-UTC timezone (#112)
add f3d4a90 Set doc link to host docs (#113)
add c32f025 Correct the behaviour of group by (#114)
add b64f2a1 Fix the updating failure of the measure (#115)
add 9f540a7 Fix data race of ob apis (#116)
add 1eda9fa Enhance the measure query (#117)
add 0cbb9e4 fix timeRange check (#118)
add f868a5d Fix invalid default time range (#119)
add 27da8b3 Merge branch 'main' into oap-e2e
No new revisions were added by this update.
Summary of changes:
.github/workflows/go.yml | 5 +
.gitignore | 3 +
README.md | 23 +-
api/Makefile | 2 +
api/buf.gen.yaml | 4 +
api/common/id.go | 43 +-
api/proto/banyandb/common/v1/common.pb.go | 428 +--
api/proto/banyandb/common/v1/common.proto | 36 +-
api/proto/banyandb/database/v1/rpc.pb.go | 1252 +++++++--
api/proto/banyandb/database/v1/rpc.proto | 48 +-
api/proto/banyandb/database/v1/rpc_grpc.pb.go | 235 ++
api/proto/banyandb/database/v1/schema.pb.go | 250 +-
api/proto/banyandb/database/v1/schema.proto | 4 +
api/proto/banyandb/measure/v1/query.pb.go | 440 +++-
api/proto/banyandb/measure/v1/query.proto | 51 +-
api/proto/banyandb/measure/v1/rpc_grpc.pb.go | 4 +
api/proto/banyandb/measure/v1/topn.pb.go | 159 +-
api/proto/banyandb/measure/v1/topn.proto | 13 +-
api/proto/banyandb/measure/v1/write.pb.go | 2 +-
api/proto/banyandb/measure/v1/write.proto | 2 +-
api/proto/banyandb/model/v1/common.pb.go | 363 ++-
api/proto/banyandb/model/v1/common.proto | 14 +
api/proto/banyandb/property/v1/property.pb.go | 290 +++
.../database.proto => property/v1/property.proto} | 35 +-
api/proto/banyandb/property/v1/rpc.pb.go | 780 ++++++
api/proto/banyandb/property/v1/rpc.proto | 72 +
api/proto/banyandb/property/v1/rpc_grpc.pb.go | 250 ++
api/proto/banyandb/stream/v1/query.pb.go | 6 +-
api/proto/banyandb/stream/v1/query.proto | 6 +-
api/proto/banyandb/stream/v1/rpc_grpc.pb.go | 4 +
api/proto/banyandb/stream/v1/write.pb.go | 2 +-
api/proto/banyandb/stream/v1/write.proto | 2 +-
banyand/internal/cmd/standalone.go | 20 +-
banyand/kv/badger.go | 25 +-
banyand/kv/kv.go | 13 +-
banyand/liaison/grpc/grpc_suite_test.go | 5 +-
banyand/liaison/grpc/measure.go | 31 +-
.../grpc/{stream_test.go => measure_test.go} | 140 +-
banyand/liaison/grpc/property.go | 70 +
banyand/liaison/grpc/registry.go | 64 +-
banyand/liaison/grpc/registry_test.go | 8 +-
banyand/liaison/grpc/server.go | 23 +-
banyand/liaison/grpc/stream.go | 15 +
banyand/liaison/grpc/stream_test.go | 51 +-
banyand/measure/encode.go | 123 +
.../measure/field_flag_test.go | 56 +-
banyand/measure/measure.go | 13 +-
banyand/measure/measure_query.go | 5 +-
banyand/measure/measure_query_test.go | 241 +-
banyand/measure/measure_suite_test.go | 8 +-
banyand/measure/measure_write.go | 24 +-
banyand/measure/measure_write_test.go | 84 +-
banyand/measure/metadata.go | 14 +-
banyand/measure/metadata_test.go | 30 +-
banyand/measure/service.go | 5 +-
banyand/measure/testdata/query_data.json | 107 -
.../measure/testdata/service_cpm_minute_data.json | 92 +
.../measure/testdata/service_cpm_minute_data1.json | 32 +
banyand/measure/testdata/service_traffic_data.json | 116 +
banyand/measure/testdata/write_data.json | 107 -
banyand/metadata/metadata.go | 13 +-
banyand/metadata/metadata_test.go | 7 +-
banyand/metadata/schema/error.go | 53 +
banyand/metadata/schema/etcd.go | 332 +--
banyand/metadata/schema/etcd_test.go | 16 +-
banyand/metadata/schema/group.go | 111 +
banyand/metadata/schema/index.go | 167 ++
banyand/metadata/schema/measure.go | 201 ++
banyand/metadata/schema/property.go | 100 +
banyand/metadata/schema/schema.go | 35 +-
banyand/metadata/schema/schema_suite_test.go | 10 +
banyand/metadata/schema/stream.go | 90 +
banyand/metadata/schema/testdata/group.json | 11 +-
banyand/metadata/schema/testdata/stream.json | 2 +-
banyand/metadata/schema/topn.go | 90 +
banyand/{prof/pprof.go => observability/metric.go} | 38 +-
banyand/{prof => observability}/pprof.go | 7 +-
.../hash.go => banyand/observability/type.go | 15 +-
banyand/query/processor.go | 127 +-
banyand/query/processor_test.go | 638 ++---
banyand/query/query.go | 24 +-
banyand/query/query_suite_test.go | 137 +
banyand/query/testdata/global_index.json | 6 +-
banyand/query/testdata/multiple_shards.json | 6 +-
banyand/stream/metadata.go | 11 +-
banyand/stream/service.go | 5 +-
banyand/stream/stream_query.go | 2 +-
banyand/stream/stream_query_test.go | 50 +-
banyand/stream/stream_suite_test.go | 4 +-
banyand/stream/stream_write.go | 8 +-
banyand/stream/stream_write_test.go | 45 +-
banyand/stream/testdata/global_index.json | 6 +-
banyand/stream/testdata/multiple_shards.json | 6 +-
banyand/tsdb/block.go | 79 +-
banyand/tsdb/bucket/bucket.go | 8 +-
banyand/tsdb/bucket/bucket_suite_test.go | 2 +-
banyand/tsdb/bucket/queue.go | 11 +
banyand/tsdb/bucket/strategy.go | 1 +
banyand/tsdb/index/writer.go | 3 +
banyand/tsdb/metric.go | 121 +
banyand/tsdb/scope.go | 9 +-
banyand/tsdb/segment.go | 95 +-
banyand/tsdb/series_seek.go | 6 +-
banyand/tsdb/series_write.go | 2 +-
banyand/tsdb/seriesdb.go | 25 +-
banyand/tsdb/seriesdb_test.go | 122 +-
banyand/tsdb/shard.go | 77 +-
banyand/tsdb/shard_test.go | 427 ++-
banyand/tsdb/tsdb.go | 20 +-
banyand/tsdb/tsdb_suite_test.go | 5 +-
docs/README.md | 26 +
docs/api-reference.md | 2732 ++++++++++++++++++++
docs/clients.md | 38 +
docs/crud/measure/query.md | 7 +
docs/crud/measure/write.md | 7 +
docs/crud/property/create.md | 7 +
docs/crud/property/delete.md | 7 +
docs/crud/property/query.md | 7 +
docs/crud/property/update.md | 7 +
docs/crud/stream/query.md | 7 +
docs/crud/stream/write.md | 7 +
docs/installation.md | 118 +
docs/menu.yml | 50 +
docs/schema.md | 58 +
go.mod | 39 +-
go.sum | 65 +-
pkg/bit/writer.go | 10 +-
pkg/bus/bus.go | 4 +-
pkg/bus/bus_test.go | 4 +-
pkg/encoding/int.go | 117 +-
pkg/encoding/int_test.go | 123 +
pkg/encoding/plain.go | 34 +-
pkg/index/index.go | 4 +
pkg/index/inverted/field_map.go | 12 +
pkg/index/inverted/inverted.go | 14 +
pkg/index/inverted/inverted_test.go | 2 +-
pkg/index/inverted/mem.go | 5 +
pkg/index/inverted/term_map.go | 12 +
pkg/index/lsm/lsm.go | 9 +
pkg/index/lsm/lsm_test.go | 2 +-
pkg/index/posting/posting.go | 2 +
pkg/index/posting/roaring/roaring.go | 4 +
pkg/pb/v1/metadata.go | 2 +
pkg/pb/v1/query.go | 170 +-
pkg/pb/v1/write.go | 120 +
.../aggregation/aggregation.go} | 69 +-
pkg/query/aggregation/function.go | 124 +
pkg/query/executor/interface.go | 52 +-
pkg/query/logical/common.go | 13 +-
pkg/query/logical/common_test.go | 84 +-
pkg/query/logical/expr.go | 83 +-
pkg/query/logical/expr_literal.go | 46 +-
pkg/query/logical/format.go | 2 +-
pkg/query/logical/interface.go | 9 +-
pkg/query/logical/measure_analyzer.go | 235 ++
pkg/query/logical/measure_analyzer_test.go | 337 +++
pkg/query/logical/measure_plan.go | 127 +
pkg/query/logical/measure_plan_aggregation.go | 264 ++
pkg/query/logical/measure_plan_execution_test.go | 357 +++
pkg/query/logical/measure_plan_groupby.go | 299 +++
pkg/query/logical/measure_plan_indexscan_local.go | 392 +++
pkg/query/logical/measure_plan_top.go | 148 ++
pkg/query/logical/measure_top.go | 152 ++
pkg/query/logical/measure_top_test.go | 78 +
pkg/query/logical/plan_orderby.go | 6 +-
pkg/query/logical/schema.go | 286 +-
.../logical/{analyzer.go => stream_analyzer.go} | 48 +-
.../{analyzer_test.go => stream_analyzer_test.go} | 58 +-
pkg/query/logical/{plan.go => stream_plan.go} | 8 +-
...ution_test.go => stream_plan_execution_test.go} | 45 +-
...n_global.go => stream_plan_indexscan_global.go} | 8 +-
...can_local.go => stream_plan_indexscan_local.go} | 35 +-
pkg/query/logical/testdata/global_index.json | 6 +-
pkg/query/logical/testdata/measure_query_data.json | 92 +
pkg/query/logical/testdata/measure_top_data.json | 182 ++
pkg/query/logical/testdata/multiple_shards.json | 6 +-
pkg/schema/metadata.go | 47 +-
pkg/test/measure/etcd.go | 106 +-
pkg/test/measure/testdata/group.json | 27 -
pkg/test/measure/testdata/groups/sw_metric.json | 12 +
.../service_instance_traffic.json} | 8 +-
.../service_traffic.json} | 8 +-
.../{entity_id.json => service_id.json} | 6 +-
.../service_cpm_day.json} | 19 +-
.../service_cpm_hour.json} | 19 +-
.../service_cpm_minute.json} | 19 +-
.../service_instance_cpm_day.json} | 20 +-
.../service_instance_cpm_hour.json} | 20 +-
.../service_instance_cpm_minute.json} | 20 +-
.../measures/service_instance_traffic.json | 39 +
.../measure/testdata/measures/service_traffic.json | 43 +
pkg/test/stream/etcd.go | 58 +-
pkg/test/stream/testdata/group.json | 11 +-
pkg/test/stream/testdata/stream.json | 2 +-
pkg/test/stream/traffic/searchable_template.json | 12 +
pkg/test/stream/traffic/traffic_test.go | 163 ++
pkg/timestamp/clock.go | 69 +
.../logical/format.go => timestamp/duration.go} | 53 +-
.../reader_test.go => timestamp/duration_test.go} | 66 +-
pkg/timestamp/nano.go | 115 +
.../mem_test.go => timestamp/nano_test.go} | 21 +-
scripts/build/base.mk | 8 +-
scripts/build/test.mk | 10 +-
203 files changed, 15018 insertions(+), 3202 deletions(-)
create mode 100644 api/proto/banyandb/property/v1/property.pb.go
copy api/proto/banyandb/{database/v1/database.proto => property/v1/property.proto} (61%)
create mode 100644 api/proto/banyandb/property/v1/rpc.pb.go
create mode 100644 api/proto/banyandb/property/v1/rpc.proto
create mode 100644 api/proto/banyandb/property/v1/rpc_grpc.pb.go
copy banyand/liaison/grpc/{stream_test.go => measure_test.go} (50%)
create mode 100644 banyand/liaison/grpc/property.go
create mode 100644 banyand/measure/encode.go
copy pkg/query/logical/interface.go => banyand/measure/field_flag_test.go (59%)
delete mode 100644 banyand/measure/testdata/query_data.json
create mode 100644 banyand/measure/testdata/service_cpm_minute_data.json
create mode 100644 banyand/measure/testdata/service_cpm_minute_data1.json
create mode 100644 banyand/measure/testdata/service_traffic_data.json
delete mode 100644 banyand/measure/testdata/write_data.json
create mode 100644 banyand/metadata/schema/error.go
create mode 100644 banyand/metadata/schema/group.go
create mode 100644 banyand/metadata/schema/index.go
create mode 100644 banyand/metadata/schema/measure.go
create mode 100644 banyand/metadata/schema/property.go
create mode 100644 banyand/metadata/schema/stream.go
create mode 100644 banyand/metadata/schema/topn.go
copy banyand/{prof/pprof.go => observability/metric.go} (61%)
rename banyand/{prof => observability}/pprof.go (93%)
copy pkg/convert/hash.go => banyand/observability/type.go (82%)
create mode 100644 banyand/query/query_suite_test.go
create mode 100644 banyand/tsdb/metric.go
create mode 100644 docs/README.md
create mode 100644 docs/api-reference.md
create mode 100644 docs/clients.md
create mode 100644 docs/crud/measure/query.md
create mode 100644 docs/crud/measure/write.md
create mode 100644 docs/crud/property/create.md
create mode 100644 docs/crud/property/delete.md
create mode 100644 docs/crud/property/query.md
create mode 100644 docs/crud/property/update.md
create mode 100644 docs/crud/stream/query.md
create mode 100644 docs/crud/stream/write.md
create mode 100644 docs/installation.md
create mode 100644 docs/menu.yml
create mode 100644 docs/schema.md
create mode 100644 pkg/encoding/int_test.go
copy pkg/{index/posting/posting.go => query/aggregation/aggregation.go} (52%)
create mode 100644 pkg/query/aggregation/function.go
create mode 100644 pkg/query/logical/measure_analyzer.go
create mode 100644 pkg/query/logical/measure_analyzer_test.go
create mode 100644 pkg/query/logical/measure_plan.go
create mode 100644 pkg/query/logical/measure_plan_aggregation.go
create mode 100644 pkg/query/logical/measure_plan_execution_test.go
create mode 100644 pkg/query/logical/measure_plan_groupby.go
create mode 100644 pkg/query/logical/measure_plan_indexscan_local.go
create mode 100644 pkg/query/logical/measure_plan_top.go
create mode 100644 pkg/query/logical/measure_top.go
create mode 100644 pkg/query/logical/measure_top_test.go
rename pkg/query/logical/{analyzer.go => stream_analyzer.go} (78%)
rename pkg/query/logical/{analyzer_test.go => stream_analyzer_test.go} (81%)
rename pkg/query/logical/{plan.go => stream_plan.go} (90%)
rename pkg/query/logical/{plan_execution_test.go => stream_plan_execution_test.go} (85%)
rename pkg/query/logical/{plan_indexscan_global.go => stream_plan_indexscan_global.go} (93%)
rename pkg/query/logical/{plan_indexscan_local.go => stream_plan_indexscan_local.go} (89%)
create mode 100644 pkg/query/logical/testdata/measure_query_data.json
create mode 100644 pkg/query/logical/testdata/measure_top_data.json
delete mode 100644 pkg/test/measure/testdata/group.json
create mode 100644 pkg/test/measure/testdata/groups/sw_metric.json
copy pkg/test/measure/testdata/{index_rule_binding.json => index_rule_bindings/service_instance_traffic.json} (62%)
rename pkg/test/measure/testdata/{index_rule_binding.json => index_rule_bindings/service_traffic.json} (65%)
rename pkg/test/measure/testdata/index_rules/{entity_id.json => service_id.json} (69%)
copy pkg/test/measure/testdata/{measure.json => measures/service_cpm_day.json} (68%)
copy pkg/test/measure/testdata/{measure.json => measures/service_cpm_hour.json} (68%)
copy pkg/test/measure/testdata/{measure.json => measures/service_cpm_minute.json} (68%)
copy pkg/test/measure/testdata/{measure.json => measures/service_instance_cpm_day.json} (71%)
copy pkg/test/measure/testdata/{measure.json => measures/service_instance_cpm_hour.json} (71%)
rename pkg/test/measure/testdata/{measure.json => measures/service_instance_cpm_minute.json} (71%)
create mode 100644 pkg/test/measure/testdata/measures/service_instance_traffic.json
create mode 100644 pkg/test/measure/testdata/measures/service_traffic.json
create mode 100644 pkg/test/stream/traffic/searchable_template.json
create mode 100644 pkg/test/stream/traffic/traffic_test.go
create mode 100644 pkg/timestamp/clock.go
copy pkg/{query/logical/format.go => timestamp/duration.go} (55%)
copy pkg/{bit/reader_test.go => timestamp/duration_test.go} (54%)
create mode 100644 pkg/timestamp/nano.go
copy pkg/{index/inverted/mem_test.go => timestamp/nano_test.go} (69%)