condition

Documentation

Index

• func NewAppConditionRouterFactory() router.PriorityRouterFactory
• func NewServiceConditionRouterFactory() router.PriorityRouterFactory
• type AppConditionRouterFactory
  • func (a *AppConditionRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)
• type ApplicationRouter
  • func NewApplicationRouter() *ApplicationRouter
  • func (a *ApplicationRouter) Notify(invokers []protocol.Invoker)
  • func (a *ApplicationRouter) Priority() int64
• type DynamicRouter
  • func (d *DynamicRouter) Process(event *config_center.ConfigChangeEvent)
  • func (d *DynamicRouter) Route(invokers []protocol.Invoker, url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (d *DynamicRouter) URL() *common.URL
• type ServiceRouteFactory
  • func (s *ServiceRouteFactory) NewPriorityRouter() (router.PriorityRouter, error)
• type ServiceRouter
  • func NewServiceRouter() *ServiceRouter
  • func (s *ServiceRouter) Notify(invokers []protocol.Invoker)
  • func (s *ServiceRouter) Priority() int64
• type StateRouter
  • func NewConditionStateRouter(url *common.URL) (*StateRouter, error)
  • func (s *StateRouter) Priority() int64
  • func (s *StateRouter) Route(invokers []protocol.Invoker, url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (s *StateRouter) URL() *common.URL

Functions

func NewAppConditionRouterFactory

func NewAppConditionRouterFactory() router.PriorityRouterFactory

NewAppConditionRouterFactory router factory

func NewServiceConditionRouterFactory

func NewServiceConditionRouterFactory() router.PriorityRouterFactory

NewServiceConditionRouterFactory constructs a new PriorityRouterFactory

Types

type AppConditionRouterFactory

type AppConditionRouterFactory struct {
}

AppConditionRouterFactory router factory

func (*AppConditionRouterFactory) NewPriorityRouter

func (a *AppConditionRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)

NewPriorityRouter constructs a new ApplicationRouter

type ApplicationRouter

type ApplicationRouter struct {
	DynamicRouter
	// contains filtered or unexported fields
}

ApplicationRouter is Application level router

func NewApplicationRouter

func NewApplicationRouter() *ApplicationRouter

func (*ApplicationRouter) Notify

func (a *ApplicationRouter) Notify(invokers []protocol.Invoker)

func (*ApplicationRouter) Priority

func (a *ApplicationRouter) Priority() int64

type DynamicRouter

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

func (*DynamicRouter) Process

func (d *DynamicRouter) Process(event *config_center.ConfigChangeEvent)

func (*DynamicRouter) Route

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

func (*DynamicRouter) URL

func (d *DynamicRouter) URL() *common.URL

type ServiceRouteFactory

type ServiceRouteFactory struct{}

ServiceRouteFactory router factory

func (*ServiceRouteFactory) NewPriorityRouter

func (s *ServiceRouteFactory) NewPriorityRouter() (router.PriorityRouter, error)

NewPriorityRouter constructs a new ServiceRouter

type ServiceRouter

type ServiceRouter struct {
	DynamicRouter
}

ServiceRouter is Service level router

func NewServiceRouter

func NewServiceRouter() *ServiceRouter

func (*ServiceRouter) Notify

func (s *ServiceRouter) Notify(invokers []protocol.Invoker)

func (*ServiceRouter) Priority

func (s *ServiceRouter) Priority() int64

type StateRouter

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

func NewConditionStateRouter

func NewConditionStateRouter(url *common.URL) (*StateRouter, error)

func (*StateRouter) Priority

func (s *StateRouter) Priority() int64

func (*StateRouter) Route

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

Route Determine the target invokers list.

func (*StateRouter) URL

func (s *StateRouter) URL() *common.URL