service

package

v1.0.6 Latest Latest Go to latest Published: Jul 7, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Service struct {
	dbs.FlyDBServiceServer
	Addr string // db server address
	// contains filtered or unexported fields
}

Service is a grpc Service for db

func NewService(addr string, db *engine.DB) *Service

NewService returns a new grpc Service

func (s *Service) Del(ctx context.Context, req *dbs.DelRequest) (*dbs.DelResponse, error)

Del is a grpc s for del

func (s *Service) Get(ctx context.Context, req *dbs.GetRequest) (*dbs.GetResponse, error)

Get is a grpc s for get

func (s *Service) IsGrpcServerRunning() bool

IsGrpcServerRunning returns whether the grpc server is running

func (s *Service) Keys(ctx context.Context, req *dbs.KeysRequest) (*dbs.KeysResponse, error)

Keys is a grpc s for keys

func (s *Service) Put(ctx context.Context, req *dbs.PutRequest) (*dbs.PutResponse, error)

Put is a grpc s for put

func (s *Service) StartServer()

StartServer starts a grpc server

func (s *Service) StopServer()