grpchan

Oct 29, 2025

Changes in this version

+ func InterceptClientConnStream(ch grpc.ClientConnInterface, streamInt ...grpc.StreamClientInterceptor) grpc.ClientConnInterface

+ func InterceptClientConnUnary(ch grpc.ClientConnInterface, unaryInt ...grpc.UnaryClientInterceptor) grpc.ClientConnInterface

+ func WithStreamInterceptors(reg grpc.ServiceRegistrar, streamInt ...grpc.StreamServerInterceptor) grpc.ServiceRegistrar

+ func WithUnaryInterceptors(reg grpc.ServiceRegistrar, unaryInt ...grpc.UnaryServerInterceptor) grpc.ServiceRegistrar

Dec 3, 2021

Changes in this version

+ func InterceptClientConn(ch grpc.ClientConnInterface, unaryInt grpc.UnaryClientInterceptor, ...) grpc.ClientConnInterface

type HandlerMap

+ func (m HandlerMap) GetServiceInfo() map[string]grpc.ServiceInfo

+ type WrappedClientConn interface

+ Unwrap func() grpc.ClientConnInterface

Mar 26, 2019

Changes in this version

+ func InterceptServer(svcDesc *grpc.ServiceDesc, unaryInt grpc.UnaryServerInterceptor, ...) *grpc.ServiceDesc

+ type Channel interface

+ Invoke func(ctx context.Context, methodName string, req, resp interface{}, ...) error

+ NewStream func(ctx context.Context, desc *grpc.StreamDesc, methodName string, ...) (grpc.ClientStream, error)

+ func InterceptChannel(ch Channel, unaryInt grpc.UnaryClientInterceptor, ...) Channel

+ type HandlerMap map[string]service

+ func (r HandlerMap) ForEach(fn func(desc *grpc.ServiceDesc, svr interface{}))

+ func (r HandlerMap) QueryService(name string) (*grpc.ServiceDesc, interface{})

+ func (r HandlerMap) RegisterService(desc *grpc.ServiceDesc, h interface{})

+ type ServiceRegistry interface

+ RegisterService func(desc *grpc.ServiceDesc, srv interface{})

+ func WithInterceptor(reg ServiceRegistry, unaryInt grpc.UnaryServerInterceptor, ...) ServiceRegistry