Versions in this module Expand all Collapse all v3 v3.1.2 Feb 5, 2024 Changes in this version + const MaxWheelTimeSpan + var DumpHeapShutdownSignals = []os.Signal — darwin/amd64, linux/amd64, windows/amd64 + var ShutdownSignals = []os.Signal — darwin/amd64, linux/amd64, windows/amd64 + func BeforeShutdown() + func GetCallback(name string) func(response common.CallbackResponse) + func GetClientTlsConfigBuilder() getty.TlsConfigBuilder + func GetConfigResolver(conf *loaderConf) *koanf.Koanf + func GetConsumerService(name string) common.RPCService + func GetConsumerServiceByInterfaceName(interfaceName string) common.RPCService + func GetConsumerServiceMap() map[string]common.RPCService + func GetDefineValue(key string, default_value interface{}) interface + func GetProtocolsInstance() map[string]*ProtocolConfig + func GetProviderService(name string) common.RPCService + func GetProviderServiceMap() map[string]common.RPCService + func GetRPCService(name string) common.RPCService + func GetServerTlsConfigBuilder() getty.TlsConfigBuilder + func IsProvider() bool + func Load(opts ...LoaderConfOption) error + func NewLoaderConf(opts ...LoaderConfOption) *loaderConf + func RPCService(service common.RPCService) + func SetClientTlsConfigBuilder(configBuilder getty.TlsConfigBuilder) + func SetConsumerConfig(c ConsumerConfig) + func SetConsumerService(service common.RPCService) + func SetConsumerServiceByInterfaceName(interfaceName string, srv common.RPCService) + func SetProviderService(service common.RPCService) + func SetRootConfig(r RootConfig) + func SetServerTlsConfigBuilder(configBuilder getty.TlsConfigBuilder) + type ApplicationConfig struct + Environment string + Group string + MetadataType string + Module string + Name string + Organization string + Owner string + Version string + func GetApplicationConfig() *ApplicationConfig + func (ApplicationConfig) Prefix() string + func (ac *ApplicationConfig) Init() error + type ApplicationConfigBuilder struct + func NewApplicationConfigBuilder() *ApplicationConfigBuilder + func (acb *ApplicationConfigBuilder) Build() *ApplicationConfig + func (acb *ApplicationConfigBuilder) SetEnvironment(environment string) *ApplicationConfigBuilder + func (acb *ApplicationConfigBuilder) SetMetadataType(metadataType string) *ApplicationConfigBuilder + func (acb *ApplicationConfigBuilder) SetModule(module string) *ApplicationConfigBuilder + func (acb *ApplicationConfigBuilder) SetName(name string) *ApplicationConfigBuilder + func (acb *ApplicationConfigBuilder) SetOrganization(organization string) *ApplicationConfigBuilder + func (acb *ApplicationConfigBuilder) SetOwner(owner string) *ApplicationConfigBuilder + func (acb *ApplicationConfigBuilder) SetVersion(version string) *ApplicationConfigBuilder + type CenterConfig struct + Address string + AppID string + Cluster string + DataId string + FileExtension string + Group string + Namespace string + Params map[string]string + Password string + Protocol string + Timeout string + Username string + func (CenterConfig) Prefix() string + func (c *CenterConfig) CreateDynamicConfiguration() (config_center.DynamicConfiguration, error) + func (c *CenterConfig) GetDynamicConfiguration() (config_center.DynamicConfiguration, error) + func (c *CenterConfig) GetUrlMap() url.Values + func (c *CenterConfig) Init(rc *RootConfig) error + type ConfigCenterConfigBuilder struct + func NewConfigCenterConfigBuilder() *ConfigCenterConfigBuilder + func (ccb *ConfigCenterConfigBuilder) Build() *CenterConfig + func (ccb *ConfigCenterConfigBuilder) SetAddress(address string) *ConfigCenterConfigBuilder + func (ccb *ConfigCenterConfigBuilder) SetDataID(dataID string) *ConfigCenterConfigBuilder + func (ccb *ConfigCenterConfigBuilder) SetGroup(group string) *ConfigCenterConfigBuilder + func (ccb *ConfigCenterConfigBuilder) SetNamespace(namespace string) *ConfigCenterConfigBuilder + func (ccb *ConfigCenterConfigBuilder) SetPassword(password string) *ConfigCenterConfigBuilder + func (ccb *ConfigCenterConfigBuilder) SetProtocol(protocol string) *ConfigCenterConfigBuilder + func (ccb *ConfigCenterConfigBuilder) SetUserName(userName string) *ConfigCenterConfigBuilder + type ConsumerConfig struct + AdaptiveService bool + Check bool + Filter string + FilterConf interface{} + MaxWaitTimeForServiceDiscovery string + Protocol string + ProxyFactory string + References map[string]*ReferenceConfig + RegistryIDs []string + RequestTimeout string + TracingKey string + func GetConsumerConfig() *ConsumerConfig + func (ConsumerConfig) Prefix() string + func (cc *ConsumerConfig) DynamicUpdateProperties(newConsumerConfig *ConsumerConfig) + func (cc *ConsumerConfig) Init(rc *RootConfig) error + func (cc *ConsumerConfig) Load() + type ConsumerConfigBuilder struct + func NewConsumerConfigBuilder() *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) AddReference(referenceKey string, referenceConfig *ReferenceConfig) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) Build() *ConsumerConfig + func (ccb *ConsumerConfigBuilder) SetCheck(check bool) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetFilter(filter string) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetFilterConf(filterConf interface{}) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetMaxWaitTimeForServiceDiscovery(maxWaitTimeForServiceDiscovery string) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetProxyFactory(proxyFactory string) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetReferences(references map[string]*ReferenceConfig) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetRegistryIDs(RegistryIDs ...string) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetRequestTimeout(requestTimeout string) *ConsumerConfigBuilder + func (ccb *ConsumerConfigBuilder) SetRootConfig(rootConfig *RootConfig) *ConsumerConfigBuilder + type CustomConfig struct + ConfigMap map[string]interface{} + func (*CustomConfig) Prefix() string + func (c *CustomConfig) GetDefineValue(key string, default_value interface{}) interface{} + func (c *CustomConfig) Init() error + type CustomConfigBuilder struct + func NewCustomConfigBuilder() *CustomConfigBuilder + func (ccb *CustomConfigBuilder) Build() *CustomConfig + func (ccb *CustomConfigBuilder) SetDefineConfig(key string, val interface{}) *CustomConfigBuilder + type EncoderConfig struct + CallerKey string + EncodeCaller string + EncodeDuration string + EncodeLevel string + EncodeTime string + LevelKey string + MessageKey string + NameKey string + Params map[string]string + StacktraceKey string + TimeKey string + type LoaderConfOption interface + func WithBytes(bytes []byte) LoaderConfOption + func WithDelim(delim string) LoaderConfOption + func WithGenre(suffix string) LoaderConfOption + func WithPath(path string) LoaderConfOption + func WithRootConfig(rc *RootConfig) LoaderConfOption + func WithSuffix(suffix file.Suffix) LoaderConfOption + type LoggerConfig struct + LumberjackConfig *lumberjack.Logger + ZapConfig ZapConfig + func (LoggerConfig) Prefix() string + func (lc *LoggerConfig) Init() error + type LoggerConfigBuilder struct + func NewLoggerConfigBuilder() *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) Build() *LoggerConfig + func (lcb *LoggerConfigBuilder) SetLumberjackConfig(lumberjackConfig *lumberjack.Logger) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetZapConfig(zapConfig ZapConfig) *LoggerConfigBuilder + type MetadataReportConfig struct + Address string + Group string + Namespace string + Password string + Protocol string + Timeout string + Username string + func GetMetadataReportConfg() *MetadataReportConfig + func (MetadataReportConfig) Prefix() string + func (mc *MetadataReportConfig) Init(rc *RootConfig) error + func (mc *MetadataReportConfig) IsValid() bool + func (mc *MetadataReportConfig) StartMetadataReport() error + func (mc *MetadataReportConfig) ToUrl() (*common.URL, error) + type MetadataReportConfigBuilder struct + func NewMetadataReportConfigBuilder() *MetadataReportConfigBuilder + func (mrcb *MetadataReportConfigBuilder) Build() *MetadataReportConfig + func (mrcb *MetadataReportConfigBuilder) SetAddress(address string) *MetadataReportConfigBuilder + func (mrcb *MetadataReportConfigBuilder) SetGroup(group string) *MetadataReportConfigBuilder + func (mrcb *MetadataReportConfigBuilder) SetPassword(password string) *MetadataReportConfigBuilder + func (mrcb *MetadataReportConfigBuilder) SetProtocol(protocol string) *MetadataReportConfigBuilder + func (mrcb *MetadataReportConfigBuilder) SetTimeout(timeout string) *MetadataReportConfigBuilder + func (mrcb *MetadataReportConfigBuilder) SetUsername(username string) *MetadataReportConfigBuilder + type MethodConfig struct + ExecuteLimit string + ExecuteLimitRejectedHandler string + InterfaceId string + InterfaceName string + LoadBalance string + Name string + RequestTimeout string + Retries string + Sticky bool + TpsLimitInterval string + TpsLimitRate string + TpsLimitStrategy string + Weight int64 + func (m *MethodConfig) Init() error + func (m *MethodConfig) Prefix() string + type MetricConfig struct + Enable bool + Mode string + Namespace string + Path string + Port string + PushGatewayAddress string + SummaryMaxAge int64 + func GetMetricConfig() *MetricConfig + func (mc *MetricConfig) Init() error + func (mc *MetricConfig) ToReporterConfig() *metrics.ReporterConfig + type MetricConfigBuilder struct + func NewMetricConfigBuilder() *MetricConfigBuilder + func (mcb *MetricConfigBuilder) Build() *MetricConfig + type MockService struct + func (*MockService) GetUser(ctx context.Context, itf []interface{}, str *struct{}) error + func (*MockService) GetUser1(ctx context.Context, itf []interface{}, str *struct{}) error + func (*MockService) Reference() string + type ProfilesConfig struct + Active string + func (ProfilesConfig) Prefix() string + type ProtocolConfig struct + Ip string + Name string + Params interface{} + Port string + func (ProtocolConfig) Prefix() string + func (p *ProtocolConfig) Init() error + type ProtocolConfigBuilder struct + func NewProtocolConfigBuilder() *ProtocolConfigBuilder + func (pcb *ProtocolConfigBuilder) Build() *ProtocolConfig + func (pcb *ProtocolConfigBuilder) SetIp(ip string) *ProtocolConfigBuilder + func (pcb *ProtocolConfigBuilder) SetName(name string) *ProtocolConfigBuilder + func (pcb *ProtocolConfigBuilder) SetParams(params interface{}) *ProtocolConfigBuilder + func (pcb *ProtocolConfigBuilder) SetPort(port string) *ProtocolConfigBuilder + type ProviderConfig struct + AdaptiveService bool + AdaptiveServiceVerbose bool + ConfigType map[string]string + Filter string + FilterConf interface{} + ProtocolIDs []string + ProxyFactory string + Register bool + RegistryIDs []string + Services map[string]*ServiceConfig + TracingKey string + func GetProviderConfig() *ProviderConfig + func (ProviderConfig) Prefix() string + func (c *ProviderConfig) Init(rc *RootConfig) error + func (c *ProviderConfig) Load() + type ProviderConfigBuilder struct + func NewProviderConfigBuilder() *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) AddConfigType(key, value string) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) AddService(serviceID string, serviceConfig *ServiceConfig) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) Build() *ProviderConfig + func (pcb *ProviderConfigBuilder) SetConfigType(configType map[string]string) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) SetFilter(filter string) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) SetFilterConf(filterConf interface{}) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) SetProxyFactory(proxyFactory string) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) SetRegister(register bool) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) SetRegistryIDs(RegistryIDs ...string) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) SetRootConfig(rootConfig *RootConfig) *ProviderConfigBuilder + func (pcb *ProviderConfigBuilder) SetServices(services map[string]*ServiceConfig) *ProviderConfigBuilder + type ReferenceConfig struct + Async bool + Check *bool + Cluster string + Filter string + ForceTag bool + Generic string + Group string + InterfaceName string + Loadbalance string + Methods []*MethodConfig + Params map[string]string + Protocol string + ProvidedBy string + RegistryIDs []string + RequestTimeout string + Retries string + Serialization string + Sticky bool + TracingKey string + URL string + Version string + func (rc *ReferenceConfig) GenericLoad(id string) + func (rc *ReferenceConfig) GetInvoker() protocol.Invoker + func (rc *ReferenceConfig) GetProxy() *proxy.Proxy + func (rc *ReferenceConfig) GetRPCService() common.RPCService + func (rc *ReferenceConfig) Implement(v common.RPCService) + func (rc *ReferenceConfig) Init(root *RootConfig) error + func (rc *ReferenceConfig) Prefix() string + func (rc *ReferenceConfig) Refer(srv interface{}) + type ReferenceConfigBuilder struct + func NewReferenceConfigBuilder() *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) Build() *ReferenceConfig + func (pcb *ReferenceConfigBuilder) SetCluster(cluster string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetGeneric(generic bool) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetInterface(interfaceName string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetProtocol(protocol string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetRegistryIDs(registryIDs ...string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetSerialization(serialization string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetURL(url string) *ReferenceConfigBuilder + type RegistryConfig struct + Address string + Group string + Namespace string + Params map[string]string + Password string + Preferred bool + Protocol string + RegistryType string + Simplified bool + TTL string + Timeout string + Username string + Weight int64 + Zone string + func NewRegistryConfig(opts ...RegistryConfigOpt) *RegistryConfig + func NewRegistryConfigWithProtocolDefaultPort(protocol string) *RegistryConfig + func (RegistryConfig) Prefix() string + func (c *RegistryConfig) DynamicUpdateProperties(updateRegistryConfig *RegistryConfig) + func (c *RegistryConfig) GetInstance(roleType common.RoleType) (registry.Registry, error) + func (c *RegistryConfig) Init() error + type RegistryConfigBuilder struct + func NewRegistryConfigBuilder() *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) AddParam(key, value string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) Build() *RegistryConfig + func (rcb *RegistryConfigBuilder) SetAddress(address string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetGroup(group string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetNamespace(namespace string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetParams(params map[string]string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetPassword(password string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetPreferred(preferred bool) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetProtocol(protocol string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetRegistryType(registryType string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetSimplified(simplified bool) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetTTL(ttl string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetTimeout(timeout string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetUsername(username string) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetWeight(weight int64) *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) SetZone(zone string) *RegistryConfigBuilder + type RegistryConfigOpt func(config *RegistryConfig) *RegistryConfig + func WithRegistryAddress(addr string) RegistryConfigOpt + func WithRegistryGroup(group string) RegistryConfigOpt + func WithRegistryParams(params map[string]string) RegistryConfigOpt + func WithRegistryPassword(psw string) RegistryConfigOpt + func WithRegistryPreferred(preferred bool) RegistryConfigOpt + func WithRegistryProtocol(regProtocol string) RegistryConfigOpt + func WithRegistrySimplified(simplified bool) RegistryConfigOpt + func WithRegistryTTL(ttl string) RegistryConfigOpt + func WithRegistryTimeOut(timeout string) RegistryConfigOpt + func WithRegistryUserName(userName string) RegistryConfigOpt + func WithRegistryWeight(weight int64) RegistryConfigOpt + type RemoteConfig struct + Address string + Params map[string]string + Password string + Protocol string + Timeout string + Username string + func (rc *RemoteConfig) GetParam(key string, def string) string + func (rc *RemoteConfig) GetTimeout() time.Duration + func (rc *RemoteConfig) Init() error + func (rc *RemoteConfig) Prefix() string + func (rc *RemoteConfig) ToURL() (*common.URL, error) + type RemoteConfigBuilder struct + func NewRemoteConfigBuilder() *RemoteConfigBuilder + func (rcb *RemoteConfigBuilder) AddParam(key, value string) *RemoteConfigBuilder + func (rcb *RemoteConfigBuilder) Build() *RemoteConfig + func (rcb *RemoteConfigBuilder) SetAddress(address string) *RemoteConfigBuilder + func (rcb *RemoteConfigBuilder) SetParams(params map[string]string) *RemoteConfigBuilder + func (rcb *RemoteConfigBuilder) SetPassword(password string) *RemoteConfigBuilder + func (rcb *RemoteConfigBuilder) SetProtocol(protocol string) *RemoteConfigBuilder + func (rcb *RemoteConfigBuilder) SetTimeout(timeout string) *RemoteConfigBuilder + func (rcb *RemoteConfigBuilder) SetUsername(username string) *RemoteConfigBuilder + type RootConfig struct + Application *ApplicationConfig + CacheFile string + ConfigCenter *CenterConfig + Consumer *ConsumerConfig + Custom *CustomConfig + EventDispatcherType string + Logger *LoggerConfig + MetadataReport *MetadataReportConfig + Metric *MetricConfig + Profiles *ProfilesConfig + Protocols map[string]*ProtocolConfig + Provider *ProviderConfig + Registries map[string]*RegistryConfig + Router []*RouterConfig + Shutdown *ShutdownConfig + Tracing map[string]*TracingConfig + func GetRootConfig() *RootConfig + func (RootConfig) Prefix() string + func (rc *RootConfig) Init() error + func (rc *RootConfig) Process(event *config_center.ConfigChangeEvent) + func (rc *RootConfig) Start() + type RootConfigBuilder struct + func NewRootConfigBuilder() *RootConfigBuilder + func (rb *RootConfigBuilder) AddProtocol(protocolID string, protocolConfig *ProtocolConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) AddRegistry(registryID string, registryConfig *RegistryConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) Build() *RootConfig + func (rb *RootConfigBuilder) SetApplication(application *ApplicationConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetCacheFile(cacheFile string) *RootConfigBuilder + func (rb *RootConfigBuilder) SetConfigCenter(configCenterConfig *CenterConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetConsumer(consumer *ConsumerConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetCustom(customConfig *CustomConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetEventDispatcherType(eventDispatcherType string) *RootConfigBuilder + func (rb *RootConfigBuilder) SetLogger(logger *LoggerConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetMetadataReport(metadataReport *MetadataReportConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetMetric(metric *MetricConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetProtocols(protocols map[string]*ProtocolConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetProvider(provider *ProviderConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetRegistries(registries map[string]*RegistryConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetRouter(router []*RouterConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetShutDown(shutDownConfig *ShutdownConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetShutdown(shutdown *ShutdownConfig) *RootConfigBuilder + type RouterConfig struct + Conditions []string + Enabled bool + Force bool + Key string + Priority int + Runtime bool + Scope string + Tags []Tag + Valid bool + func (RouterConfig) Prefix() string + func (c *RouterConfig) Init() error + type RouterConfigBuilder struct + func NewRouterConfigBuilder() *RouterConfigBuilder + func (rcb *RouterConfigBuilder) AddCondition(condition string) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) AddTag(tag Tag) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) Build() *RouterConfig + func (rcb *RouterConfigBuilder) SetConditions(conditions []string) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetEnabled(enabled bool) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetForce(force bool) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetKey(key string) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetPriority(priority int) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetRuntime(runtime bool) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetScope(scope string) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetTags(tags []Tag) *RouterConfigBuilder + func (rcb *RouterConfigBuilder) SetValid(valid bool) *RouterConfigBuilder + type ServiceConfig struct + AccessLog string + Auth string + Cluster string + ExecuteLimit string + ExecuteLimitRejectedHandler string + Filter string + Group string + GrpcMaxMessageSize int + Interface string + Loadbalance string + Methods []*MethodConfig + NotRegister bool + ParamSign string + Params map[string]string + ProtocolIDs []string + ProxyFactoryKey string + RCProtocolsMap map[string]*ProtocolConfig + RCRegistriesMap map[string]*RegistryConfig + RegistryIDs []string + Retries string + Serialization string + Tag string + Token string + TpsLimitInterval string + TpsLimitRate string + TpsLimitRejectedHandler string + TpsLimitStrategy string + TpsLimiter string + TracingKey string + Version string + Warmup string + func (s *ServiceConfig) Export() error + func (s *ServiceConfig) GetExportedUrls() []*common.URL + func (s *ServiceConfig) Implement(rpcService common.RPCService) + func (s *ServiceConfig) Init(rc *RootConfig) error + func (s *ServiceConfig) InitExported() + func (s *ServiceConfig) IsExport() bool + func (s *ServiceConfig) Prefix() string + func (s *ServiceConfig) Unexport() + type ServiceConfigBuilder struct + func NewServiceConfigBuilder() *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) AddRCProtocol(protocolName string, protocolConfig *ProtocolConfig) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) AddRCRegistry(registryName string, registryConfig *RegistryConfig) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) Build() *ServiceConfig + func (pcb *ServiceConfigBuilder) SetCluster(cluster string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetGroup(group string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetInterface(interfaceName string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetLoadBalancce(lb string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetMetadataType(setMetadataType string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetNotRegister(notRegister bool) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetProtocolIDs(protocolIDs ...string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetProxyFactoryKey(proxyFactoryKey string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetRPCService(service common.RPCService) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetRegistryIDs(registryIDs ...string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetSerialization(serialization string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetServiceID(id string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetVersion(version string) *ServiceConfigBuilder + func (pcb *ServiceConfigBuilder) SetWarmUpTie(warmUp string) *ServiceConfigBuilder + type ServiceDiscoveryConfig struct + Group string + Protocol string + RemoteRef string + func (ServiceDiscoveryConfig) Init() error + func (ServiceDiscoveryConfig) Prefix() string + type ServiceDiscoveryConfigBuilder struct + func NewServiceDiscoveryConfigBuilder() *ServiceDiscoveryConfigBuilder + func (sdcb *ServiceDiscoveryConfigBuilder) Build() *ServiceDiscoveryConfig + func (sdcb *ServiceDiscoveryConfigBuilder) SetGroup(group string) *ServiceDiscoveryConfigBuilder + func (sdcb *ServiceDiscoveryConfigBuilder) SetProtocol(protocol string) *ServiceDiscoveryConfigBuilder + func (sdcb *ServiceDiscoveryConfigBuilder) SetRemoteRef(remoteRef string) *ServiceDiscoveryConfigBuilder + type Setter interface + Set func(name string, config interface{}) + type ShutdownConfig struct + ConsumerActiveCount atomic.Int32 + ConsumerUpdateWaitTime string + InternalSignal bool + ProviderActiveCount atomic.Int32 + RejectRequest atomic.Bool + RejectRequestHandler string + StepTimeout string + Timeout string + func GetShutDown() *ShutdownConfig + func (config *ShutdownConfig) GetConsumerUpdateWaitTime() time.Duration + func (config *ShutdownConfig) GetStepTimeout() time.Duration + func (config *ShutdownConfig) GetTimeout() time.Duration + func (config *ShutdownConfig) Init() error + func (config *ShutdownConfig) Prefix() string + type ShutdownConfigBuilder struct + func NewShutDownConfigBuilder() *ShutdownConfigBuilder + func (scb *ShutdownConfigBuilder) Build() *ShutdownConfig + func (scb *ShutdownConfigBuilder) SetInternalSignal(internalSignal bool) *ShutdownConfigBuilder + func (scb *ShutdownConfigBuilder) SetRejectRequest(rejectRequest bool) *ShutdownConfigBuilder + func (scb *ShutdownConfigBuilder) SetRejectRequestHandler(rejectRequestHandler string) *ShutdownConfigBuilder + func (scb *ShutdownConfigBuilder) SetStepTimeout(stepTimeout string) *ShutdownConfigBuilder + func (scb *ShutdownConfigBuilder) SetTimeout(timeout string) *ShutdownConfigBuilder + type Tag struct + Addresses []string + Name string + type TracingConfig struct + Address string + Name string + ServiceName string + UseAgent bool + func GetTracingConfig(tracingKey string) *TracingConfig + func (TracingConfig) Prefix() string + func (c *TracingConfig) Init() error + type ZapConfig struct + Development bool + DisableCaller bool + DisableStacktrace bool + EncoderConfig EncoderConfig + Encoding string + ErrorOutputPaths []string + InitialFields map[string]interface{} + Level string + OutputPaths []string
Go to main page