api

Documentation

Overview

Package api contains the over-the-wire gRPC server for PranaDB.

Index

• type Server
  • func NewAPIServer(metaController *meta.Controller, ce *command.Executor, ...) *Server
  • func (s *Server) ExecuteStatement(in *service.ExecuteStatementRequest, ...) error
  • func (s *Server) GetListenAddress() string
  • func (s *Server) RegisterProtobufs(ctx context.Context, request *service.RegisterProtobufsRequest) (*emptypb.Empty, error)
  • func (s *Server) Start() error
  • func (s *Server) Stop() error

Types

type Server

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

func NewAPIServer

func NewAPIServer(metaController *meta.Controller, ce *command.Executor, protobufs *protolib.ProtoRegistry, cfg conf.Config) *Server

func (*Server) ExecuteStatement

func (s *Server) ExecuteStatement(in *service.ExecuteStatementRequest,
	stream service.PranaDBService_ExecuteStatementServer) error

func (*Server) GetListenAddress

func (s *Server) GetListenAddress() string

func (*Server) RegisterProtobufs

func (s *Server) RegisterProtobufs(ctx context.Context, request *service.RegisterProtobufsRequest) (*emptypb.Empty, error)

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop() error