Versions in this module Expand all Collapse all v0 v0.6.1 Jul 31, 2023 v0.0.4 Jul 31, 2023 Changes in this version + func GRPCHeader(ctx context.Context, md *metadata.MD) context.Context + func GRPCTrailer(ctx context.Context, md *metadata.MD) context.Context + func GetHeaderMetadataFromCtx(ctx context.Context) *metadata.MD + 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 + func SendHeader(ctx context.Context, md metadata.MD) error + func SetHeader(ctx context.Context, md metadata.MD) error + func SetTrailer(ctx context.Context, md metadata.MD) error + type GRPCConn interface + ReadFrame func() (hdr, data []byte, err error) + WriteFrame func(hdr, data []byte) (n int, err error) + func GetServerConn(st streaming.Stream) (GRPCConn, error) + type Streamer func(ctx context.Context, svcInfo serviceinfo.ServiceInfo, conn net.Conn, ...) streaming.Stream + type SvrTrans struct
Go to main page