unistack-org/micro
4
0
Fork 3
Code Issues 19 Pull Requests 1 Actions Packages Projects Releases 259 Wiki Activity

Fix breaking api changes

Browse Source
This commit is contained in:
Asim Aslam 2019-08-05 17:47:50 +01:00
parent 4030ccc27b
commit f1b6709722
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
router/handler/router.go
View File

@ -44,7 +44,7 @@ func (r *Router) Lookup(ctx context.Context, req *pb.LookupRequest, resp *pb.Loo
return nil 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() advertChan, err := r.Router.Advertise()
if err != nil { if err != nil {
return errors.InternalServerError("go.micro.router", "failed to get adverts: %v", err) return errors.InternalServerError("go.micro.router", "failed to get adverts: %v", err)

2
router/service/service.go
View File

@ -145,7 +145,7 @@ func (s *svc) Advertise() (<-chan *router.Advert, error) {
switch status.Code { switch status.Code {
case router.Running, router.Advertising: 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 { if err != nil {
return nil, fmt.Errorf("failed getting advert stream: %s", err) return nil, fmt.Errorf("failed getting advert stream: %s", err)
} }