server

Documentation

Overview

Package server is the SQLFlow grpc server which connects to database and parse, submit or execute the training and predicting codes.

To generate grpc protobuf code, run the below command:

Index

• type Server
  • func NewServer(run func(string, *sf.DB, string, *pb.Session) *sf.PipeReader, db *sf.DB, ...) *Server
  • func (s *Server) Run(req *pb.Request, stream pb.SQLFlow_RunServer) error

Types

type Server

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

Server is the instance will be used to connect to DB and execute training

func NewServer

func NewServer(run func(string, *sf.DB, string, *pb.Session) *sf.PipeReader, db *sf.DB, modelDir string, enableSession bool) *Server

NewServer returns a server instance

func (*Server) Run

func (s *Server) Run(req *pb.Request, stream pb.SQLFlow_RunServer) error

Run implements `rpc Run (Request) returns (stream Response)`