nphttp2

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
  • func GetServerConn(st streaming.Stream) (GRPCConn, error)
• type Streamer
• type SvrTrans

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

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

func GetServerConn

func GetServerConn(st streaming.Stream) (GRPCConn, error)

type Streamer

type Streamer func(ctx context.Context, svcInfo serviceinfo.ServiceInfo, conn net.Conn,
	handler remote.TransReadWriter) streaming.Stream

Streamer Stream creator

type SvrTrans

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