chain

Documentation

Index

• type RouterChain
  • func NewRouterChain() (*RouterChain, error)
  • func (c *RouterChain) AddRouters(routers []router.PriorityRouter)
  • func (c *RouterChain) Route(url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (c *RouterChain) SetInvokers(invokers []protocol.Invoker)

Types

type RouterChain

type RouterChain struct {
	// contains filtered or unexported fields
}

RouterChain Router chain

func NewRouterChain

func NewRouterChain() (*RouterChain, error)

NewRouterChain init router chain Loop routerFactories and call NewRouter method

func (*RouterChain) AddRouters

func (c *RouterChain) AddRouters(routers []router.PriorityRouter)

AddRouters Add routers to router chain New a array add builtinRouters which is not sorted in RouterChain and routers Sort the array Replace router array in RouterChain

func (*RouterChain) Route

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

Route Loop routers in RouterChain and call Route method to determine the target invokers list.

func (*RouterChain) SetInvokers

func (c *RouterChain) SetInvokers(invokers []protocol.Invoker)

SetInvokers receives updated invokers from registry center. If the times of notification exceeds countThreshold and time interval exceeds timeThreshold since last cache update, then notify to update the cache.