Versions in this module Expand all Collapse all v1 v1.0.1 Oct 17, 2020 Changes in this version + type Config struct + Debug bool + RepoPath string + type Service struct + func NewService(network app.Net, conf Config) (*Service, error) + func (s *Service) Close() error + func (s *Service) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateReply, error) + func (s *Service) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteReply, error) + func (s *Service) DeleteCollection(ctx context.Context, req *pb.DeleteCollectionRequest) (*pb.DeleteCollectionReply, error) + func (s *Service) DeleteDB(ctx context.Context, req *pb.DeleteDBRequest) (*pb.DeleteDBReply, error) + func (s *Service) Find(ctx context.Context, req *pb.FindRequest) (*pb.FindReply, error) + func (s *Service) FindByID(ctx context.Context, req *pb.FindByIDRequest) (*pb.FindByIDReply, error) + func (s *Service) GetCollectionIndexes(ctx context.Context, req *pb.GetCollectionIndexesRequest) (*pb.GetCollectionIndexesReply, error) + func (s *Service) GetCollectionInfo(ctx context.Context, req *pb.GetCollectionInfoRequest) (*pb.GetCollectionInfoReply, error) + func (s *Service) GetDBInfo(ctx context.Context, req *pb.GetDBInfoRequest) (*pb.GetDBInfoReply, error) + func (s *Service) GetToken(server pb.API_GetTokenServer) error + func (s *Service) Has(ctx context.Context, req *pb.HasRequest) (*pb.HasReply, error) + func (s *Service) ListCollections(ctx context.Context, req *pb.ListCollectionsRequest) (*pb.ListCollectionsReply, error) + func (s *Service) ListDBs(ctx context.Context, _ *pb.ListDBsRequest) (*pb.ListDBsReply, error) + func (s *Service) Listen(req *pb.ListenRequest, server pb.API_ListenServer) error + func (s *Service) NewCollection(ctx context.Context, req *pb.NewCollectionRequest) (*pb.NewCollectionReply, error) + func (s *Service) NewDB(ctx context.Context, req *pb.NewDBRequest) (*pb.NewDBReply, error) + func (s *Service) NewDBFromAddr(ctx context.Context, req *pb.NewDBFromAddrRequest) (*pb.NewDBReply, error) + func (s *Service) ReadTransaction(stream pb.API_ReadTransactionServer) error + func (s *Service) Save(ctx context.Context, req *pb.SaveRequest) (*pb.SaveReply, error) + func (s *Service) UpdateCollection(ctx context.Context, req *pb.UpdateCollectionRequest) (*pb.UpdateCollectionReply, error) + func (s *Service) Verify(ctx context.Context, req *pb.VerifyRequest) (*pb.VerifyReply, error) + func (s *Service) WriteTransaction(stream pb.API_WriteTransactionServer) error
Go to main page