Versions in this module Expand all Collapse all v0 v0.3.1 Jun 6, 2022 v0.3.0 Mar 22, 2022 Changes in this version + func NewFrame(payload []byte) interface v0.2.0 Dec 20, 2019 Changes in this version + func Codec() grpc.Codec + func CodecWithParent(fallback grpc.Codec) grpc.Codec + func RegisterService(server *grpc.Server, director StreamDirector, serviceName string, ...) + func TransparentHandler(director StreamDirector, options ...Option) grpc.StreamHandler + type Backend interface + AppendInfo func(streaming bool, resp []byte) ([]byte, error) + BuildError func(streaming bool, err error) ([]byte, error) + GetConnection func(ctx context.Context) (context.Context, *grpc.ClientConn, error) + String func() string + type Mode int + const One2Many + const One2One + type Option func(*handlerOptions) + func WithMethodNames(methodNames ...string) Option + func WithStreamedDetector(detector StreamedDetectorFunc) Option + func WithStreamedMethodNames(streamedMethodNames ...string) Option + type ServerStreamWrapper struct + func (wrapper *ServerStreamWrapper) SendHeader(md metadata.MD) error + func (wrapper *ServerStreamWrapper) SendMsg(m interface{}) error + func (wrapper *ServerStreamWrapper) SetHeader(md metadata.MD) error + func (wrapper *ServerStreamWrapper) SetTrailer(md metadata.MD) + type SingleBackend struct + GetConn func(ctx context.Context) (context.Context, *grpc.ClientConn, error) + func (sb *SingleBackend) AppendInfo(streaming bool, resp []byte) ([]byte, error) + func (sb *SingleBackend) BuildError(streaming bool, err error) ([]byte, error) + func (sb *SingleBackend) GetConnection(ctx context.Context) (context.Context, *grpc.ClientConn, error) + func (sb *SingleBackend) String() string + type StreamDirector func(ctx context.Context, fullMethodName string) (Mode, []Backend, error) + type StreamedDetectorFunc func(fullMethodName string) bool
Go to main page