Versions in this module Expand all Collapse all v0 v0.7.1 Aug 16, 2018 Changes in this version + const DefaultConfigPath + const DefaultRouterType + func BackOffKind(source, service string) string + func BackOffMaxMs(source, service string) int + func BackOffMinMs(source, service string) int + func GetGlobalAppID() string + func GetRouterEndpoints() string + func GetRouterReference() map[string]model.ReferencesStruct + func GetRouterType() string + func GetServiceDiscoveryConfigPath() string v0.5.1 May 31, 2018 Changes in this version + const DefaultAbortPercent + const DefaultAbortStatus + const DefaultBackoffKind + const DefaultCircuitBreakerEnabled + const DefaultCircuitBreakerForceClosed + const DefaultCircuitBreakerForceOpen + const DefaultDelayPercent + const DefaultErrorPercentThreshold + const DefaultFailedTimes + const DefaultFallbackEnable + const DefaultForceFallback + const DefaultMaxConcurrent + const DefaultRequestVolumeThreshold + const DefaultSessionTimeout + const DefaultSleepWindow + const DefaultStrategy + const DefaultTimeout + const DefaultTimeoutEnabled + const FixedPrefix + const LoadBalance + const NamespaceCircuitBreaker + const NamespaceFallback + const NamespaceFallbackpolicy + const NamespaceIsolation + const PolicyNull + const PolicyThrowException + const PropertyAbort + const PropertyConsumer + const PropertyDelay + const PropertyEnabled + const PropertyErrorThresholdPercentage + const PropertyFault + const PropertyFixedDelay + const PropertyForce + const PropertyForceClosed + const PropertyForceOpen + const PropertyGlobal + const PropertyGovernance + const PropertyHTTPStatus + const PropertyMaxConcurrentRequests + const PropertyOperations + const PropertyPercent + const PropertyPolicy + const PropertyProtocol + const PropertyRequestVolumeThreshold + const PropertySchema + const PropertySleepWindowInMilliseconds + const PropertyTimeoutEnabled + const PropertyTimeoutInMilliseconds + var ErrNoName = errors.New("Microservice name is missing in description file") + var GlobalDefinition *model.GlobalCfg + var HystrixConfig *model.HystrixConfigWrapper + var MicroserviceDefinition *model.MicroserviceCfg + var NodeIP string + var PaasLagerDefinition *model.PassLagerCfg + var RouterDefinition *model.RouterConfig + var SelfMetadata map[string]string + var SelfServiceID string + var SelfServiceName string + var SelfVersion string + func GetAbortPercent(protocol, microServiceName, schema, operation string) int + func GetAbortStatus(protocol, microServiceName, schema, operation string) int + func GetBackOff(source, service string) backoff.BackOff + func GetCircuitBreakerEnabled(command, t string) bool + func GetCircuitBreakerEnabledKey(command string) string + func GetContractDiscoveryAPIVersion() string + func GetContractDiscoveryAddress() string + func GetContractDiscoveryDisable() bool + func GetContractDiscoveryTenant() string + func GetContractDiscoveryType() string + func GetDefaultCircuitBreakerEnabledKey(t string) string + func GetDefaultErrorPercentThreshold(t string) string + func GetDefaultFallbackPolicyKey(t string) string + func GetDefaultForceCloseKey(t string) string + func GetDefaultForceFallbackKey(t string) string + func GetDefaultForceOpenKey(t string) string + func GetDefaultGetFallbackEnabledKey(t string) string + func GetDefaultMaxConcurrentKey(t string) string + func GetDefaultRequestVolumeThresholdKey(t string) string + func GetDefaultSleepWindowKey(t string) string + func GetDefaultTimeEnabledKey(t string) string + func GetDefaultTimeoutKey(t string) string + func GetDelayPercent(protocol, microServiceName, schema, operation string) int + func GetErrorPercentThreshold(command, t string) int + func GetErrorPercentThresholdKey(command string) string + func GetFallbackEnabled(command, t string) bool + func GetFallbackEnabledKey(command string) string + func GetFallbackPolicyKey(command string) string + func GetFaultAbortHTTPStatusKey(key, protocol string) string + func GetFaultAbortPercentKey(key, protocol string) string + func GetFaultDelayPercentKey(key, protocol string) string + func GetFaultFixedDelayKey(key, protocol string) string + func GetFaultInjectionGlobalKey() string + func GetFaultInjectionOperationKey(microServiceName, schema, operation string) string + func GetFaultInjectionSchemaKey(microServiceName, schema string) string + func GetFaultInjectionServiceKey(microServiceName string) string + func GetFilterNamesKey() string + func GetFixedDelay(protocol, microServiceName, schema, operation string) time.Duration + func GetForceClose(service, t string) bool + func GetForceCloseKey(command string) string + func GetForceFallback(service, t string) bool + func GetForceFallbackKey(command string) string + func GetForceOpen(service, t string) bool + func GetForceOpenKey(command string) string + func GetHystrixConfig() *model.HystrixConfig + func GetHystrixSpecificKey(namespace, cmd, property string) string + func GetLoadBalancing() *model.LoadBalancing + func GetMaxConcurrentKey(command string) string + func GetMaxConcurrentRequests(command, t string) int + func GetPolicy(service, t string) string + func GetRegistratorAPIVersion() string + func GetRegistratorAddress() string + func GetRegistratorAutoRegister() string + func GetRegistratorDisable() bool + func GetRegistratorScope() string + func GetRegistratorTenant() string + func GetRegistratorType() string + func GetRequestVolumeThreshold(command, t string) int + func GetRequestVolumeThresholdKey(command string) string + func GetRetryOnNext(source, service string) int + func GetRetryOnSame(source, service string) int + func GetServerListFilters() (filters []string) + func GetServiceDiscoveryAPIVersion() string + func GetServiceDiscoveryAddress() string + func GetServiceDiscoveryDisable() bool + func GetServiceDiscoveryHealthCheck() bool + func GetServiceDiscoveryRefreshInterval() string + func GetServiceDiscoveryTenant() string + func GetServiceDiscoveryType() string + func GetServiceDiscoveryWatch() bool + func GetSessionTimeout(source, service string) int + func GetSleepWindow(command, t string) int + func GetSleepWindowKey(command string) string + func GetStrategyName(source, service string) string + func GetTimeEnabledKey(command string) string + func GetTimeout(command, t string) int + func GetTimeoutEnabled(service, t string) bool + func GetTimeoutKey(command string) string + func Init() error + func ReadHystrixFromArchaius() error + func ReadLBFromArchaius() error + func ReadMicroserviceConfigFromBytes(data []byte) error + func RetryEnabled(source, service string) bool + func StrategySuccessiveFailedTimes(source, service string) int