Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[ISSUE #2124] feat:support polaris router ability #2132

Merged
merged 6 commits into from
Nov 26, 2022
Merged

[ISSUE #2124] feat:support polaris router ability #2132

Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
6643278
feat:support polaris router ability
chuntaojun Nov 22, 2022
ecd21cc
feat:support polaris router ability
chuntaojun Nov 22, 2022
2ce51b0
chore:update polaris-go version to 1.3.0-alpha
chuntaojun Nov 24, 2022
98b059e
style:fix code style
chuntaojun Nov 26, 2022
f520903
style:fix code style
chuntaojun Nov 26, 2022
dd8308e
style:fix code style
chuntaojun Nov 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
feat:support polaris router ability
  • Loading branch information
@chuntaojun
chuntaojun committed Nov 22, 2022
commit ecd21ccaabff883f75fc88fe8a91297ba72fea72
6 changes: 3 additions & 3 deletions cluster/router/polaris/router.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,7 @@ func (p *polarisRouter) buildRouteRequest(svc string, url *common.URL,
invoaction protocol.Invocation) (polaris.ProcessRoutersRequest, error) {

routeReq := polaris.ProcessRoutersRequest{
model.ProcessRoutersRequest{
ProcessRoutersRequest: model.ProcessRoutersRequest{
SourceService: model.ServiceInfo{
Metadata: map[string]string{},
},
Expand Down Expand Up @@ -241,7 +241,7 @@ func collectRouteLabels(routings []*v1.Route) []string {

func (p *polarisRouter) buildInstanceMap(svc string) map[string]model.Instance {
resp, err := p.consumerApi.GetAllInstances(&polaris.GetAllInstancesRequest{
model.GetAllInstancesRequest{
GetAllInstancesRequest: model.GetAllInstancesRequest{
Service: svc,
Namespace: remotingpolaris.GetNamespace(),
},
Expand Down Expand Up @@ -295,7 +295,7 @@ func (p *polarisRouter) Notify(invokers []protocol.Invoker) {
}

_, err = p.consumerApi.GetAllInstances(&polaris.GetAllInstancesRequest{
model.GetAllInstancesRequest{
GetAllInstancesRequest: model.GetAllInstancesRequest{
Service: service,
Namespace: remotingpolaris.GetNamespace(),
},
Expand Down