base

Documentation

Index

• func GetLoadBalance(invoker protocol.Invoker, methodName string) loadbalance.LoadBalance
• type BaseClusterInvoker
  • func NewBaseClusterInvoker(directory directory.Directory) BaseClusterInvoker
  • func (invoker *BaseClusterInvoker) CheckInvokers(invokers []protocol.Invoker, invocation protocol.Invocation) error
  • func (invoker *BaseClusterInvoker) CheckWhetherDestroyed() error
  • func (invoker *BaseClusterInvoker) Destroy()
  • func (invoker *BaseClusterInvoker) DoSelect(lb loadbalance.LoadBalance, invocation protocol.Invocation, ...) protocol.Invoker
  • func (invoker *BaseClusterInvoker) GetURL() *common.URL
  • func (invoker *BaseClusterInvoker) IsAvailable() bool

Functions

func GetLoadBalance

func GetLoadBalance(invoker protocol.Invoker, methodName string) loadbalance.LoadBalance

Types

type BaseClusterInvoker

type BaseClusterInvoker struct {
	Directory      directory.Directory
	AvailableCheck bool
	Destroyed      *atomic.Bool
	StickyInvoker  protocol.Invoker
}

func NewBaseClusterInvoker

func NewBaseClusterInvoker(directory directory.Directory) BaseClusterInvoker

func (*BaseClusterInvoker) CheckInvokers

func (invoker *BaseClusterInvoker) CheckInvokers(invokers []protocol.Invoker, invocation protocol.Invocation) error

CheckInvokers checks invokers' status if is available or not

func (*BaseClusterInvoker) CheckWhetherDestroyed

func (invoker *BaseClusterInvoker) CheckWhetherDestroyed() error

CheckWhetherDestroyed checks if cluster invoker was destroyed or not

func (*BaseClusterInvoker) Destroy

func (invoker *BaseClusterInvoker) Destroy()

func (*BaseClusterInvoker) DoSelect

func (invoker *BaseClusterInvoker) DoSelect(lb loadbalance.LoadBalance, invocation protocol.Invocation, invokers []protocol.Invoker, invoked []protocol.Invoker) protocol.Invoker

func (*BaseClusterInvoker) GetURL

func (invoker *BaseClusterInvoker) GetURL() *common.URL

func (*BaseClusterInvoker) IsAvailable

func (invoker *BaseClusterInvoker) IsAvailable() bool