This is an automated email from the ASF dual-hosted git repository. hanahmily pushed a commit to branch feat/liasion in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
commit 67d8a41ee7a80ad4adfca6852f2c245e5a3ccdb3 Author: Qiuxia Fan <[email protected]> AuthorDate: Fri Jun 18 16:56:18 2021 +0800 update server info --- banyand/liaison/grpc/grpc.go | 5 +++-- banyand/series/service.go | 17 +++++++++-------- 2 files changed, 12 insertions(+), 10 deletions(-) diff --git a/banyand/liaison/grpc/grpc.go b/banyand/liaison/grpc/grpc.go index c9b804d..58014cf 100644 --- a/banyand/liaison/grpc/grpc.go +++ b/banyand/liaison/grpc/grpc.go @@ -20,11 +20,12 @@ package grpc import ( "context" "fmt" + "net" + "time" + flatbuffers "github.com/google/flatbuffers/go" grpclib "google.golang.org/grpc" "google.golang.org/grpc/encoding" - "net" - "time" v1 "github.com/apache/skywalking-banyandb/api/fbs/v1" "github.com/apache/skywalking-banyandb/banyand/queue" diff --git a/banyand/series/service.go b/banyand/series/service.go index 6c6a6d7..a62c7d0 100644 --- a/banyand/series/service.go +++ b/banyand/series/service.go @@ -20,10 +20,6 @@ package series import ( "bytes" "context" - "time" - - "go.uber.org/multierr" - "github.com/apache/skywalking-banyandb/api/common" "github.com/apache/skywalking-banyandb/api/data" v1 "github.com/apache/skywalking-banyandb/api/fbs/v1" @@ -31,12 +27,15 @@ import ( "github.com/apache/skywalking-banyandb/banyand/series/schema/sw" "github.com/apache/skywalking-banyandb/banyand/storage" "github.com/apache/skywalking-banyandb/pkg/run" + "go.uber.org/multierr" + "time" ) var _ Service = (*service)(nil) type service struct { db storage.Database + addr string } //Methods for query objects in the schema @@ -133,17 +132,19 @@ func (s *service) ScanEntity(traceSeries common.Metadata, startTime, endTime uin } func (s *service) Name() string { - panic("implement me") + return "series" } func (s *service) FlagSet() *run.FlagSet { - panic("implement me") + fs := run.NewFlagSet("series") + fs.StringVarP(&s.addr, "series", "", ":17911", "the address of banyand listens") + return fs } func (s *service) Validate() error { - panic("implement me") + return nil } func (s *service) PreRun() error { - panic("implement me") + return nil }
