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/06/26 12:33:39 UTC
[skywalking-banyandb] branch simple-streaming-api updated (488e38b -> ed9630e)
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
from 488e38b Merge branch 'main' into simple-streaming-api
add ed9630e refactor flow API
No new revisions were added by this update.
Summary of changes:
dist/LICENSE | 9 +-
...s.txt => license-github.com-emirpasic-gods.txt} | 20 +-
dist/licenses/ui-licenses/license-bindings.txt | 22 --
.../ui-licenses/license-file-uri-to-path.txt | 20 --
dist/licenses/ui-licenses/license-nan.txt | 9 -
pkg/{streaming => flow}/api/priority_queue_set.go | 17 ++
pkg/{streaming => flow}/api/types.go | 73 +++---
pkg/{ => flow}/streaming/api/op.go | 0
pkg/{ => flow}/streaming/api/types.go | 29 +--
pkg/{ => flow}/streaming/api/utils.go | 0
pkg/{streaming/flow => flow/streaming}/flow.go | 51 ++--
.../flow => flow/streaming}/flow_sliding_window.go | 106 ++++----
.../streaming}/flow_sliding_window_test.go | 17 +-
pkg/flow/streaming/flow_test.go | 285 +++++++++++++++++++++
.../flow => flow/streaming}/flow_topn.go | 47 ++--
.../flow => flow/streaming}/flow_topn_test.go | 2 +-
.../flow => flow/streaming}/flow_unary.go | 51 ++--
pkg/{ => flow}/streaming/sink/slice.go | 2 +-
pkg/{ => flow}/streaming/sources/channel.go | 4 +-
pkg/{ => flow}/streaming/sources/channel_test.go | 11 +-
pkg/{ => flow}/streaming/sources/reader.go | 13 +-
pkg/{ => flow}/streaming/sources/reader_test.go | 11 +-
pkg/{ => flow}/streaming/sources/slice.go | 28 +-
pkg/{ => flow}/streaming/sources/slice_test.go | 11 +-
pkg/streaming/flow/flow_test.go | 205 ---------------
ui/LICENSE | 3 -
26 files changed, 570 insertions(+), 476 deletions(-)
copy dist/licenses/{license-github.com-pkg-errors.txt => license-github.com-emirpasic-gods.txt} (58%)
delete mode 100644 dist/licenses/ui-licenses/license-bindings.txt
delete mode 100644 dist/licenses/ui-licenses/license-file-uri-to-path.txt
delete mode 100644 dist/licenses/ui-licenses/license-nan.txt
rename pkg/{streaming => flow}/api/priority_queue_set.go (77%)
copy pkg/{streaming => flow}/api/types.go (54%)
rename pkg/{ => flow}/streaming/api/op.go (100%)
rename pkg/{ => flow}/streaming/api/types.go (77%)
rename pkg/{ => flow}/streaming/api/utils.go (100%)
rename pkg/{streaming/flow => flow/streaming}/flow.go (72%)
rename pkg/{streaming/flow => flow/streaming}/flow_sliding_window.go (74%)
rename pkg/{streaming/flow => flow/streaming}/flow_sliding_window_test.go (80%)
create mode 100644 pkg/flow/streaming/flow_test.go
rename pkg/{streaming/flow => flow/streaming}/flow_topn.go (91%)
rename pkg/{streaming/flow => flow/streaming}/flow_topn_test.go (99%)
rename pkg/{streaming/flow => flow/streaming}/flow_unary.go (65%)
rename pkg/{ => flow}/streaming/sink/slice.go (95%)
rename pkg/{ => flow}/streaming/sources/channel.go (94%)
rename pkg/{ => flow}/streaming/sources/channel_test.go (81%)
rename pkg/{ => flow}/streaming/sources/reader.go (82%)
rename pkg/{ => flow}/streaming/sources/reader_test.go (81%)
rename pkg/{ => flow}/streaming/sources/slice.go (69%)
rename pkg/{ => flow}/streaming/sources/slice_test.go (81%)
delete mode 100644 pkg/streaming/flow/flow_test.go