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/08/05 13:04:32 UTC
[skywalking-banyandb] branch main updated: Init local pipeline
This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
The following commit(s) were added to refs/heads/main by this push:
new 199c1b0 Init local pipeline
199c1b0 is described below
commit 199c1b0334b8cf4851fe1f1e8b0ebd2bf3f665db
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Thu Aug 5 21:04:09 2021 +0800
Init local pipeline
Signed-off-by: Gao Hongtao <ha...@gmail.com>
---
banyand/queue/queue.go | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/banyand/queue/queue.go b/banyand/queue/queue.go
index 57c7b37..a39f494 100644
--- a/banyand/queue/queue.go
+++ b/banyand/queue/queue.go
@@ -32,5 +32,8 @@ type Queue interface {
}
func NewQueue(_ context.Context, repo discovery.ServiceRepo) (Queue, error) {
- return &local{repo: repo}, nil
+ return &local{
+ repo: repo,
+ local: bus.NewBus(),
+ }, nil
}