You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by ha...@apache.org on 2021/11/11 09:37:09 UTC
[skywalking-banyandb] 03/04: Merge branch 'main' of
github.com:apache/skywalking-banyandb into main
This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a commit to branch go-1.17
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
commit 393b7deabfbecd6c2dfbc233a755bab3355f3dd9
Merge: 0da455c d7b8833
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Thu Nov 11 17:27:09 2021 +0800
Merge branch 'main' of github.com:apache/skywalking-banyandb into main
Makefile | 1 +
api/Makefile | 2 +-
api/proto/banyandb/common/v1/common.pb.go | 136 +-
api/proto/banyandb/common/v1/common.proto | 10 +
api/proto/banyandb/database/v1/database.pb.go | 2 +-
api/proto/banyandb/database/v1/event.pb.go | 2 +-
api/proto/banyandb/database/v1/rpc.pb.go | 3423 ++++++++++++++++++++
api/proto/banyandb/database/v1/rpc.proto | 248 ++
api/proto/banyandb/database/v1/rpc_grpc.pb.go | 1133 +++++++
api/proto/banyandb/database/v1/schema.pb.go | 872 +++--
api/proto/banyandb/database/v1/schema.proto | 62 +-
api/proto/banyandb/measure/v1/query.pb.go | 627 ++++
api/proto/banyandb/measure/v1/query.proto | 69 +
api/proto/banyandb/measure/v1/rpc.pb.go | 126 +
.../v1/common.proto => measure/v1/rpc.proto} | 27 +-
api/proto/banyandb/measure/v1/rpc_grpc.pb.go | 207 ++
api/proto/banyandb/measure/v1/topn.pb.go | 520 +++
api/proto/banyandb/measure/v1/topn.proto | 66 +
api/proto/banyandb/measure/v1/write.pb.go | 350 ++
api/proto/banyandb/measure/v1/write.proto | 48 +
api/proto/banyandb/model/v1/common.pb.go | 178 +-
api/proto/banyandb/model/v1/common.proto | 9 +
api/proto/banyandb/model/v1/query.pb.go | 414 ++-
api/proto/banyandb/model/v1/query.proto | 24 +-
api/proto/banyandb/stream/v1/query.pb.go | 169 +-
api/proto/banyandb/stream/v1/query.proto | 8 +-
api/proto/banyandb/stream/v1/rpc.pb.go | 2 +-
api/proto/banyandb/stream/v1/write.pb.go | 2 +-
banyand/internal/cmd/standalone.go | 4 +-
banyand/liaison/grpc/registry.go | 294 ++
banyand/liaison/grpc/registry_test.go | 187 ++
banyand/liaison/grpc/server.go | 37 +-
banyand/liaison/grpc/stream_test.go | 32 +-
banyand/liaison/liaison.go | 5 +-
banyand/metadata/metadata.go | 93 +-
banyand/metadata/metadata_test.go | 38 +-
banyand/metadata/schema/etcd.go | 502 +++
banyand/metadata/schema/etcd_test.go | 375 +++
banyand/metadata/schema/schema.go | 49 +-
banyand/metadata/schema/sw.go | 139 -
banyand/metadata/schema/sw_test.go | 73 -
.../{data => testdata}/index_rule_binding.json | 0
.../index_rules/db.instance.json | 0
.../{data => testdata}/index_rules/db.type.json | 0
.../{data => testdata}/index_rules/duration.json | 0
.../index_rules/endpoint_id.json | 0
.../index_rules/http.method.json | 0
.../{data => testdata}/index_rules/mq.broker.json | 0
.../{data => testdata}/index_rules/mq.queue.json | 0
.../{data => testdata}/index_rules/mq.topic.json | 0
.../index_rules/status_code.json | 0
.../{data => testdata}/index_rules/trace_id.json | 0
.../metadata/schema/{data => testdata}/stream.json | 12 +-
banyand/query/processor.go | 17 +-
banyand/query/processor_test.go | 25 +-
banyand/query/query.go | 5 +-
banyand/stream/index.go | 2 +-
banyand/stream/service.go | 6 +-
banyand/stream/stream.go | 2 +-
banyand/stream/stream_query.go | 2 +-
banyand/stream/stream_query_test.go | 17 +-
banyand/stream/stream_write.go | 2 +-
banyand/stream/stream_write_test.go | 22 +-
banyand/tsdb/series_seek.go | 10 +-
banyand/tsdb/series_seek_sort.go | 10 +-
go.mod | 3 +
go.sum | 214 +-
pkg/index/index.go | 2 +-
pkg/index/inverted/inverted.go | 8 +-
pkg/index/inverted/mem.go | 6 +-
pkg/index/iterator.go | 8 +-
pkg/index/lsm/search.go | 4 +-
pkg/index/testcases/duration.go | 30 +-
pkg/pb/v1/query.go | 8 +-
pkg/query/logical/analyzer.go | 19 +-
pkg/query/logical/analyzer_test.go | 124 +-
pkg/query/logical/common.go | 4 +-
pkg/query/logical/common_test.go | 21 +-
pkg/query/logical/plan_execution_test.go | 151 +-
pkg/query/logical/plan_orderby.go | 36 +-
pkg/query/logical/schema.go | 2 +-
pkg/test/etcd.go | 100 +
.../test/testdata}/index_rule_binding.json | 0
.../test/testdata}/index_rules/db.instance.json | 0
.../test/testdata}/index_rules/db.type.json | 0
.../test/testdata}/index_rules/duration.json | 0
.../test/testdata}/index_rules/endpoint_id.json | 0
.../test/testdata}/index_rules/http.method.json | 0
.../test/testdata}/index_rules/mq.broker.json | 0
.../test/testdata}/index_rules/mq.queue.json | 0
.../test/testdata}/index_rules/mq.topic.json | 0
.../test/testdata}/index_rules/status_code.json | 0
.../test/testdata}/index_rules/trace_id.json | 0
.../schema/data => pkg/test/testdata}/stream.json | 12 +-
scripts/build/base.mk | 35 +-
95 files changed, 10348 insertions(+), 1136 deletions(-)