Documentation
¶
Overview ¶
Package base implements invoker for the manipulation of cluster strategy.
Index ¶
- func GetLoadBalance(invoker base.Invoker, methodName string) loadbalance.LoadBalance
- type BaseClusterInvoker
- func (invoker *BaseClusterInvoker) CheckInvokers(invokers []base.Invoker, invocation base.Invocation) error
- func (invoker *BaseClusterInvoker) CheckWhetherDestroyed() error
- func (invoker *BaseClusterInvoker) Destroy()
- func (invoker *BaseClusterInvoker) DoSelect(lb loadbalance.LoadBalance, invocation base.Invocation, ...) base.Invoker
- func (invoker *BaseClusterInvoker) GetURL() *common.URL
- func (invoker *BaseClusterInvoker) IsAvailable() bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetLoadBalance ¶
func GetLoadBalance(invoker base.Invoker, methodName string) loadbalance.LoadBalance
Types ¶
type BaseClusterInvoker ¶ added in v3.0.1
type BaseClusterInvoker struct {
Directory directory.Directory
AvailableCheck bool
Destroyed *atomic.Bool
StickyInvoker base.Invoker
}
func NewBaseClusterInvoker ¶ added in v3.0.1
func NewBaseClusterInvoker(directory directory.Directory) BaseClusterInvoker
func (*BaseClusterInvoker) CheckInvokers ¶ added in v3.0.1
func (invoker *BaseClusterInvoker) CheckInvokers(invokers []base.Invoker, invocation base.Invocation) error
CheckInvokers checks invokers' status if is available or not
func (*BaseClusterInvoker) CheckWhetherDestroyed ¶ added in v3.0.1
func (invoker *BaseClusterInvoker) CheckWhetherDestroyed() error
CheckWhetherDestroyed checks if cluster invoker was destroyed or not
func (*BaseClusterInvoker) Destroy ¶ added in v3.0.1
func (invoker *BaseClusterInvoker) Destroy()
func (*BaseClusterInvoker) DoSelect ¶ added in v3.0.1
func (invoker *BaseClusterInvoker) DoSelect(lb loadbalance.LoadBalance, invocation base.Invocation, invokers []base.Invoker, invoked []base.Invoker) base.Invoker
func (*BaseClusterInvoker) GetURL ¶ added in v3.0.1
func (invoker *BaseClusterInvoker) GetURL() *common.URL
func (*BaseClusterInvoker) IsAvailable ¶ added in v3.0.1
func (invoker *BaseClusterInvoker) IsAvailable() bool
Click to show internal directories.
Click to hide internal directories.