Documentation ¶
Index ¶
Constants ¶
View Source
const ( // InitialWindowSize window size, default 128 MB. InitialWindowSize int32 = 128 << 20 // InitialConnWindowSize connection window size, default 64 MB. InitialConnWindowSize int32 = 64 << 20 // ReadBufferSize buffer size, default 32 MB. ReadBufferSize = 32 << 20 // WriteBufferSize write buffer size, default 32 MB. WriteBufferSize = 32 << 20 )
View Source
const ( // MaxRecvMsgSize max message size MaxRecvMsgSize = 1024 * 1024 * 1024 // MaxConcurrentStreams max concurrent MaxConcurrentStreams = 1000 // GRPCTIMEOUT grpc timeout GRPCTIMEOUT = 20 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HttpServer ¶
type HttpServer struct {
// contains filtered or unexported fields
}
HttpServer defines gRPC-Gateway for forwarding http requests
func NewHttpServer ¶
func NewHttpServer(conf *config.ExecutorConf) (*HttpServer, error)
NewHttpServer initiates gRPC-Gateway, allowCROS is used to determine whether to allow cross-domain requests
type Server ¶
Server defines grpc server and http server
func New ¶
func New(conf *config.ExecutorConf) (*Server, error)
New creates GRPC and HTTP server which has no service registered and has not started to accept requests yet.
func (*Server) StartGrpcServe ¶
startGrpcServe runs GerpcServer, block go-routine until get Stop signal
Click to show internal directories.
Click to hide internal directories.