meshrouter

Documentation

Index

• func NewMeshRouter() (router.PriorityRouter, error)
• func NewMeshRouterFactory() router.PriorityRouterFactory
• type MeshRouter
  • func (r *MeshRouter) Name() string
  • func (r *MeshRouter) Notify(invokers []protocol.Invoker)
  • func (r *MeshRouter) Priority() int64
  • func (r *MeshRouter) Process(event *config_center.ConfigChangeEvent)
  • func (r *MeshRouter) Route(invokers []protocol.Invoker, url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (r *MeshRouter) URL() *common.URL
• type MeshRouterFactory
  • func (f *MeshRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)

Functions

func NewMeshRouter

func NewMeshRouter() (router.PriorityRouter, error)

NewMeshRouter construct an NewConnCheckRouter via url

func NewMeshRouterFactory

func NewMeshRouterFactory() router.PriorityRouterFactory

NewMeshRouterFactory constructs a new PriorityRouterFactory

Types

type MeshRouter

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

MeshRouter have

func (*MeshRouter) Name

func (r *MeshRouter) Name() string

Name get name of ConnCheckerRouter

func (*MeshRouter) Notify

func (r *MeshRouter) Notify(invokers []protocol.Invoker)

Notify the router the invoker list

func (*MeshRouter) Priority

func (r *MeshRouter) Priority() int64

Priority get Router priority level

func (*MeshRouter) Process

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

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

func (*MeshRouter) Route

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

Route gets a list of routed invoker

func (*MeshRouter) URL

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

URL Return URL in router

type MeshRouterFactory

type MeshRouterFactory struct{}

MeshRouterFactory is mesh router's factory

func (*MeshRouterFactory) NewPriorityRouter

func (f *MeshRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)

NewPriorityRouter construct a new UniformRouteFactory as PriorityRouter