Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ToNextResolver = errors.New("to next resolver")
)
Functions ¶
func AsContextedAnyResolver ¶
func AsContextedAnyResolver(ctx context.Context, in RuntimeProtoStore) jsonpb.AnyResolver
Types ¶
type ProxyServer ¶
type ProxyServer struct {
// contains filtered or unexported fields
}
ProxyServer is TODO: treat as a real gRPC server.
func (*ProxyServer) Invoke ¶
func (ps *ProxyServer) Invoke(ctx *Context) (proto.Message, *metadataSet, error)
func (*ProxyServer) Meta ¶
func (p *ProxyServer) Meta() map[string]string
func (*ProxyServer) Name ¶
func (p *ProxyServer) Name() string
func (*ProxyServer) ServeHTTP ¶
func (ps *ProxyServer) ServeHTTP(ctx *gin.Context)
type ResolveOnceRequest ¶
type RuntimeProtoStore ¶
type RuntimeServiceResolver ¶
type RuntimeServiceResolver interface { ResolveOnce(context.Context, *ResolveOnceRequest) (string, error) Name() string }
func ChainDefaultResolver ¶
func ChainDefaultResolver(in ...RuntimeServiceResolver) RuntimeServiceResolver
type ServerOpt ¶
type ServerOpt func(*ProxyServer)
func SetProtoStore ¶
func SetProtoStore(in RuntimeProtoStore) ServerOpt
func SetResolver ¶
func SetResolver(in RuntimeServiceResolver) ServerOpt
Click to show internal directories.
Click to hide internal directories.