2019-08-13 15:21:51 +01:00
|
|
|
// Package mux provides proxy muxing
|
|
|
|
package mux
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"sync"
|
|
|
|
|
2019-12-04 12:27:30 +00:00
|
|
|
"github.com/micro/go-micro/debug/service/handler"
|
2019-08-13 15:21:51 +01:00
|
|
|
"github.com/micro/go-micro/proxy"
|
|
|
|
"github.com/micro/go-micro/server"
|
|
|
|
)
|
|
|
|
|
2019-08-15 08:47:32 +01:00
|
|
|
// Server is a proxy muxer that incudes the use of the DefaultHandler
|
2019-08-13 15:21:51 +01:00
|
|
|
type Server struct {
|
|
|
|
// name of service
|
|
|
|
Name string
|
|
|
|
// Proxy handler
|
|
|
|
Proxy proxy.Proxy
|
|
|
|
}
|
|
|
|
|
|
|
|
var (
|
|
|
|
once sync.Once
|
|
|
|
)
|
|
|
|
|
2019-11-25 16:31:43 +00:00
|
|
|
func (s *Server) ProcessMessage(ctx context.Context, msg server.Message) error {
|
|
|
|
if msg.Topic() == s.Name {
|
|
|
|
return server.DefaultRouter.ProcessMessage(ctx, msg)
|
|
|
|
}
|
|
|
|
return s.Proxy.ProcessMessage(ctx, msg)
|
|
|
|
}
|
|
|
|
|
2019-08-13 15:21:51 +01:00
|
|
|
func (s *Server) ServeRequest(ctx context.Context, req server.Request, rsp server.Response) error {
|
|
|
|
if req.Service() == s.Name {
|
|
|
|
return server.DefaultRouter.ServeRequest(ctx, req, rsp)
|
|
|
|
}
|
|
|
|
return s.Proxy.ServeRequest(ctx, req, rsp)
|
|
|
|
}
|
|
|
|
|
|
|
|
func New(name string, p proxy.Proxy) *Server {
|
|
|
|
// only register this once
|
|
|
|
once.Do(func() {
|
2019-12-02 14:55:35 +00:00
|
|
|
server.DefaultRouter.Handle(
|
|
|
|
server.DefaultRouter.NewHandler(
|
|
|
|
handler.DefaultHandler,
|
|
|
|
server.InternalHandler(true),
|
|
|
|
),
|
2019-08-13 15:21:51 +01:00
|
|
|
)
|
|
|
|
})
|
|
|
|
|
|
|
|
return &Server{
|
2019-08-15 08:47:32 +01:00
|
|
|
Name: name,
|
2019-08-13 15:21:51 +01:00
|
|
|
Proxy: p,
|
|
|
|
}
|
|
|
|
}
|