From f1b670972216afed1f5aa634dcf4551c7ef8353c Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Mon, 5 Aug 2019 17:47:50 +0100 Subject: [PATCH] Fix breaking api changes --- router/handler/router.go | 2 +- router/service/service.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/router/handler/router.go b/router/handler/router.go index 1b02b939..a7571024 100644 --- a/router/handler/router.go +++ b/router/handler/router.go @@ -44,7 +44,7 @@ func (r *Router) Lookup(ctx context.Context, req *pb.LookupRequest, resp *pb.Loo return nil } -func (r *Router) Advertise(ctx context.Context, req *pb.AdvertiseRequest, stream pb.Router_AdvertiseStream) error { +func (r *Router) Advertise(ctx context.Context, req *pb.Request, stream pb.Router_AdvertiseStream) error { advertChan, err := r.Router.Advertise() if err != nil { return errors.InternalServerError("go.micro.router", "failed to get adverts: %v", err) diff --git a/router/service/service.go b/router/service/service.go index cdae90e5..b06de9c8 100644 --- a/router/service/service.go +++ b/router/service/service.go @@ -145,7 +145,7 @@ func (s *svc) Advertise() (<-chan *router.Advert, error) { switch status.Code { case router.Running, router.Advertising: - stream, err := s.router.Advertise(context.Background(), &pb.AdvertiseRequest{}, s.callOpts...) + stream, err := s.router.Advertise(context.Background(), &pb.Request{}, s.callOpts...) if err != nil { return nil, fmt.Errorf("failed getting advert stream: %s", err) }