Documentation
¶
Overview ¶
Package grpc NOTES
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func TransparentHandler ¶
func TransparentHandler(director Director) grpc.StreamHandler
TransparentHandler returns a handler that attempts to proxy all requests that are not registered in the server. The indented use here is as a transparent proxy, where the server doesn't know about the services implemented by the backends. It should be used as a `grpc.UnknownServiceHandler`.
This can *only* be used if the `server` also uses grpcproxy.CodecForServer() ServerOption.
Types ¶
type ClientConn ¶
type ClientConn interface {
Value() *grpc.ClientConn
Close() error
}
ClientConn is a wrapper around a *grpc.ClientConn with closable
type Director ¶
type Director interface {
// Director returns a gRPC ClientConn to be used to forward the call to.
//
// The presence of the `Context` allows for rich filtering, e.g. based on Metadata (headers).
// If no handling is meant to be done, a `codes.NotImplemented` gRPC error should be returned.
//
// The context returned from this function should be the context for the *outgoing* (to backend) call. In case you want
// to forward any Metadata between the inbound request and outbound requests, you should do it manually. However, you
// *must* propagate the cancel function (`context.WithCancel`) of the inbound context to the one returned.
//
// It is worth noting that the Director will be fired *after* all server-side stream interceptors
// are invoked. So decisions around authorization, monitoring etc. are better to be handled there.
Director(ctx context.Context, fullMethodName string) (context.Context, ClientConn, error)
}
Director is a function that returns a gRPC ClientConn to be used to forward the call to.
type FeedServerDirector ¶
type FeedServerDirector struct {
// contains filtered or unexported fields
}
FeedServerDirector is a Director implementation that routes all requests to the upstream feed server.
func NewFeedServerDirector ¶
func NewFeedServerDirector() (*FeedServerDirector, error)
NewFeedServerDirector returns a new FeedServerDirector
func (*FeedServerDirector) Director ¶
func (d *FeedServerDirector) Director(ctx context.Context, fullMethodName string) (context.Context, ClientConn, error)
Director returns a gRPC ClientConn to be used to forward the call to.
func (*FeedServerDirector) Terminate ¶
func (d *FeedServerDirector) Terminate() error
Terminate closes the grpc pool
Source Files