Documentation
¶
Overview ¶
Package nphttp2 transport powered by netpoll
Index ¶
- func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory
- func NewConnPool(remoteService string, size uint32, connOpts grpc.ConnectOptions) *connPool
- func NewStream(ctx context.Context, svcInfo *serviceinfo.ServiceInfo, conn net.Conn, ...) streaming.Stream
- func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory
- type GRPCConn
- type Streamer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCliTransHandlerFactory ¶
func NewCliTransHandlerFactory() remote.ClientTransHandlerFactory
NewCliTransHandlerFactory ...
func NewConnPool ¶
func NewConnPool(remoteService string, size uint32, connOpts grpc.ConnectOptions) *connPool
NewConnPool ...
func NewStream ¶
func NewStream(ctx context.Context, svcInfo *serviceinfo.ServiceInfo, conn net.Conn, handler remote.TransReadWriter, ) streaming.Stream
NewStream ...
func NewSvrTransHandlerFactory ¶
func NewSvrTransHandlerFactory() remote.ServerTransHandlerFactory
NewSvrTransHandlerFactory ...
Types ¶
type GRPCConn ¶ added in v0.3.3
type GRPCConn interface {
net.Conn
// WriteFrame set header and data buffer into frame with nocopy
WriteFrame(hdr, data []byte) (n int, err error)
// ReadFrame read a frame and return header and payload data
ReadFrame() (hdr, data []byte, err error)
}
GRPCConn implement WriteFrame and ReadFrame
type Streamer ¶
type Streamer func(ctx context.Context, svcInfo serviceinfo.ServiceInfo, conn net.Conn, handler remote.TransReadWriter) streaming.Stream
Streamer Stream creator
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package codes defines the canonical error codes used by gRPC.
|
Package codes defines the canonical error codes used by gRPC. |
|
The files in grpc package are forked from gRPC[github.com/grpc/grpc-go], and we keep the original Copyright[Copyright 2017 gRPC authors] and License of gRPC for those files.
|
The files in grpc package are forked from gRPC[github.com/grpc/grpc-go], and we keep the original Copyright[Copyright 2017 gRPC authors] and License of gRPC for those files. |
|
syscall
Package syscall provides functionalities that grpc uses to get low-level operating system stats/info.
|
Package syscall provides functionalities that grpc uses to get low-level operating system stats/info. |
|
testutils/leakcheck
Package leakcheck contains functions to check leaked goroutines.
|
Package leakcheck contains functions to check leaked goroutines. |
|
Package metadata define the structure of the metadata supported by gRPC library.
|
Package metadata define the structure of the metadata supported by gRPC library. |
|
Package status implements errors returned by gRPC.
|
Package status implements errors returned by gRPC. |
Click to show internal directories.
Click to hide internal directories.