Add proxy string method

This commit is contained in:
Asim Aslam 2019-12-16 15:18:20 +00:00
parent 303adca500
commit 1ea6390eae
4 changed files with 14 additions and 0 deletions

View File

@ -136,6 +136,10 @@ func (p *Proxy) ServeRequest(ctx context.Context, req server.Request, rsp server
} }
} }
func (p *Proxy) String() string {
return "grpc"
}
// NewProxy returns a new grpc proxy server // NewProxy returns a new grpc proxy server
func NewProxy(opts ...proxy.Option) proxy.Proxy { func NewProxy(opts ...proxy.Option) proxy.Proxy {
var options proxy.Options var options proxy.Options

View File

@ -188,6 +188,10 @@ func (p *Proxy) ServeRequest(ctx context.Context, req server.Request, rsp server
} }
} }
func (p *Proxy) String() string {
return "http"
}
// NewSingleHostProxy returns a router which sends requests to a single http backend // NewSingleHostProxy returns a router which sends requests to a single http backend
func NewSingleHostProxy(url string) proxy.Proxy { func NewSingleHostProxy(url string) proxy.Proxy {
return &Proxy{ return &Proxy{

View File

@ -521,6 +521,10 @@ func (p *Proxy) serveRequest(ctx context.Context, link client.Client, service, e
} }
} }
func (p *Proxy) String() string {
return "mucp"
}
// NewSingleHostProxy returns a proxy which sends requests to a single backend // NewSingleHostProxy returns a proxy which sends requests to a single backend
func NewSingleHostProxy(endpoint string) *Proxy { func NewSingleHostProxy(endpoint string) *Proxy {
return &Proxy{ return &Proxy{

View File

@ -13,6 +13,8 @@ type Proxy interface {
ProcessMessage(context.Context, server.Message) error ProcessMessage(context.Context, server.Message) error
// ServeRequest handles inbound requests // ServeRequest handles inbound requests
ServeRequest(context.Context, server.Request, server.Response) error ServeRequest(context.Context, server.Request, server.Response) error
// Name of the proxy protocol
String() string
} }
var ( var (