v3router

Documentation

Index

• func NewUniformRouterChain(virtualServiceConfig, destinationRuleConfig []byte, notify chan struct{}) (router.PriorityRouter, error)
• func NewUniformRouterFactory() router.PriorityRouterFactory
• type DubboRouterRule
• type RouterChain
  • func (r *RouterChain) Name() string
  • func (r *RouterChain) Priority() int64
  • func (r *RouterChain) Process(event *config_center.ConfigChangeEvent)
  • func (r *RouterChain) Route(invokers []protocol.Invoker, url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (r *RouterChain) URL() *common.URL
• type UniformRouteFactory
  • func (f *UniformRouteFactory) NewPriorityRouter(vsConfigBytes, distConfigBytes []byte, notify chan struct{}) (router.PriorityRouter, error)
• type UniformRouter
  • func NewUniformRouter(dubboRouter *DubboRouterRule, notify chan struct{}) (*UniformRouter, error)
  • func (r *UniformRouter) Name() string
  • func (r *UniformRouter) Priority() int64
  • func (r *UniformRouter) Process(event *config_center.ConfigChangeEvent)
  • func (r *UniformRouter) Route(invokers []protocol.Invoker, url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (r *UniformRouter) URL() *common.URL
• type UniformRule
• type VirtualServiceRule

Functions

func NewUniformRouterChain

func NewUniformRouterChain(virtualServiceConfig, destinationRuleConfig []byte, notify chan struct{}) (router.PriorityRouter, error)

NewUniformRouterChain return

func NewUniformRouterFactory

func NewUniformRouterFactory() router.PriorityRouterFactory

NewUniformRouterFactory constructs a new PriorityRouterFactory

Types

type DubboRouterRule

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

nolint

type RouterChain

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

RouterChain contains all uniform router logic it has UniformRouter list,

func (*RouterChain) Name

func (r *RouterChain) Name() string

Name get name of ConnCheckerRouter

func (*RouterChain) Priority

func (r *RouterChain) Priority() int64

Priority get Router priority level

func (*RouterChain) Process

func (r *RouterChain) Process(event *config_center.ConfigChangeEvent)

func (*RouterChain) Route

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

Route route invokers using RouterChain's routers one by one

func (*RouterChain) URL

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

URL Return URL in router

type UniformRouteFactory

type UniformRouteFactory struct{}

UniformRouteFactory is uniform router's factory

func (*UniformRouteFactory) NewPriorityRouter

func (f *UniformRouteFactory) NewPriorityRouter(vsConfigBytes, distConfigBytes []byte, notify chan struct{}) (router.PriorityRouter, error)

NewPriorityRouter construct a new UniformRouteFactory as PriorityRouter

type UniformRouter

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

UniformRouter have

func NewUniformRouter

func NewUniformRouter(dubboRouter *DubboRouterRule, notify chan struct{}) (*UniformRouter, error)

NewUniformRouter construct an NewConnCheckRouter via url

func (*UniformRouter) Name

func (r *UniformRouter) Name() string

Name get name of ConnCheckerRouter

func (*UniformRouter) Priority

func (r *UniformRouter) Priority() int64

Priority get Router priority level

func (*UniformRouter) Process

func (r *UniformRouter) Process(event *config_center.ConfigChangeEvent)

Process there is no process needs for uniform Router, as it upper struct RouterChain has done it

func (*UniformRouter) Route

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

Route gets a list of routed invoker

func (*UniformRouter) URL

func (r *UniformRouter) URL() *common.URL

URL Return URL in router

type UniformRule

type UniformRule struct {
	DestinationLabelListMap map[string]map[string]string
	// contains filtered or unexported fields
}

UniformRule

type VirtualServiceRule

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

VirtualServiceRule is item of virtual service, it aims at judge if invocation context match it's condition, and if match, get result destination key, which should be defined in DestinationRule yaml file