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/10/19 04:27:50 UTC
[skywalking-banyandb] branch api-measure updated (78ae41d ->
e73decc)
This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch api-measure
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git.
from 78ae41d Support to generate topN and bottomN statistics at the same time.
add be066f1 Feat: metadata registry with embedded etcd (#55)
add 9760740 Merge remote-tracking branch 'origin/main' into api-measure
add e73decc Support in operation in query criteria
No new revisions were added by this update.
Summary of changes:
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 | 2 +-
api/proto/banyandb/model/v1/common.pb.go | 2 +-
api/proto/banyandb/model/v1/query.pb.go | 2 +-
api/proto/banyandb/model/v1/query.proto | 2 +
api/proto/banyandb/stream/v1/query.pb.go | 2 +-
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 | 0
banyand/query/processor.go | 17 +-
banyand/query/processor_test.go | 21 +-
banyand/query/query.go | 5 +-
banyand/stream/service.go | 2 +-
banyand/stream/stream_query_test.go | 11 +-
banyand/stream/stream_write_test.go | 22 +-
go.mod | 3 +
go.sum | 214 +-
pkg/query/logical/analyzer.go | 19 +-
pkg/query/logical/analyzer_test.go | 116 +-
pkg/query/logical/common_test.go | 21 +-
pkg/query/logical/plan_execution_test.go | 141 +-
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 +-
67 files changed, 7077 insertions(+), 461 deletions(-)
create mode 100644 api/proto/banyandb/database/v1/rpc.pb.go
create mode 100644 api/proto/banyandb/database/v1/rpc.proto
create mode 100644 api/proto/banyandb/database/v1/rpc_grpc.pb.go
create mode 100644 banyand/liaison/grpc/registry.go
create mode 100644 banyand/liaison/grpc/registry_test.go
create mode 100644 banyand/metadata/schema/etcd.go
create mode 100644 banyand/metadata/schema/etcd_test.go
delete mode 100644 banyand/metadata/schema/sw.go
delete mode 100644 banyand/metadata/schema/sw_test.go
copy banyand/metadata/schema/{data => testdata}/index_rule_binding.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/db.instance.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/db.type.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/duration.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/endpoint_id.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/http.method.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/mq.broker.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/mq.queue.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/mq.topic.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/status_code.json (100%)
copy banyand/metadata/schema/{data => testdata}/index_rules/trace_id.json (100%)
copy banyand/metadata/schema/{data => testdata}/stream.json (100%)
create mode 100644 pkg/test/etcd.go
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rule_binding.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/db.instance.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/db.type.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/duration.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/endpoint_id.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/http.method.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/mq.broker.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/mq.queue.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/mq.topic.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/status_code.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/index_rules/trace_id.json (100%)
rename {banyand/metadata/schema/data => pkg/test/testdata}/stream.json (91%)