extension

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2019 License: Apache-2.0 Imports: 9 Imported by: 32

Documentation

Index

Constants

View Source
const DefaultKey = "default"

Variables

This section is empty.

Functions

func GetCluster

func GetCluster(name string) cluster.Cluster

func GetConfigCenter

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

func GetConfigurator added in v1.2.0

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

func GetDefaultConfigurator added in v1.2.0

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

func GetDefaultConfiguratorFunc added in v1.2.0

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 added in v1.2.0

func GetRejectedExecutionHandler(name string) common.RejectedExecutionHandler

func GetRouterFactory

func GetRouterFactory(name string) cluster.RouterFactory

func GetTpsLimitStrategyCreator added in v1.2.0

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

func GetTpsLimiter added in v1.2.0

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 added in v1.2.0

func SetConfigurator(name string, v getConfiguratorFunc)

func SetDefaultConfigurator added in v1.2.0

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 added in v1.2.0

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

func SetRouterFactory

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

func SetTpsLimitStrategy added in v1.2.0

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

func SetTpsLimiter added in v1.2.0

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL