Versions in this module Expand all Collapse all v1 v1.5.4 Oct 26, 2023 Changes in this version + const AllLevel + const CampusLevel + const DefaultAPIInvokeTimeout + const DefaultAPIMaxRetryTimes + const DefaultAPIRetryInterval + const DefaultBuiltInServerConnectionCloseTimeout + const DefaultCachePersistDir + const DefaultCacheReporter + const DefaultCircuitBreakerCheckPeriod + const DefaultCircuitBreakerEnabled + const DefaultCircuitBreakerErrCheck + const DefaultCircuitBreakerErrCount + const DefaultCircuitBreakerErrRate + const DefaultConfigConnector + const DefaultConfigConnectorAddresses + const DefaultConfigFile + const DefaultConfigFilterEnabled + const DefaultConnectorType + const DefaultDiscoverServiceRetryInterval + const DefaultHealthCheckConcurrency + const DefaultHealthCheckConcurrencyAlways + const DefaultHealthCheckInterval + const DefaultHealthCheckTimeout + const DefaultLimiterNamespace + const DefaultLimiterService + const DefaultLoadBalanceReporter + const DefaultLoadBalancerHash + const DefaultLoadBalancerL5CST + const DefaultLoadBalancerMaglev + const DefaultLoadBalancerRingHash + const DefaultLoadBalancerWR + const DefaultLocalCache + const DefaultLocationProvider + const DefaultMapKVTupleSeparator + const DefaultMapKeyValueSeparator + const DefaultMatchLevel + const DefaultMaxServiceExpireCheckTime + const DefaultMetricsChain + const DefaultMinRegisterInterval + const DefaultMinServiceExpireTime + const DefaultMinTimingInterval + const DefaultNamesSeparator + const DefaultPercentOfMinInstances + const DefaultPersistAvailableInterval + const DefaultPersistMaxReadRetry + const DefaultPersistMaxWriteRetry + const DefaultPersistRetryInterval + const DefaultPluginReporter + const DefaultPropertiesValueCacheSize + const DefaultPropertiesValueExpireTime + const DefaultRateLimitAcquireInterval + const DefaultRateLimitPurgeInterval + const DefaultRateLimitReportAmountPresent + const DefaultRateLimitReporter + const DefaultRateLimitWindowCount + const DefaultReConnectInterval + const DefaultRecoverAllEnabled + const DefaultRecoverNumBuckets + const DefaultRecoverWindow + const DefaultRejectRateLimiter + const DefaultReportClientIntervalDuration + const DefaultReportSDKConfigurationInterval + const DefaultRequestCountAfterHalfOpen + const DefaultRequestQueueSize + const DefaultServerConnectTimeout + const DefaultServerConnectionIdleTimeout + const DefaultServerConnector + const DefaultServerMessageTimeout + const DefaultServerServiceRefreshInterval + const DefaultServerSwitchInterval + const DefaultServiceExpireTime + const DefaultServiceRefreshIntervalDuration + const DefaultServiceRouteReporter + const DefaultServiceRouterCanary + const DefaultServiceRouterDstMeta + const DefaultServiceRouterFilterOnly + const DefaultServiceRouterNearbyBased + const DefaultServiceRouterRuleBased + const DefaultServiceRouterSetDivision + const DefaultServiceRouterZeroProtect + const DefaultSleepWindow + const DefaultStatReportEnabled + const DefaultStatReporter + const DefaultSuccessCountAfterHalfOpen + const DefaultTCPHealthCheck + const DefaultUDPHealthCheck + const DefaultUniformRateLimiter + const DefaultWarmUpRateLimiter + const DefaultWarmUpWaitLimiter + const ForbidServerMetricService + const HealthCheckAlways + const HealthCheckNever + const HealthCheckOnRecover + const MaxRateLimitReportAmountPresent + const MaxRateLimitReportInterval + const MaxRateLimitWindowSize + const MaxRedirectTimes + const MinCircuitBreakerCheckPeriod + const MinHealthCheckInterval + const MinRateLimitReportAmountPresent + const MinRateLimitReportInterval + const MinRecoverNumBuckets + const MinRecoverWindow + const MinSleepWindow + const RegionLevel + const ServerConfigService + const ServerDiscoverService + const ServerHeartBeatService + const ServerMonitorService + const ServerNamespace + const SubscribeLocalChannel + const ZoneLevel + var DefaultConfigFileEnable = true + var DefaultPolarisServicesRouterChain = []string + var DefaultPushEmptyProtection = false + var DefaultRateLimitEnable = true + var DefaultServerServiceRouterChain = []string + var DefaultServerServiceToLoadBalancer = map[ClusterType]string + var DefaultServerServiceToUseDefault = map[ClusterType]bool + var DefaultUseFileCacheFlag = true + func GetContainerNameEnvList() []string + func RegisterPluginConfigType(typ common.Type, name string, cfg BaseConfig) + func ServiceClusterToServiceKey(config ServerClusterConfig) model.ServiceKey + type APIConfig interface + GetBindIP func() string + GetBindIntf func() string + GetMaxRetryTimes func() int + GetReportInterval func() time.Duration + GetRetryInterval func() time.Duration + GetTimeout func() time.Duration + SetBindIP func(string) + SetBindIntf func(string) + SetMaxRetryTimes func(int) + SetReportInterval func(time.Duration) + SetRetryInterval func(time.Duration) + SetTimeout func(time.Duration) + type APIConfigImpl struct + BindIP string + BindIPValue string + BindIntf string + MaxRetryTimes int + ReportInterval *time.Duration + RetryInterval *time.Duration + Timeout *time.Duration + func (a *APIConfigImpl) GetBindIP() string + func (a *APIConfigImpl) GetBindIntf() string + func (a *APIConfigImpl) GetMaxRetryTimes() int + func (a *APIConfigImpl) GetReportInterval() time.Duration + func (a *APIConfigImpl) GetRetryInterval() time.Duration + func (a *APIConfigImpl) GetTimeout() time.Duration + func (a *APIConfigImpl) SetBindIP(bindIPValue string) + func (a *APIConfigImpl) SetBindIntf(bindIntf string) + func (a *APIConfigImpl) SetDefault() + func (a *APIConfigImpl) SetMaxRetryTimes(maxRetryTimes int) + func (a *APIConfigImpl) SetReportInterval(interval time.Duration) + func (a *APIConfigImpl) SetRetryInterval(interval time.Duration) + func (a *APIConfigImpl) SetTimeout(timeout time.Duration) + func (a *APIConfigImpl) Verify() error + type BaseConfig interface + SetDefault func() + Verify func() error + type CircuitBreakerConfig interface + GetChain func() []string + GetCheckPeriod func() time.Duration + GetErrorCountConfig func() ErrorCountConfig + GetErrorRateConfig func() ErrorRateConfig + GetRecoverNumBuckets func() int + GetRecoverWindow func() time.Duration + GetRequestCountAfterHalfOpen func() int + GetSleepWindow func() time.Duration + GetSuccessCountAfterHalfOpen func() int + IsEnable func() bool + SetChain func([]string) + SetCheckPeriod func(time.Duration) + SetEnable func(bool) + SetRecoverNumBuckets func(value int) + SetRecoverWindow func(value time.Duration) + SetRequestCountAfterHalfOpen func(count int) + SetSleepWindow func(interval time.Duration) + SetSuccessCountAfterHalfOpen func(count int) + type CircuitBreakerConfigImpl struct + Chain []string + CheckPeriod *time.Duration + Enable *bool + Plugin PluginConfigs + RecoverNumBuckets int + RecoverWindow *time.Duration + RequestCountAfterHalfOpen int + SleepWindow *time.Duration + SuccessCountAfterHalfOpen int + func (c *CircuitBreakerConfigImpl) GetChain() []string + func (c *CircuitBreakerConfigImpl) GetCheckPeriod() time.Duration + func (c *CircuitBreakerConfigImpl) GetErrorCountConfig() ErrorCountConfig + func (c *CircuitBreakerConfigImpl) GetErrorRateConfig() ErrorRateConfig + func (c *CircuitBreakerConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (c *CircuitBreakerConfigImpl) GetRecoverNumBuckets() int + func (c *CircuitBreakerConfigImpl) GetRecoverWindow() time.Duration + func (c *CircuitBreakerConfigImpl) GetRequestCountAfterHalfOpen() int + func (c *CircuitBreakerConfigImpl) GetSleepWindow() time.Duration + func (c *CircuitBreakerConfigImpl) GetSuccessCountAfterHalfOpen() int + func (c *CircuitBreakerConfigImpl) Init() + func (c *CircuitBreakerConfigImpl) IsEnable() bool + func (c *CircuitBreakerConfigImpl) SetChain(chain []string) + func (c *CircuitBreakerConfigImpl) SetCheckPeriod(period time.Duration) + func (c *CircuitBreakerConfigImpl) SetDefault() + func (c *CircuitBreakerConfigImpl) SetEnable(enable bool) + func (c *CircuitBreakerConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (c *CircuitBreakerConfigImpl) SetRecoverNumBuckets(value int) + func (c *CircuitBreakerConfigImpl) SetRecoverWindow(value time.Duration) + func (c *CircuitBreakerConfigImpl) SetRequestCountAfterHalfOpen(count int) + func (c *CircuitBreakerConfigImpl) SetSleepWindow(interval time.Duration) + func (c *CircuitBreakerConfigImpl) SetSuccessCountAfterHalfOpen(count int) + func (c *CircuitBreakerConfigImpl) Verify() error + type ClusterService struct + ClusterConfig ServerClusterConfig + ClusterType ClusterType + func (c ClusterService) String() string + type ClusterType string + const BuiltinCluster + const ConfigCluster + const DiscoverCluster + const HealthCheckCluster + const MonitorCluster + type ConfigConnectorConfig interface + GetConnectorType func() string + type ConfigConnectorConfigImpl struct + Addresses []string + ConnectTimeout *time.Duration + ConnectionIdleTimeout *time.Duration + ConnectorType string + MessageTimeout *time.Duration + Plugin PluginConfigs + Protocol string + ReconnectInterval *time.Duration + RequestQueueSize *int32 + ServerSwitchInterval *time.Duration + func (c *ConfigConnectorConfigImpl) GetAddresses() []string + func (c *ConfigConnectorConfigImpl) GetConnectTimeout() time.Duration + func (c *ConfigConnectorConfigImpl) GetConnectionIdleTimeout() time.Duration + func (c *ConfigConnectorConfigImpl) GetConnectorType() string + func (c *ConfigConnectorConfigImpl) GetMessageTimeout() time.Duration + func (c *ConfigConnectorConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (c *ConfigConnectorConfigImpl) GetProtocol() string + func (c *ConfigConnectorConfigImpl) GetReconnectInterval() time.Duration + func (c *ConfigConnectorConfigImpl) GetRequestQueueSize() int32 + func (c *ConfigConnectorConfigImpl) GetServerSwitchInterval() time.Duration + func (c *ConfigConnectorConfigImpl) Init() + func (c *ConfigConnectorConfigImpl) SetAddresses(addresses []string) + func (c *ConfigConnectorConfigImpl) SetConnectTimeout(timeout time.Duration) + func (c *ConfigConnectorConfigImpl) SetConnectionIdleTimeout(timeout time.Duration) + func (c *ConfigConnectorConfigImpl) SetConnectorType(connectorType string) + func (c *ConfigConnectorConfigImpl) SetDefault() + func (c *ConfigConnectorConfigImpl) SetMessageTimeout(timeout time.Duration) + func (c *ConfigConnectorConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (c *ConfigConnectorConfigImpl) SetProtocol(protocol string) + func (c *ConfigConnectorConfigImpl) SetReconnectInterval(interval time.Duration) + func (c *ConfigConnectorConfigImpl) SetRequestQueueSize(queueSize int32) + func (c *ConfigConnectorConfigImpl) SetServerSwitchInterval(interval time.Duration) + func (c *ConfigConnectorConfigImpl) Verify() error + type ConfigFileConfig interface + GetConfigConnectorConfig func() ConfigConnectorConfig + GetConfigFilterConfig func() ConfigFilterConfig + GetLocalCache func() ConfigLocalCacheConfig + GetPropertiesValueCacheSize func() int32 + GetPropertiesValueExpireTime func() int64 + IsEnable func() bool + type ConfigFileConfigImpl struct + ConfigConnectorConfig *ConfigConnectorConfigImpl + ConfigFilterConfig *ConfigFilterConfigImpl + Enable *bool + LocalCache *ConfigLocalCacheConfigImpl + PropertiesValueCacheSize *int32 + PropertiesValueExpireTime *int64 + func (c *ConfigFileConfigImpl) GetConfigConnectorConfig() ConfigConnectorConfig + func (c *ConfigFileConfigImpl) GetConfigFilterConfig() ConfigFilterConfig + func (c *ConfigFileConfigImpl) GetLocalCache() ConfigLocalCacheConfig + func (c *ConfigFileConfigImpl) GetPropertiesValueCacheSize() int32 + func (c *ConfigFileConfigImpl) GetPropertiesValueExpireTime() int64 + func (c *ConfigFileConfigImpl) Init() + func (c *ConfigFileConfigImpl) IsEnable() bool + func (c *ConfigFileConfigImpl) SetDefault() + func (c *ConfigFileConfigImpl) SetEnable(enable bool) + func (c *ConfigFileConfigImpl) SetPropertiesValueCacheSize(propertiesValueCacheSize int32) + func (c *ConfigFileConfigImpl) SetPropertiesValueExpireTime(propertiesValueExpireTime int64) + func (c *ConfigFileConfigImpl) Verify() error + type ConfigFilterConfig interface + GetChain func() []string + IsEnable func() bool + type ConfigFilterConfigImpl struct + Chain []string + Enable *bool + Plugin PluginConfigs + func (c *ConfigFilterConfigImpl) GetChain() []string + func (c *ConfigFilterConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (c *ConfigFilterConfigImpl) Init() + func (c *ConfigFilterConfigImpl) IsEnable() bool + func (c *ConfigFilterConfigImpl) SetChain(chain []string) + func (c *ConfigFilterConfigImpl) SetDefault() + func (c *ConfigFilterConfigImpl) SetEnable(enable bool) + func (c *ConfigFilterConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (c *ConfigFilterConfigImpl) Verify() error + type ConfigLocalCacheConfig interface + GetPersistDir func() string + GetPersistMaxReadRetry func() int + GetPersistMaxWriteRetry func() int + GetPersistRetryInterval func() time.Duration + IsFallbackToLocalCache func() bool + IsPersistEnable func() bool + SetFallbackToLocalCache func(enable bool) + SetPersistDir func(string) + SetPersistEnable func(enable bool) + SetPersistMaxReadRetry func(int) + SetPersistMaxWriteRetry func(int) + SetPersistRetryInterval func(time.Duration) + type ConfigLocalCacheConfigImpl struct + FallbackToLocalCache *bool + PersistDir string + PersistEnable *bool + PersistMaxReadRetry int + PersistMaxWriteRetry int + PersistRetryInterval *time.Duration + func (l *ConfigLocalCacheConfigImpl) GetPersistDir() string + func (l *ConfigLocalCacheConfigImpl) GetPersistMaxReadRetry() int + func (l *ConfigLocalCacheConfigImpl) GetPersistMaxWriteRetry() int + func (l *ConfigLocalCacheConfigImpl) GetPersistRetryInterval() time.Duration + func (l *ConfigLocalCacheConfigImpl) Init() + func (l *ConfigLocalCacheConfigImpl) IsFallbackToLocalCache() bool + func (l *ConfigLocalCacheConfigImpl) IsPersistEnable() bool + func (l *ConfigLocalCacheConfigImpl) SetDefault() + func (l *ConfigLocalCacheConfigImpl) SetFallbackToLocalCache(enable bool) + func (l *ConfigLocalCacheConfigImpl) SetPersistDir(dir string) + func (l *ConfigLocalCacheConfigImpl) SetPersistEnable(enable bool) + func (l *ConfigLocalCacheConfigImpl) SetPersistMaxReadRetry(maxReadRetry int) + func (l *ConfigLocalCacheConfigImpl) SetPersistMaxWriteRetry(maxWriteRetry int) + func (l *ConfigLocalCacheConfigImpl) SetPersistRetryInterval(interval time.Duration) + func (l *ConfigLocalCacheConfigImpl) Verify() error + type Configuration interface + GetConfigFile func() ConfigFileConfig + GetConsumer func() ConsumerConfig + GetGlobal func() GlobalConfig + GetProvider func() ProviderConfig + type ConfigurationImpl struct + Config *ConfigFileConfigImpl + Consumer *ConsumerConfigImpl + Global *GlobalConfigImpl + Provider *ProviderConfigImpl + func LoadConfiguration(buf []byte) (*ConfigurationImpl, error) + func LoadConfigurationByDefaultFile() (*ConfigurationImpl, error) + func LoadConfigurationByFile(path string) (*ConfigurationImpl, error) + func NewDefaultConfiguration(addresses []string) *ConfigurationImpl + func NewDefaultConfigurationWithDomain() *ConfigurationImpl + func (c *ConfigurationImpl) GetConfigFile() ConfigFileConfig + func (c *ConfigurationImpl) GetConsumer() ConsumerConfig + func (c *ConfigurationImpl) GetGlobal() GlobalConfig + func (c *ConfigurationImpl) GetProvider() ProviderConfig + func (c *ConfigurationImpl) Init() + func (c *ConfigurationImpl) SetDefault() + func (c *ConfigurationImpl) Verify() error + type ConsumerConfig interface + GetCircuitBreaker func() CircuitBreakerConfig + GetHealthCheck func() HealthCheckConfig + GetLoadbalancer func() LoadbalancerConfig + GetLocalCache func() LocalCacheConfig + GetServiceRouter func() ServiceRouterConfig + GetServiceSpecific func(namespace string, service string) ServiceSpecificConfig + type ConsumerConfigImpl struct + CircuitBreaker *CircuitBreakerConfigImpl + HealthCheck *HealthCheckConfigImpl + Loadbalancer *LoadBalancerConfigImpl + LocalCache *LocalCacheConfigImpl + ServiceRouter *ServiceRouterConfigImpl + ServicesSpecific []*ServiceSpecific + func (c *ConsumerConfigImpl) GetCircuitBreaker() CircuitBreakerConfig + func (c *ConsumerConfigImpl) GetHealthCheck() HealthCheckConfig + func (c *ConsumerConfigImpl) GetLoadbalancer() LoadbalancerConfig + func (c *ConsumerConfigImpl) GetLocalCache() LocalCacheConfig + func (c *ConsumerConfigImpl) GetServiceRouter() ServiceRouterConfig + func (c *ConsumerConfigImpl) GetServiceSpecific(namespace string, service string) ServiceSpecificConfig + func (c *ConsumerConfigImpl) Init() + func (c *ConsumerConfigImpl) SetDefault() + func (c *ConsumerConfigImpl) Verify() error + type ErrorCountConfig interface + GetBucketInterval func() time.Duration + GetContinuousErrorThreshold func() int + GetMetricNumBuckets func() int + GetMetricStatTimeWindow func() time.Duration + SetContinuousErrorThreshold func(int) + SetMetricNumBuckets func(int) + SetMetricStatTimeWindow func(time.Duration) + type ErrorRateConfig interface + GetBucketInterval func() time.Duration + GetErrorRatePercent func() int + GetMetricNumBuckets func() int + GetMetricStatTimeWindow func() time.Duration + GetRequestVolumeThreshold func() int + SetErrorRatePercent func(int) + SetMetricNumBuckets func(int) + SetMetricStatTimeWindow func(time.Duration) + SetRequestVolumeThreshold func(int) + type GlobalConfig interface + GetAPI func() APIConfig + GetLocation func() LocationConfig + GetServerConnector func() ServerConnectorConfig + GetStatReporter func() StatReporterConfig + GetSystem func() SystemConfig + type GlobalConfigImpl struct + API *APIConfigImpl + Location *LocationConfigImpl + ServerConnector *ServerConnectorConfigImpl + StatReporter *StatReporterConfigImpl + System *SystemConfigImpl + func (g *GlobalConfigImpl) GetAPI() APIConfig + func (g *GlobalConfigImpl) GetLocation() LocationConfig + func (g *GlobalConfigImpl) GetServerConnector() ServerConnectorConfig + func (g *GlobalConfigImpl) GetStatReporter() StatReporterConfig + func (g *GlobalConfigImpl) GetSystem() SystemConfig + func (g *GlobalConfigImpl) Init() + func (g *GlobalConfigImpl) SetDefault() + func (g *GlobalConfigImpl) Verify() error + type HealthCheckConfig interface + GetChain func() []string + GetConcurrency func() int + GetInterval func() time.Duration + GetTimeout func() time.Duration + GetWhen func() When + SetChain func([]string) + SetConcurrency func(int) + SetInterval func(duration time.Duration) + SetTimeout func(duration time.Duration) + SetWhen func(When) + type HealthCheckConfigImpl struct + Chain []string + Concurrency int + Interval time.Duration + Plugin PluginConfigs + Timeout time.Duration + When When + func (h *HealthCheckConfigImpl) GetChain() []string + func (h *HealthCheckConfigImpl) GetConcurrency() int + func (h *HealthCheckConfigImpl) GetInterval() time.Duration + func (h *HealthCheckConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (h *HealthCheckConfigImpl) GetTimeout() time.Duration + func (h *HealthCheckConfigImpl) GetWhen() When + func (h *HealthCheckConfigImpl) Init() + func (h *HealthCheckConfigImpl) SetChain(chain []string) + func (h *HealthCheckConfigImpl) SetConcurrency(value int) + func (h *HealthCheckConfigImpl) SetDefault() + func (h *HealthCheckConfigImpl) SetInterval(duration time.Duration) + func (h *HealthCheckConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (h *HealthCheckConfigImpl) SetTimeout(duration time.Duration) + func (h *HealthCheckConfigImpl) SetWhen(when When) + func (h *HealthCheckConfigImpl) Verify() error + type LoadBalancerConfigImpl struct + Plugin PluginConfigs + Type string + func (l *LoadBalancerConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (l *LoadBalancerConfigImpl) GetType() string + func (l *LoadBalancerConfigImpl) Init() + func (l *LoadBalancerConfigImpl) SetDefault() + func (l *LoadBalancerConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (l *LoadBalancerConfigImpl) SetType(typ string) + func (l *LoadBalancerConfigImpl) Verify() error + type LoadbalancerConfig interface + GetType func() string + SetType func(string) + type LocalCacheConfig interface + GetPersistAvailableInterval func() time.Duration + GetPersistDir func() string + GetPersistMaxReadRetry func() int + GetPersistMaxWriteRetry func() int + GetPersistRetryInterval func() time.Duration + GetPushEmptyProtection func() bool + GetServiceExpireTime func() time.Duration + GetServiceRefreshInterval func() time.Duration + GetStartUseFileCache func() bool + GetType func() string + IsPersistEnable func() bool + SetPersistAvailableInterval func(interval time.Duration) + SetPersistDir func(string) + SetPersistEnable func(enable bool) + SetPersistMaxReadRetry func(int) + SetPersistMaxWriteRetry func(int) + SetPersistRetryInterval func(time.Duration) + SetPushEmptyProtection func(pushEmptyProtection bool) + SetServiceExpireTime func(time.Duration) + SetServiceRefreshInterval func(time.Duration) + SetStartUseFileCache func(useCacheFile bool) + SetType func(string) + type LocalCacheConfigImpl struct + PersistAvailableInterval *time.Duration + PersistDir string + PersistEnable bool + PersistMaxReadRetry int + PersistMaxWriteRetry int + PersistRetryInterval *time.Duration + Plugin PluginConfigs + PushEmptyProtection *bool + ServiceExpireTime *time.Duration + ServiceRefreshInterval *time.Duration + StartUseFileCache *bool + Type string + func (l *LocalCacheConfigImpl) GetPersistAvailableInterval() time.Duration + func (l *LocalCacheConfigImpl) GetPersistDir() string + func (l *LocalCacheConfigImpl) GetPersistMaxReadRetry() int + func (l *LocalCacheConfigImpl) GetPersistMaxWriteRetry() int + func (l *LocalCacheConfigImpl) GetPersistRetryInterval() time.Duration + func (l *LocalCacheConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (l *LocalCacheConfigImpl) GetPushEmptyProtection() bool + func (l *LocalCacheConfigImpl) GetServiceExpireTime() time.Duration + func (l *LocalCacheConfigImpl) GetServiceRefreshInterval() time.Duration + func (l *LocalCacheConfigImpl) GetStartUseFileCache() bool + func (l *LocalCacheConfigImpl) GetType() string + func (l *LocalCacheConfigImpl) Init() + func (l *LocalCacheConfigImpl) IsPersistEnable() bool + func (l *LocalCacheConfigImpl) SetDefault() + func (l *LocalCacheConfigImpl) SetPersistAvailableInterval(interval time.Duration) + func (l *LocalCacheConfigImpl) SetPersistDir(dir string) + func (l *LocalCacheConfigImpl) SetPersistEnable(enable bool) + func (l *LocalCacheConfigImpl) SetPersistMaxReadRetry(maxReadRetry int) + func (l *LocalCacheConfigImpl) SetPersistMaxWriteRetry(maxWriteRetry int) + func (l *LocalCacheConfigImpl) SetPersistRetryInterval(interval time.Duration) + func (l *LocalCacheConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (l *LocalCacheConfigImpl) SetPushEmptyProtection(pushEmptyProtection bool) + func (l *LocalCacheConfigImpl) SetServiceExpireTime(expireTime time.Duration) + func (l *LocalCacheConfigImpl) SetServiceRefreshInterval(interval time.Duration) + func (l *LocalCacheConfigImpl) SetStartUseFileCache(useCacheFile bool) + func (l *LocalCacheConfigImpl) SetType(typ string) + func (l *LocalCacheConfigImpl) Verify() error + type LocationConfig interface + GetProvider func(typ string) *LocationProviderConfigImpl + GetProviders func() []*LocationProviderConfigImpl + type LocationConfigImpl struct + Providers []*LocationProviderConfigImpl + func (a *LocationConfigImpl) GetProvider(providerType string) *LocationProviderConfigImpl + func (a *LocationConfigImpl) GetProviders() []*LocationProviderConfigImpl + func (a *LocationConfigImpl) Init() + func (a *LocationConfigImpl) SetDefault() + func (a *LocationConfigImpl) Verify() error + type LocationProviderConfigImpl struct + Options map[string]interface{} + Type string + func (l *LocationProviderConfigImpl) GetOptions() map[string]interface{} + func (l *LocationProviderConfigImpl) GetType() string + func (l *LocationProviderConfigImpl) SetDefault() + func (l *LocationProviderConfigImpl) Verify() error + type NearbyConfig interface + GetLowestMatchLevel func() string + GetMatchLevel func() string + GetMaxMatchLevel func() string + GetUnhealthyPercentToDegrade func() int + IsEnableDegradeByUnhealthyPercent func() bool + IsStrictNearby func() bool + SetEnableDegradeByUnhealthyPercent func(e bool) + SetLowestMatchLevel func(level string) + SetMatchLevel func(level string) + SetMaxMatchLevel func(level string) + SetStrictNearby func(s bool) + SetUnhealthyPercentToDegrade func(u int) + type PluginConfig interface + GetPluginConfig func(pluginName string) BaseConfig + SetPluginConfig func(plugName string, value BaseConfig) error + type PluginConfigs map[string]interface + func (p PluginConfigs) GetPluginConfig(pluginName string) BaseConfig + func (p PluginConfigs) Init(typ common.Type) + func (p PluginConfigs) SetDefault(typ common.Type) + func (p PluginConfigs) SetPluginConfig(plugType common.Type, plugName string, value BaseConfig) error + func (p PluginConfigs) Verify() error + type ProviderConfig interface + GetMinRegisterInterval func() time.Duration + GetRateLimit func() RateLimitConfig + type ProviderConfigImpl struct + MinRgisterInterval time.Duration + RateLimit *RateLimitConfigImpl + func (p *ProviderConfigImpl) GetMinRegisterInterval() time.Duration + func (p *ProviderConfigImpl) GetRateLimit() RateLimitConfig + func (p *ProviderConfigImpl) Init() + func (p *ProviderConfigImpl) SetDefault() + func (p *ProviderConfigImpl) Verify() error + type RateLimitConfig interface + GetLimiterNamespace func() string + GetLimiterService func() string + GetMaxWindowSize func() int + GetPurgeInterval func() time.Duration + IsEnable func() bool + SetEnable func(bool) + SetLimiterNamespace func(value string) + SetLimiterService func(value string) + SetMaxWindowSize func(maxSize int) + SetPurgeInterval func(time.Duration) + type RateLimitConfigImpl struct + Enable *bool + LimiterNamespace string + LimiterService string + MaxWindowSize int + Plugin PluginConfigs + PurgeInterval time.Duration + func (r *RateLimitConfigImpl) GetLimiterNamespace() string + func (r *RateLimitConfigImpl) GetLimiterService() string + func (r *RateLimitConfigImpl) GetMaxWindowSize() int + func (r *RateLimitConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (r *RateLimitConfigImpl) GetPurgeInterval() time.Duration + func (r *RateLimitConfigImpl) Init() + func (r *RateLimitConfigImpl) IsEnable() bool + func (r *RateLimitConfigImpl) SetDefault() + func (r *RateLimitConfigImpl) SetEnable(value bool) + func (r *RateLimitConfigImpl) SetLimiterNamespace(value string) + func (r *RateLimitConfigImpl) SetLimiterService(value string) + func (r *RateLimitConfigImpl) SetMaxWindowSize(maxSize int) + func (r *RateLimitConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (r *RateLimitConfigImpl) SetPurgeInterval(v time.Duration) + func (r *RateLimitConfigImpl) Verify() error + type ServerClusterConfig interface + GetNamespace func() string + GetRefreshInterval func() time.Duration + GetService func() string + SetNamespace func(string) + SetRefreshInterval func(time.Duration) + SetService func(string) + type ServerClusterConfigImpl struct + Namespace string + RefreshInterval *time.Duration + Service string + func NewServerClusterConfig(svcKey model.ServiceKey) *ServerClusterConfigImpl + func (s *ServerClusterConfigImpl) GetNamespace() string + func (s *ServerClusterConfigImpl) GetRefreshInterval() time.Duration + func (s *ServerClusterConfigImpl) GetService() string + func (s *ServerClusterConfigImpl) SetDefault() + func (s *ServerClusterConfigImpl) SetNamespace(namespace string) + func (s *ServerClusterConfigImpl) SetRefreshInterval(interval time.Duration) + func (s *ServerClusterConfigImpl) SetService(service string) + func (s *ServerClusterConfigImpl) Verify() error + type ServerConnectorConfig interface + GetAddresses func() []string + GetConnectTimeout func() time.Duration + GetConnectionIdleTimeout func() time.Duration + GetMessageTimeout func() time.Duration + GetProtocol func() string + GetReconnectInterval func() time.Duration + GetRequestQueueSize func() int32 + GetServerSwitchInterval func() time.Duration + SetAddresses func([]string) + SetConnectTimeout func(time.Duration) + SetConnectionIdleTimeout func(time.Duration) + SetMessageTimeout func(time.Duration) + SetProtocol func(string) + SetReconnectInterval func(time.Duration) + SetRequestQueueSize func(int32) + SetServerSwitchInterval func(time.Duration) + type ServerConnectorConfigImpl struct + Addresses []string + ConnectTimeout *time.Duration + ConnectionIdleTimeout *time.Duration + MessageTimeout *time.Duration + Plugin PluginConfigs + Protocol string + ReconnectInterval *time.Duration + RequestQueueSize *int32 + ServerSwitchInterval *time.Duration + func (s *ServerConnectorConfigImpl) GetAddresses() []string + func (s *ServerConnectorConfigImpl) GetConnectTimeout() time.Duration + func (s *ServerConnectorConfigImpl) GetConnectionIdleTimeout() time.Duration + func (s *ServerConnectorConfigImpl) GetMessageTimeout() time.Duration + func (s *ServerConnectorConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (s *ServerConnectorConfigImpl) GetProtocol() string + func (s *ServerConnectorConfigImpl) GetReconnectInterval() time.Duration + func (s *ServerConnectorConfigImpl) GetRequestQueueSize() int32 + func (s *ServerConnectorConfigImpl) GetServerSwitchInterval() time.Duration + func (s *ServerConnectorConfigImpl) Init() + func (s *ServerConnectorConfigImpl) SetAddresses(addresses []string) + func (s *ServerConnectorConfigImpl) SetConnectTimeout(timeout time.Duration) + func (s *ServerConnectorConfigImpl) SetConnectionIdleTimeout(timeout time.Duration) + func (s *ServerConnectorConfigImpl) SetDefault() + func (s *ServerConnectorConfigImpl) SetMessageTimeout(timeout time.Duration) + func (s *ServerConnectorConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (s *ServerConnectorConfigImpl) SetProtocol(protocol string) + func (s *ServerConnectorConfigImpl) SetReconnectInterval(interval time.Duration) + func (s *ServerConnectorConfigImpl) SetRequestQueueSize(queueSize int32) + func (s *ServerConnectorConfigImpl) SetServerSwitchInterval(interval time.Duration) + func (s *ServerConnectorConfigImpl) Verify() error + type ServerServices map[ClusterType]ClusterService + func GetServerServices(cfg Configuration) ServerServices + func (s ServerServices) GetClusterService(clsType ClusterType) *ClusterService + type ServiceRouterConfig interface + GetAfterChain func() []string + GetChain func() []string + GetNearbyConfig func() NearbyConfig + GetPercentOfMinInstances func() float64 + IsEnableRecoverAll func() bool + SetChain func([]string) + SetEnableRecoverAll func(bool) + SetPercentOfMinInstances func(float64) + type ServiceRouterConfigImpl struct + AfterChain []string + Chain []string + EnableRecoverAll *bool + PercentOfMinInstances *float64 + Plugin PluginConfigs + func (s *ServiceRouterConfigImpl) GetAfterChain() []string + func (s *ServiceRouterConfigImpl) GetChain() []string + func (s *ServiceRouterConfigImpl) GetNearbyConfig() NearbyConfig + func (s *ServiceRouterConfigImpl) GetPercentOfMinInstances() float64 + func (s *ServiceRouterConfigImpl) GetPluginConfig(pluginName string) BaseConfig + func (s *ServiceRouterConfigImpl) Init() + func (s *ServiceRouterConfigImpl) IsEnableRecoverAll() bool + func (s *ServiceRouterConfigImpl) SetAfterChain(chain []string) + func (s *ServiceRouterConfigImpl) SetChain(chain []string) + func (s *ServiceRouterConfigImpl) SetDefault() + func (s *ServiceRouterConfigImpl) SetEnableRecoverAll(recoverAll bool) + func (s *ServiceRouterConfigImpl) SetPercentOfMinInstances(percent float64) + func (s *ServiceRouterConfigImpl) SetPluginConfig(pluginName string, value BaseConfig) error + func (s *ServiceRouterConfigImpl) Verify() error + type ServiceSpecific struct + CircuitBreaker *CircuitBreakerConfigImpl + Namespace string + Service string + ServiceRouter *ServiceRouterConfigImpl + func (s *ServiceSpecific) GetServiceCircuitBreaker() CircuitBreakerConfig + func (s *ServiceSpecific) GetServiceRouter() ServiceRouterConfig + func (s *ServiceSpecific) Init() + func (s *ServiceSpecific) SetDefault() + func (s *ServiceSpecific) Verify() error + type ServiceSpecificConfig interface + GetServiceCircuitBreaker func() CircuitBreakerConfig + GetServiceRouter func() ServiceRouterConfig + type ServicesSpecificImpl struct + Services []*ServiceSpecific + type StatReporterConfig interface + GetChain func() []string + IsEnable func() bool + SetChain func([]string) + SetEnable func(bool) + type StatReporterConfigImpl struct + Chain []string + Enable *bool + Plugin PluginConfigs + func (s *StatReporterConfigImpl) GetChain() []string + func (s *StatReporterConfigImpl) GetPluginConfig(name string) BaseConfig + func (s *StatReporterConfigImpl) Init() + func (s *StatReporterConfigImpl) IsEnable() bool + func (s *StatReporterConfigImpl) SetChain(chain []string) + func (s *StatReporterConfigImpl) SetDefault() + func (s *StatReporterConfigImpl) SetEnable(enable bool) + func (s *StatReporterConfigImpl) SetPluginConfig(plugName string, value BaseConfig) error + func (s *StatReporterConfigImpl) Verify() error + type SystemConfig interface + GetDiscoverCluster func() ServerClusterConfig + GetHealthCheckCluster func() ServerClusterConfig + GetMode func() model.RunMode + GetMonitorCluster func() ServerClusterConfig + GetVariable func(key string) (string, bool) + SetMode func(model.RunMode) + SetVariable func(key, value string) + UnsetVariable func(key string) + type SystemConfigImpl struct + DiscoverCluster *ServerClusterConfigImpl + HealthCheckCluster *ServerClusterConfigImpl + Mode model.RunMode + MonitorCluster *ServerClusterConfigImpl + Variables map[string]string + func (s *SystemConfigImpl) GetDiscoverCluster() ServerClusterConfig + func (s *SystemConfigImpl) GetHealthCheckCluster() ServerClusterConfig + func (s *SystemConfigImpl) GetMode() model.RunMode + func (s *SystemConfigImpl) GetMonitorCluster() ServerClusterConfig + func (s *SystemConfigImpl) GetVariable(key string) (string, bool) + func (s *SystemConfigImpl) Init() + func (s *SystemConfigImpl) SetDefault() + func (s *SystemConfigImpl) SetMode(mode model.RunMode) + func (s *SystemConfigImpl) SetVariable(key, value string) + func (s *SystemConfigImpl) UnsetVariable(key string) + func (s *SystemConfigImpl) Verify() error + type When string