chain

Documentation

Index

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

Types

type RouterChain

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

RouterChain Router chain

func NewRouterChain

func NewRouterChain(url *common.URL) (*RouterChain, error)

NewRouterChain Use url to 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(invokers []protocol.Invoker, 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 notify router chain of the initial addresses from registry at the first time. Notify whenever addresses in registry change.

func (*RouterChain) URL

func (c *RouterChain) URL() common.URL

URL Return URL in RouterChain