api

Documentation

Index

• type Config
• type Service
  • 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) 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) 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) 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) WriteTransaction(stream pb.API_WriteTransactionServer) error

Types

type Config

type Config struct {
	RepoPath string
	Debug    bool
}

Config specifies server settings.

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service is a gRPC service for a DB manager.

func NewService

func NewService(network app.Net, conf Config) (*Service, error)

NewService starts and returns a new service with the given network. The network is *not* managed by the server.

func (*Service) Close

func (s *Service) Close() error

func (*Service) Create

func (s *Service) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateReply, error)

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteReply, error)

func (*Service) Find

func (s *Service) Find(ctx context.Context, req *pb.FindRequest) (*pb.FindReply, error)

func (*Service) FindByID

func (s *Service) FindByID(ctx context.Context, req *pb.FindByIDRequest) (*pb.FindByIDReply, error)

func (*Service) GetDBInfo

func (s *Service) GetDBInfo(ctx context.Context, req *pb.GetDBInfoRequest) (*pb.GetDBInfoReply, error)

func (*Service) GetToken

func (s *Service) GetToken(server pb.API_GetTokenServer) error

func (*Service) Has

func (s *Service) Has(ctx context.Context, req *pb.HasRequest) (*pb.HasReply, error)

func (*Service) Listen

func (s *Service) Listen(req *pb.ListenRequest, server pb.API_ListenServer) error

func (*Service) NewCollection

func (s *Service) NewCollection(ctx context.Context, req *pb.NewCollectionRequest) (*pb.NewCollectionReply, error)

func (*Service) NewDB

func (s *Service) NewDB(ctx context.Context, req *pb.NewDBRequest) (*pb.NewDBReply, error)

func (*Service) NewDBFromAddr

func (s *Service) NewDBFromAddr(ctx context.Context, req *pb.NewDBFromAddrRequest) (*pb.NewDBReply, error)

func (*Service) ReadTransaction

func (s *Service) ReadTransaction(stream pb.API_ReadTransactionServer) error

func (*Service) Save

func (s *Service) Save(ctx context.Context, req *pb.SaveRequest) (*pb.SaveReply, error)

func (*Service) WriteTransaction

func (s *Service) WriteTransaction(stream pb.API_WriteTransactionServer) error