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
discard 982bbba fix test case
omit 4f733d4 fix ci
omit da06692 fix check
omit 7c03a2b fix test cases
omit 1c0201b refactor window
omit 15ae5eb fix lint
omit 9ae5ce1 fix lint
omit 8fd8ff3 add lateness and refactor window flush
omit 1e4d566 Merge branch 'main' into simple-streaming-api
omit 687c50f fix async measure write and adjust timebucket logic
omit 1257554 fix sort and simplify iter
omit bc180cf refactor post processor
omit fb59d5d regenerate
omit 8ed1bd3 remove necessary data
omit 8c02c09 add first test
omit 0f4370a add partial timeline impl
omit 4911b45 add test skeleton
omit 7039bd1 fix measure topn
omit fdf5f37 fix lateness check
omit 5e545ab delete snapshot on purge
omit 9c45d3a refactor purge and polish API
omit e527405 add streaming api and topN aggregator
add ebdbb62 add measure and group cmd (#180)
add 49fc864 Add Exist endpoints to all services (#186)
add 1f8e82c Try to create the group if absent (#187)
add f166614 add streaming api and topN aggregator
add 125f83d refactor purge and polish API
add 436c3cc delete snapshot on purge
add 9e996d4 fix lateness check
add c41d9d6 fix measure topn
add 621a235 add test skeleton
add 4468538 add partial timeline impl
add dd41b1a add first test
add ff44f51 remove necessary data
add fef0a60 regenerate
add f675b47 refactor post processor
add 62b83ea fix sort and simplify iter
add 4c69e3e fix async measure write and adjust timebucket logic
add 4f646b8 add lateness and refactor window flush
add be8dbfa fix lint
add e26a3cb fix lint
add 88fb21f refactor window
add 71910de fix test cases
add 3261add fix check
add a5196ca fix ci
add e2edeef fix test case
add fbcf2d0 adjust test cases
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 (982bbba)
\
N -- N -- N refs/heads/simple-streaming-api (fbcf2d0)
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:
api/common/id.go | 13 +
api/proto/banyandb/database/v1/rpc.pb.go | 2660 +++++++++++++-------
api/proto/banyandb/database/v1/rpc.pb.validate.go | 1802 +++++++++++--
api/proto/banyandb/database/v1/rpc.proto | 64 +
api/proto/banyandb/database/v1/rpc_grpc.pb.go | 226 ++
.../openapi/banyandb/database/v1/rpc.swagger.json | 63 +
banyand/liaison/grpc/measure.go | 13 +-
banyand/liaison/grpc/registry.go | 118 +
banyand/liaison/grpc/registry_test.go | 12 +
banyand/liaison/grpc/stream.go | 13 +-
banyand/liaison/http/health.go | 42 +-
banyand/liaison/http/server.go | 37 +-
banyand/query/processor.go | 33 +-
bydbctl/internal/cmd/group.go | 66 +-
bydbctl/internal/cmd/group_test.go | 150 ++
bydbctl/internal/cmd/{stream.go => measure.go} | 74 +-
bydbctl/internal/cmd/measure_test.go | 220 ++
bydbctl/internal/cmd/rest.go | 98 +-
bydbctl/internal/cmd/root.go | 11 +-
bydbctl/internal/cmd/stream.go | 11 +-
bydbctl/internal/cmd/stream_test.go | 230 +-
dist/LICENSE | 2 +-
dist/licenses/license-github.com-ghodss-yaml.txt | 50 -
...license-github.com-xhit-go-str2duration-v2.txt} | 2 +-
docs/api-reference.md | 203 ++
go.mod | 2 +-
go.sum | 3 +-
pkg/schema/metadata.go | 5 +-
pkg/test/helpers/http_health.go | 3 +
pkg/test/setup/setup.go | 10 +-
test/cases/{measure => stream}/data/data.go | 72 +-
test/cases/stream/{ => data}/input/all.yaml | 0
test/cases/stream/{ => data}/input/filter_tag.yaml | 0
.../stream/{ => data}/input/filter_tag_empty.yaml | 0
.../stream/{ => data}/input/global_index.yaml | 0
test/cases/stream/{ => data}/input/having.yaml | 0
.../stream/{ => data}/input/indexed_only.yaml | 0
test/cases/stream/{ => data}/input/less.yaml | 0
test/cases/stream/{ => data}/input/less_eq.yaml | 0
test/cases/stream/{ => data}/input/limit.yaml | 0
test/cases/stream/{ => data}/input/logical.yaml | 0
test/cases/stream/{ => data}/input/offset.yaml | 0
test/cases/stream/{ => data}/input/search.yaml | 0
test/cases/stream/{ => data}/input/sort_desc.yaml | 0
test/cases/stream/{ => data}/testdata/data.json | 0
.../data/testdata/service_cpm_minute_data.json | 0
test/cases/stream/{ => data}/want/all.yaml | 0
test/cases/stream/{ => data}/want/filter_tag.yaml | 0
.../cases/stream/{ => data}/want/global_index.yaml | 0
test/cases/stream/{ => data}/want/having.yaml | 0
.../cases/stream/{ => data}/want/indexed_only.yaml | 0
test/cases/stream/{ => data}/want/less.yaml | 0
test/cases/stream/{ => data}/want/less_eq.yaml | 0
test/cases/stream/{ => data}/want/limit.yaml | 0
test/cases/stream/{ => data}/want/logical.yaml | 0
test/cases/stream/{ => data}/want/offset.yaml | 0
test/cases/stream/{ => data}/want/search.yaml | 0
test/cases/stream/{ => data}/want/sort_desc.yaml | 0
test/cases/stream/stream.go | 129 +-
test/integration/cold_query/query_suite_test.go | 29 +-
test/integration/other/measure_test.go | 2 +-
test/integration/other/property_test.go | 4 +-
test/integration/other/tls_test.go | 2 +-
test/integration/query/query_suite_test.go | 30 +-
64 files changed, 4996 insertions(+), 1508 deletions(-)
create mode 100644 bydbctl/internal/cmd/group_test.go
copy bydbctl/internal/cmd/{stream.go => measure.go} (69%)
create mode 100644 bydbctl/internal/cmd/measure_test.go
delete mode 100644 dist/licenses/license-github.com-ghodss-yaml.txt
copy dist/licenses/{license-golang.org-x-exp.txt =>
license-github.com-xhit-go-str2duration-v2.txt} (99%)
copy test/cases/{measure => stream}/data/data.go (63%)
rename test/cases/stream/{ => data}/input/all.yaml (100%)
rename test/cases/stream/{ => data}/input/filter_tag.yaml (100%)
rename test/cases/stream/{ => data}/input/filter_tag_empty.yaml (100%)
rename test/cases/stream/{ => data}/input/global_index.yaml (100%)
rename test/cases/stream/{ => data}/input/having.yaml (100%)
rename test/cases/stream/{ => data}/input/indexed_only.yaml (100%)
rename test/cases/stream/{ => data}/input/less.yaml (100%)
rename test/cases/stream/{ => data}/input/less_eq.yaml (100%)
rename test/cases/stream/{ => data}/input/limit.yaml (100%)
rename test/cases/stream/{ => data}/input/logical.yaml (100%)
rename test/cases/stream/{ => data}/input/offset.yaml (100%)
rename test/cases/stream/{ => data}/input/search.yaml (100%)
rename test/cases/stream/{ => data}/input/sort_desc.yaml (100%)
rename test/cases/stream/{ => data}/testdata/data.json (100%)
copy test/cases/{measure => stream}/data/testdata/service_cpm_minute_data.json
(100%)
rename test/cases/stream/{ => data}/want/all.yaml (100%)
rename test/cases/stream/{ => data}/want/filter_tag.yaml (100%)
rename test/cases/stream/{ => data}/want/global_index.yaml (100%)
rename test/cases/stream/{ => data}/want/having.yaml (100%)
rename test/cases/stream/{ => data}/want/indexed_only.yaml (100%)
rename test/cases/stream/{ => data}/want/less.yaml (100%)
rename test/cases/stream/{ => data}/want/less_eq.yaml (100%)
rename test/cases/stream/{ => data}/want/limit.yaml (100%)
rename test/cases/stream/{ => data}/want/logical.yaml (100%)
rename test/cases/stream/{ => data}/want/offset.yaml (100%)
rename test/cases/stream/{ => data}/want/search.yaml (100%)
rename test/cases/stream/{ => data}/want/sort_desc.yaml (100%)
