api

package
Version: v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 5, 2022 License: MIT Imports: 19 Imported by: 3

Documentation

Overview

Package api is all about the DB API. It contains the protobuf definition (under /pb), a Go client (under /client) and a gRPC service for the API backed by the actual DB manager.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Debug bool
}

Config specifies service settings.

type Service added in v0.1.12

type Service struct {
	pb.UnimplementedAPIServer
	// contains filtered or unexported fields
}

Service is a gRPC DB API service backed by a DB manager.

func NewService added in v0.1.12

func NewService(store kt.TxnDatastoreExtended, 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 added in v0.1.12

func (s *Service) Close() error

func (*Service) Create added in v0.1.12

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

func (*Service) Delete added in v0.1.12

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

func (*Service) DeleteCollection added in v0.1.19

func (s *Service) DeleteCollection(ctx context.Context, req *pb.DeleteCollectionRequest) (*pb.DeleteCollectionReply, error)

func (*Service) DeleteDB added in v0.1.15

func (s *Service) DeleteDB(ctx context.Context, req *pb.DeleteDBRequest) (*pb.DeleteDBReply, error)

func (*Service) Find added in v0.1.12

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

func (*Service) FindByID added in v0.1.12

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

func (*Service) GetCollectionIndexes added in v0.1.19

func (s *Service) GetCollectionIndexes(ctx context.Context, req *pb.GetCollectionIndexesRequest) (*pb.GetCollectionIndexesReply, error)

func (*Service) GetCollectionInfo added in v0.1.22

func (s *Service) GetCollectionInfo(ctx context.Context, req *pb.GetCollectionInfoRequest) (*pb.GetCollectionInfoReply, error)

func (*Service) GetDBInfo added in v0.1.12

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

func (*Service) GetToken added in v0.1.13

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

func (*Service) Has added in v0.1.12

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

func (*Service) ListCollections added in v0.1.22

func (s *Service) ListCollections(ctx context.Context, req *pb.ListCollectionsRequest) (*pb.ListCollectionsReply, error)

func (*Service) ListDBs added in v0.1.19

func (s *Service) ListDBs(ctx context.Context, _ *pb.ListDBsRequest) (*pb.ListDBsReply, error)

func (*Service) Listen added in v0.1.12

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

func (*Service) NewCollection added in v0.1.12

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

func (*Service) NewDB added in v0.1.12

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

func (*Service) NewDBFromAddr added in v0.1.12

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

func (*Service) ReadTransaction added in v0.1.12

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

func (*Service) Save added in v0.1.12

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

func (*Service) UpdateCollection added in v0.1.19

func (s *Service) UpdateCollection(ctx context.Context, req *pb.UpdateCollectionRequest) (*pb.UpdateCollectionReply, error)

func (*Service) Verify added in v1.0.0

func (s *Service) Verify(ctx context.Context, req *pb.VerifyRequest) (*pb.VerifyReply, error)

func (*Service) WriteTransaction added in v0.1.12

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

Source Files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL