router

Documentation

Index

• Constants
• func MatchCondition(pairs map[string]MatchPair, url *common.URL, param *common.URL, ...) (bool, error)
• func NewConditionRouterFactory() cluster.RouterFactory
• type ConditionRouter
  • func (c *ConditionRouter) MatchThen(url common.URL, param common.URL) (bool, error)
  • func (c *ConditionRouter) MatchWhen(url common.URL, invocation protocol.Invocation) (bool, error)
  • func (c *ConditionRouter) Route(invokers []protocol.Invoker, url common.URL, invocation protocol.Invocation) []protocol.Invoker
• type ConditionRouterFactory
  • func (c ConditionRouterFactory) Router(url *common.URL) (cluster.Router, error)
• type MatchPair

Constants

const (
	ROUTE_PATTERN = `([&!=,]*)\\s*([^&!=,\\s]+)`
	FORCE         = "force"
	PRIORITY      = "priority"
)

Functions

func MatchCondition

func MatchCondition(pairs map[string]MatchPair, url *common.URL, param *common.URL, invocation protocol.Invocation) (bool, error)

MatchCondition MatchCondition

func NewConditionRouterFactory

func NewConditionRouterFactory() cluster.RouterFactory

Types

type ConditionRouter

type ConditionRouter struct {
	Pattern       string
	Url           *common.URL
	Priority      int64
	Force         bool
	WhenCondition map[string]MatchPair
	ThenCondition map[string]MatchPair
}

ConditionRouter condition router struct

func (*ConditionRouter) MatchThen

func (c *ConditionRouter) MatchThen(url common.URL, param common.URL) (bool, error)

MatchThen MatchThen

func (*ConditionRouter) MatchWhen

func (c *ConditionRouter) MatchWhen(url common.URL, invocation protocol.Invocation) (bool, error)

func (*ConditionRouter) Route

func (c *ConditionRouter) Route(invokers []protocol.Invoker, url common.URL, invocation protocol.Invocation) []protocol.Invoker

Router determine the target server list.

type ConditionRouterFactory

type ConditionRouterFactory struct{}

func (ConditionRouterFactory) Router

func (c ConditionRouterFactory) Router(url *common.URL) (cluster.Router, error)

type MatchPair

type MatchPair struct {
	Matches    *gxset.HashSet
	Mismatches *gxset.HashSet
}