server

Sep 18, 2023

Changes in this version

+ type ClientConnCloser interface

+ Close func() error

May 27, 2022

Changes in this version

+ var ReqBufferSize = 1

Feb 2, 2022

Changes in this version

+ func LoadGlobalServiceMap() map[string]*ServiceMethod

+ func LoadServiceMap(files *protoregistry.Files) map[string]*ServiceMethod

+ type Server struct

+ func New(dialer TargetDialer, authorizer *rpcauth.Authorizer) *Server

+ func NewWithServiceMap(dialer TargetDialer, authorizer *rpcauth.Authorizer, ...) *Server

+ func (s *Server) Proxy(stream pb.Proxy_ProxyServer) error

+ func (s *Server) Register(sr grpc.ServiceRegistrar)

+ type ServiceMethod struct

+ func (s *ServiceMethod) ClientStreams() bool

+ func (s *ServiceMethod) FullName() string

+ func (s *ServiceMethod) NewReply() proto.Message

+ func (s *ServiceMethod) NewRequest() proto.Message

+ func (s *ServiceMethod) ServerStreams() bool

+ func (s *ServiceMethod) StreamDesc() *grpc.StreamDesc

+ type TargetDialer interface

+ DialContext func(ctx context.Context, target string) (grpc.ClientConnInterface, error)

+ func NewDialer(opts ...grpc.DialOption) TargetDialer

+ type TargetStream struct

+ func NewTargetStream(ctx context.Context, target string, dialer TargetDialer, method *ServiceMethod) (*TargetStream, error)

+ func (s *TargetStream) ClientCancel()

+ func (s *TargetStream) CloseSend()

+ func (s *TargetStream) CloseWith(err error)

+ func (s *TargetStream) Method() string

+ func (s *TargetStream) NewRequest() proto.Message

+ func (s *TargetStream) PeerAuthInfo() *rpcauth.PeerAuthInput

+ func (s *TargetStream) Run(replyChan chan *pb.ProxyReply)

+ func (s *TargetStream) Send(req proto.Message) error

+ func (s *TargetStream) StreamID() uint64

+ func (s *TargetStream) String() string

+ func (s *TargetStream) Target() string

+ type TargetStreamSet struct

+ func NewTargetStreamSet(serviceMethods map[string]*ServiceMethod, dialer TargetDialer, ...) *TargetStreamSet

+ func (t *TargetStreamSet) Add(ctx context.Context, req *pb.StartStream, replyChan chan *pb.ProxyReply, ...) error

+ func (t *TargetStreamSet) ClientCancel(req *pb.ClientCancel) error

+ func (t *TargetStreamSet) ClientClose(req *pb.ClientClose) error

+ func (t *TargetStreamSet) ClientCloseAll()

+ func (t *TargetStreamSet) Remove(streamID uint64)

+ func (t *TargetStreamSet) Send(ctx context.Context, req *pb.StreamData) error

+ func (t *TargetStreamSet) Wait()