Skip to content
Snippets Groups Projects
Commit 0ea1e3a0 authored by aliiohs's avatar aliiohs
Browse files

fix

parent 209fcf36
No related branches found
No related tags found
No related merge requests found
......@@ -21,4 +21,4 @@ classes
vendor/
logs/
.vscode/
......@@ -25,7 +25,7 @@ import (
// Extension - Router
type RouterFactory interface {
Router(common.URL) (Router, error)
Router(*common.URL) (Router, error)
}
type Router interface {
......
......@@ -40,14 +40,14 @@ const (
//ConditionRouter condition router struct
type ConditionRouter struct {
Pattern string
Url common.URL
Url *common.URL
Priority int64
Force bool
WhenCondition map[string]MatchPair
ThenCondition map[string]MatchPair
}
func newConditionRouter(url common.URL) (*ConditionRouter, error) {
func newConditionRouter(url *common.URL) (*ConditionRouter, error) {
var (
whenRule string
thenRule string
......
......@@ -54,24 +54,24 @@ func (bi *MockInvoker) GetUrl() common.URL {
return bi.url
}
func getRouteUrl(rule string) common.URL {
func getRouteUrl(rule string) *common.URL {
url, _ := common.NewURL(context.TODO(), "condition://0.0.0.0/com.foo.BarService")
url.AddParam("rule", rule)
url.AddParam("force", "true")
return url
return &url
}
func getRouteUrlWithForce(rule, force string) common.URL {
func getRouteUrlWithForce(rule, force string) *common.URL {
url, _ := common.NewURL(context.TODO(), "condition://0.0.0.0/com.foo.BarService")
url.AddParam("rule", rule)
url.AddParam("force", force)
return url
return &url
}
func getRouteUrlWithNoForce(rule string) common.URL {
func getRouteUrlWithNoForce(rule string) *common.URL {
url, _ := common.NewURL(context.TODO(), "condition://0.0.0.0/com.foo.BarService")
url.AddParam("rule", rule)
return url
return &url
}
func (bi *MockInvoker) IsAvailable() bool {
......
......@@ -32,6 +32,6 @@ type ConditionRouterFactory struct{}
func NewConditionRouterFactory() cluster.RouterFactory {
return ConditionRouterFactory{}
}
func (c ConditionRouterFactory) Router(url common.URL) (cluster.Router, error) {
func (c ConditionRouterFactory) Router(url *common.URL) (cluster.Router, error) {
return newConditionRouter(url)
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment