api

Documentation

Index

• type Config
• type Service
  • func NewService(network net.Net, conf Config) (*Service, error)
  • func (s *Service) Close() error
  • func (s *Service) Create(_ context.Context, req *pb.CreateRequest) (*pb.CreateReply, error)
  • func (s *Service) Delete(_ context.Context, req *pb.DeleteRequest) (*pb.DeleteReply, error)
  • func (s *Service) Find(_ context.Context, req *pb.FindRequest) (*pb.FindReply, error)
  • func (s *Service) FindByID(_ context.Context, req *pb.FindByIDRequest) (*pb.FindByIDReply, error)
  • func (s *Service) GetDBInfo(ctx context.Context, req *pb.GetDBInfoRequest) (*pb.GetDBInfoReply, error)
  • func (s *Service) Has(_ context.Context, req *pb.HasRequest) (*pb.HasReply, error)
  • func (s *Service) Listen(req *pb.ListenRequest, server pb.API_ListenServer) error
  • func (s *Service) NewCollection(_ 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(_ 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 net.Net, conf Config) (*Service, error)

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

func (*Service) Close

func (s *Service) Close() error

Close the service and the db manager.

func (*Service) Create

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

Create adds a new instance of a collection to a db.

func (*Service) Delete

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

func (*Service) Find

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

func (*Service) FindByID

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

func (*Service) GetDBInfo

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

GetDBInfo returns db addresses and keys.

func (*Service) Has

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

func (*Service) Listen

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

Listen returns a stream of instances, trigged by a local or remote state change.

func (*Service) NewCollection

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

NewCollection registers a JSON schema with a db.

func (*Service) NewDB

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

NewDB adds a new db into the manager.

func (*Service) NewDBFromAddr

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

NewDBFromAddr adds a new db into the manager from an existing address.

func (*Service) ReadTransaction

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

func (*Service) Save

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

func (*Service) WriteTransaction

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