affinity

Documentation

Index

• func NewApplicationAffinityRouterFactory() router.PriorityRouterFactory
• func NewServiceAffinityRouterFactory() router.PriorityRouterFactory
• type ApplicationAffinityRoute
  • func (s *ApplicationAffinityRoute) Notify(invokers []protocol.Invoker)
  • func (a *ApplicationAffinityRoute) Priority() int64
  • func (a *ApplicationAffinityRoute) Process(event *config_center.ConfigChangeEvent)
  • func (a *ApplicationAffinityRoute) Route(invokers []protocol.Invoker, url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (a *ApplicationAffinityRoute) URL() *common.URL
• type ApplicationAffinityRouterFactory
  • func (n ApplicationAffinityRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)
• type ServiceAffinityRoute
  • func (s *ServiceAffinityRoute) Notify(invokers []protocol.Invoker)
  • func (a *ServiceAffinityRoute) Priority() int64
  • func (a *ServiceAffinityRoute) Process(event *config_center.ConfigChangeEvent)
  • func (a *ServiceAffinityRoute) Route(invokers []protocol.Invoker, url *common.URL, invocation protocol.Invocation) []protocol.Invoker
  • func (a *ServiceAffinityRoute) URL() *common.URL
• type ServiceAffinityRouterFactory
  • func (n ServiceAffinityRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)

Functions

func NewApplicationAffinityRouterFactory

func NewApplicationAffinityRouterFactory() router.PriorityRouterFactory

NewApplicationAffinityRouterFactory constructs a new PriorityRouterFactory

func NewServiceAffinityRouterFactory

func NewServiceAffinityRouterFactory() router.PriorityRouterFactory

NewServiceAffinityRouterFactory constructs a new PriorityRouterFactory

Types

type ApplicationAffinityRoute

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

func (*ApplicationAffinityRoute) Notify

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

func (*ApplicationAffinityRoute) Priority

func (a *ApplicationAffinityRoute) Priority() int64

func (*ApplicationAffinityRoute) Process

func (a *ApplicationAffinityRoute) Process(event *config_center.ConfigChangeEvent)

func (*ApplicationAffinityRoute) Route

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

func (*ApplicationAffinityRoute) URL

func (a *ApplicationAffinityRoute) URL() *common.URL

type ApplicationAffinityRouterFactory

type ApplicationAffinityRouterFactory struct{}

ApplicationAffinityRouterFactory router factory

func (ApplicationAffinityRouterFactory) NewPriorityRouter

func (n ApplicationAffinityRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)

type ServiceAffinityRoute

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

func (*ServiceAffinityRoute) Notify

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

func (*ServiceAffinityRoute) Priority

func (a *ServiceAffinityRoute) Priority() int64

func (*ServiceAffinityRoute) Process

func (a *ServiceAffinityRoute) Process(event *config_center.ConfigChangeEvent)

func (*ServiceAffinityRoute) Route

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

func (*ServiceAffinityRoute) URL

func (a *ServiceAffinityRoute) URL() *common.URL

type ServiceAffinityRouterFactory

type ServiceAffinityRouterFactory struct{}

ServiceAffinityRouterFactory router factory

func (ServiceAffinityRouterFactory) NewPriorityRouter

func (n ServiceAffinityRouterFactory) NewPriorityRouter() (router.PriorityRouter, error)