extension

Documentation

Index

• Constants
• func GetCluster(name string) cluster.Cluster
• func GetConfigCenter(name string, config *common.URL) (config_center.DynamicConfiguration, error)
• func GetConfigCenterFactory(name string) config_center.DynamicConfigurationFactory
• func GetConfigurator(name string, url *common.URL) config_center.Configurator
• func GetDefaultConfigurator(url *common.URL) config_center.Configurator
• func GetDefaultConfiguratorFunc() getConfiguratorFunc
• func GetFilter(name string) filter.Filter
• func GetLoadbalance(name string) cluster.LoadBalance
• func GetProtocol(name string) protocol.Protocol
• func GetProxyFactory(name string) proxy.ProxyFactory
• func GetRegistry(name string, config *common.URL) (registry.Registry, error)
• func GetRejectedExecutionHandler(name string) common.RejectedExecutionHandler
• func GetRouterFactory(name string) cluster.RouterFactory
• func GetTpsLimitStrategyCreator(name string) func(rate int, interval int) tps.TpsLimitStrategy
• func GetTpsLimiter(name string) tps.TpsLimiter
• func SetCluster(name string, fcn func() cluster.Cluster)
• func SetConfigCenter(name string, ...)
• func SetConfigCenterFactory(name string, v func() config_center.DynamicConfigurationFactory)
• func SetConfigurator(name string, v getConfiguratorFunc)
• func SetDefaultConfigurator(v getConfiguratorFunc)
• func SetFilter(name string, v func() filter.Filter)
• func SetLoadbalance(name string, fcn func() cluster.LoadBalance)
• func SetProtocol(name string, v func() protocol.Protocol)
• func SetProxyFactory(name string, f func(...proxy.Option) proxy.ProxyFactory)
• func SetRegistry(name string, v func(config *common.URL) (registry.Registry, error))
• func SetRejectedExecutionHandler(name string, creator func() common.RejectedExecutionHandler)
• func SetRouterFactory(name string, fun func() cluster.RouterFactory)
• func SetTpsLimitStrategy(name string, creator func(rate int, interval int) tps.TpsLimitStrategy)
• func SetTpsLimiter(name string, creator func() tps.TpsLimiter)

Constants

const DefaultKey = "default"

Functions

func GetCluster

func GetCluster(name string) cluster.Cluster

func GetConfigCenter

func GetConfigCenter(name string, config *common.URL) (config_center.DynamicConfiguration, error)

func GetConfigCenterFactory

func GetConfigCenterFactory(name string) config_center.DynamicConfigurationFactory

func GetConfigurator

func GetConfigurator(name string, url *common.URL) config_center.Configurator

func GetDefaultConfigurator

func GetDefaultConfigurator(url *common.URL) config_center.Configurator

func GetDefaultConfiguratorFunc

func GetDefaultConfiguratorFunc() getConfiguratorFunc

func GetFilter

func GetFilter(name string) filter.Filter

func GetLoadbalance

func GetLoadbalance(name string) cluster.LoadBalance

func GetProtocol

func GetProtocol(name string) protocol.Protocol

func GetProxyFactory

func GetProxyFactory(name string) proxy.ProxyFactory

func GetRegistry

func GetRegistry(name string, config *common.URL) (registry.Registry, error)

func GetRejectedExecutionHandler

func GetRejectedExecutionHandler(name string) common.RejectedExecutionHandler

func GetRouterFactory

func GetRouterFactory(name string) cluster.RouterFactory

func GetTpsLimitStrategyCreator

func GetTpsLimitStrategyCreator(name string) func(rate int, interval int) tps.TpsLimitStrategy

func GetTpsLimiter

func GetTpsLimiter(name string) tps.TpsLimiter

func SetCluster

func SetCluster(name string, fcn func() cluster.Cluster)

func SetConfigCenter

func SetConfigCenter(name string, v func(config *common.URL) (config_center.DynamicConfiguration, error))

func SetConfigCenterFactory

func SetConfigCenterFactory(name string, v func() config_center.DynamicConfigurationFactory)

func SetConfigurator

func SetConfigurator(name string, v getConfiguratorFunc)

func SetDefaultConfigurator

func SetDefaultConfigurator(v getConfiguratorFunc)

func SetFilter

func SetFilter(name string, v func() filter.Filter)

func SetLoadbalance

func SetLoadbalance(name string, fcn func() cluster.LoadBalance)

func SetProtocol

func SetProtocol(name string, v func() protocol.Protocol)

func SetProxyFactory

func SetProxyFactory(name string, f func(...proxy.Option) proxy.ProxyFactory)

func SetRegistry

func SetRegistry(name string, v func(config *common.URL) (registry.Registry, error))

func SetRejectedExecutionHandler

func SetRejectedExecutionHandler(name string, creator func() common.RejectedExecutionHandler)

func SetRouterFactory

func SetRouterFactory(name string, fun func() cluster.RouterFactory)

func SetTpsLimitStrategy

func SetTpsLimitStrategy(name string, creator func(rate int, interval int) tps.TpsLimitStrategy)

func SetTpsLimiter

func SetTpsLimiter(name string, creator func() tps.TpsLimiter)